Commands mapping

This page maps each Valkey or Redis command to the Redisson object and methods that issue it. Commands are grouped by family; within each group the three API columns show the equivalent call on the synchronous/asynchronous API (Redisson.create(config)), the Reactive API (redisson.reactive()), and the RxJava3 API (redisson.rxJava()).

A dash (-) means the command has no direct equivalent on that API - for instance because it is set through Config rather than called at runtime, or is handled internally by Redisson.

This table lists the commands that map directly to Redisson methods. Redisson also provides distributed features that don't correspond to any single Valkey or Redis command - such as locks and synchronizers, rate limiters, remote and executor services, and near-caching - so they aren't listed here. It also provides higher-level messaging and standard-API layers, including reliable pub/sub, reliable queues, JMS, and JCache (JSR-107).

Strings

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
APPEND	RBinaryStream. getOutputStream().write()	-	-
DECR	RAtomicLong. decrementAndGet() decrementAndGetAsync()	RAtomicLongReactive. decrementAndGet()	RAtomicLongRx. decrementAndGet()
DECRBY	RAtomicLong. addAndGet() addAndGetAsync()	RAtomicLongReactive. addAndGet()	RAtomicLongRx. addAndGet()
GET	RBucket. get() getAsync() RBinaryStream. get() getAsync()	RBucketReactive. get() RBinaryStreamReactive. get()	RBucketRx. get() RBinaryStreamRx. get()
GETEX	RBucket. getAndExpire() getAndExpireAsync() getAndClearExpire() getAndClearExpireAsync()	RBucketReactive. getAndExpire() getAndClearExpire()	RBucketRx. getAndExpire() getAndClearExpire()
GETRANGE	RBinaryStream. getChannel().read()	RBinaryStreamReactive. read()	RBinaryStreamRx. read()
GETSET	RBucket. getAndSet() getAndSetAsync() RAtomicLong. getAndSet() getAndSetAsync() RAtomicDouble. getAndSet() getAndSetAsync()	RBucketReactive. getAndSet() RAtomicLongReactive. getAndSet() RAtomicDoubleReactive. getAndSet()	RBucketRx. getAndSet() RAtomicLongRx. getAndSet() RAtomicDoubleRx. getAndSet()
INCR	RAtomicLong. incrementAndGet() incrementAndGetAsync()	RAtomicLongReactive. incrementAndGet()	RAtomicLongRx. incrementAndGet()
INCRBY	RAtomicLong. addAndGet() addAndGetAsync()	RAtomicLongReactive. addAndGet()	RAtomicLongRx. addAndGet()
INCRBYFLOAT	RAtomicDouble. addAndGet() addAndGetAsync()	RAtomicDoubleReactive. addAndGet()	RAtomicDoubleRx. addAndGet()
LCS	RBucket. findCommon() findCommonAsync() findCommonLength() findCommonLengthAsync()	RBucketReactive. findCommon() findCommonLength()	RBucketRx. findCommon() findCommonLength()
MGET	RBuckets. get() getAsync()	RBucketsReactive. get()	RBucketsRx. get()
MSET	RBuckets. set() setAsync()	RBucketsReactive. set()	RBucketsRx. set()
MSETNX	RBuckets. trySet() trySetAsync()	RBucketsReactive. trySet()	RBucketsRx. trySet()
PSETEX	RBucket. set() setAsync()	RBucketReactive. set()	RBucketRx. set()
SET	RBucket. set() setAsync()	RBucketReactive. set()	RBucketRx. set()
SETEX	RBucket. set() setAsync()	RBucketReactive. set()	RBucketRx. set()
SETNX	RBucket. setIfAbsent() setIfAbsentAsync()	RBucketReactive. setIfAbsent()	RBucketRx. setIfAbsent()
SETRANGE	RBinaryStream. getChannel().write()	RBinaryStreamReactive. write()	RBinaryStreamRx. write()
STRLEN	RBucket. size() sizeAsync()	RBucketReactive. size()	RBucketRx. size()

Bitmaps

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
BITCOUNT	RBitSet. cardinality() cardinalityAsync()	RBitSetReactive. cardinality()	RBitSetRx. cardinality()
BITFIELD	RBitSet. getByte() setByte() incrementAndGetByte() getShort() setShort() incrementAndGetShort() getInteger() setInteger() incrementAndGetInteger() getLong() setLong() incrementAndGetLong()	RBitSetReactive. getByte() setByte() incrementAndGetByte() getShort() setShort() incrementAndGetShort() getInteger() setInteger() incrementAndGetInteger() getLong() setLong() incrementAndGetLong()	RBitSetRx. getByte() setByte() incrementAndGetByte() getShort() setShort() incrementAndGetShort() getInteger() setInteger() incrementAndGetInteger() getLong() setLong() incrementAndGetLong()
BITOP	RBitSet. or() and() xor() orAsync() andAsync() xorAsync()	RBitSetReactive. or() and() xor()	RBitSetRx. or() and() xor()
BITPOS	RBitSet. length() lengthAsync()	RBitSetReactive. length()	RBitSetRx. length()
GETBIT	RBitSet. get() getAsync()	RBitSetReactive. get()	RBitSetRx. get()
SETBIT	RBitSet. set() clear() setAsync() clearAsync()	RBitSetReactive. set() clear()	RBitSetRx. set() clear()

HyperLogLog

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
PFADD	RHyperLogLog. add() addAsync() addAll() addAllAsync()	RHyperLogLogReactive. add() addAll()	RHyperLogLogRx. add() addAll()
PFCOUNT	RHyperLogLog. count() countAsync() countWith() countWithAsync()	RHyperLogLogReactive. count() countWith()	RHyperLogLogRx. count() countWith()
PFMERGE	RHyperLogLog. mergeWith() mergeWithAsync()	RHyperLogLogReactive. mergeWith()	RHyperLogLogRx. mergeWith()

Hashes

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
HDEL	RMap. fastRemove() fastRemoveAsync()	RMapReactive. fastRemove()	RMapRx. fastRemove()
HEXISTS	RMap. containsKey() containsKeyAsync()	RMapReactive. containsKey()	RMapRx. containsKey()
HEXPIRE	RMapCacheNative. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() putAsync() fastPutAsync() putIfAbsentAsync() fastPutIfAbsentAsync() putAllAsync() expireEntryAsync()	RMapCacheNativeReactive. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry()	RMapCacheNativeRx. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry()
HEXPIREAT	RMapCacheNative. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() putAsync() fastPutAsync() putIfAbsentAsync() fastPutIfAbsentAsync() putAllAsync() expireEntryAsync()	RMapCacheNativeReactive. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry()	RMapCacheNativeRx. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry()
HGET	RMap. get() getAsync()	RMapReactive. get()	RMapRx. get()
HGETALL	RMap. readAllEntrySet() readAllEntrySetAsync()	RMapReactive. readAllEntrySet()	RMapRx. readAllEntrySet()
HINCRBY	RMap. addAndGet() addAndGetAsync()	RMapReactive. addAndGet()	RMapRx. addAndGet()
HINCRBYFLOAT	RMap. addAndGet() addAndGetAsync()	RMapReactive. addAndGet()	RMapRx. addAndGet()
HKEYS	RMap. readAllKeySet() readAllKeySetAsync()	RMapReactive. readAllKeySet()	RMapRx. readAllKeySet()
HLEN	RMap. size() sizeAsync()	RMapReactive. size()	RMapRx. size()
HMGET	RMap. getAll() getAllAsync()	RMapReactive. getAll()	RMapRx. getAll()
HMSET	RMap. putAll() putAllAsync()	RMapReactive. putAll()	RMapRx. putAll()
HPERSIST	RMapCacheNative. clearExpire() clearExpireAsync()	RMapCacheNativeReactive. clearExpire()	RMapCacheNativeRx. clearExpire()
HPEXPIRE	RMapCacheNative. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() putAsync() fastPutAsync() putIfAbsentAsync() fastPutIfAbsentAsync() putAllAsync() expireEntryAsync()	RMapCacheNativeReactive. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry()	RMapCacheNativeRx. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry()
HPEXPIREAT	RMapCacheNative. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry() putAsync() fastPutAsync() putIfAbsentAsync() fastPutIfAbsentAsync() putAllAsync() expireEntryAsync()	RMapCacheNativeReactive. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry()	RMapCacheNativeRx. put() fastPut() putIfAbsent() fastPutIfAbsent() putAll() expireEntry()
HPTTL	RMapCacheNative. remainTimeToLive() remainTimeToLiveAsync()	RMapCacheNativeReactive. remainTimeToLive()	RMapCacheNativeRx. remainTimeToLive()
HRANDFIELD	RMap. putAll() putAllAsync()	RMapReactive. putAll()	RMapRx. putAll()
HSCAN	RMap. keySet().iterator() values().iterator() entrySet().iterator()	RMapReactive. keyIterator() valueIterator() entryIterator()	RMapRx. keyIterator() valueIterator() entryIterator()
HSET	RMap. randomEntries() randomKeys() randomEntriesAsync() randomKeysAsync()	RMapReactive. randomEntries() randomKeys()	RMapRx. randomEntries() randomKeys()
HSETNX	RMap. fastPutIfAbsent() fastPutIfAbsentAsync()	RMapReactive. fastPutIfAbsent()	RMapRx. fastPutIfAbsent()
HSTRLEN	RMap. valueSize() valueSizeAsync()	RMapReactive. valueSize()	RMapRx. valueSize()
HVALS	RMap. readAllValues() readAllValuesAsync()	RMapReactive. readAllValues()	RMapRx. readAllValues()

Lists & blocking queues

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
BLMOVE	RBlockingDeque. move() moveAsync()	RBlockingDequeReactive. move()	RBlockingDequeRx. move()
BLMPOP	RBlockingQueue. pollLastFromAny() pollFirstFromAny() pollLastFromAnyAsync() pollFirstFromAnyAsync()	RBlockingQueueReactive. pollLastFromAny() pollFirstFromAny()	RBlockingQueueRx. pollLastFromAny() pollFirstFromAny()
BLPOP	RBlockingQueue. take() poll() pollFromAny() takeAsync() pollAsync() pollFromAnyAsync()	RBlockingQueueReactive. take() poll() pollFromAny()	RBlockingQueueRx. take() poll() pollFromAny()
BRPOP	RBlockingDeque. takeLast() takeLastAsync()	RBlockingDequeReactive. takeLast()	RBlockingDequeRx. takeLast()
BRPOPLPUSH	RBlockingQueue. pollLastAndOfferFirstTo() pollLastAndOfferFirstToAsync()	RBlockingQueueReactive. pollLastAndOfferFirstTo()	RBlockingQueueRx. pollLastAndOfferFirstTo()
LINDEX	RList. get() getAsync()	RListReactive. get()	RListRx. get()
LINSERT	RList. addBefore() addAfter() addBeforeAsync() addAfterAsync()	RListReactive. addBefore() addAfter()	RListRx. addBefore() addAfter()
LLEN	RList. size() sizeAsync()	RListReactive. size()	RListRx. size()
LMOVE	RDeque. move() moveAsync()	RDequeReactive. move()	RDequeRx. move()
LPOP	RQueue. poll() pollAsync()	RQueueReactive. poll()	RQueueRx. poll()
LPUSH	RDeque. addFirst() addFirstAsync()	RDequeReactive. addFirst()	RDequeRx. addFirst()
LPUSHX	RDeque. addFirstIfExists() addFirstIfExistsAsync()	RDequeReactive. addFirstIfExists()	RDequeRx. addFirstIfExists()
LRANGE	RList. readAll() readAllAsync()	RListReactive.readAll()	RListRx.readAll()
LREM	RList. fastRemove() fastRemoveAsync()	RListReactive. fastRemove()	RListRx. fastRemove()
LSET	RList. fastSet() fastSetAsync()	RListReactive. fastSet()	RListRx. fastSet()
LTRIM	RList. trim() trimAsync()	RListReactive. trim()	RListRx. trim()
RPOP	RDeque. pollLast() removeLast() pollLastAsync() removeLastAsync()	RDequeReactive. pollLast() removeLast()	RDequeRx. pollLast() removeLast()
RPOPLPUSH	RDeque. pollLastAndOfferFirstTo() pollLastAndOfferFirstToAsync()	RDequeReactive. pollLastAndOfferFirstTo()	RDequeRx. pollLastAndOfferFirstTo()
RPUSH	RList. add() addAsync()	RListReactive. add()	RListRx. add()
RPUSHX	RDeque. addLastIfExists() addLastIfExistsAsync()	RListReactive. addLastIfExists()	RListRx. addLastIfExists()

Sets

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
SADD	RSet. add() addAsync()	RSetReactive. add()	RSetRx. add()
SCARD	RSet. size() sizeAsync()	RSetReactive. size()	RSetRx. size()
SDIFF	RSet. readDiff() readDiffAsync()	RSetReactive. readDiff()	RSetRx. readDiff()
SDIFFSTORE	RSet. diff() diffAsync()	RSetReactive. diff()	RSetRx. diff()
SINTER	RSet. readIntersection() readIntersectionAsync()	RSetReactive. readIntersection()	RSetRx. readIntersection()
SINTERCARD	RSet. countIntersection() countIntersectionAsync()	RSetReactive. countIntersection()	RSetRx. countIntersection()
SINTERSTORE	RSet. intersection() intersectionAsync()	RSetReactive. intersection()	RSetRx. intersection()
SISMEMBER	RSet. contains() containsAsync()	RSetReactive. contains()	RSetRx. contains()
SMEMBERS	RSet. readAll() readAllAsync()	RSetReactive. readAll()	RSetRx. readAll()
SMISMEMBER	RSet. containsEach() containsEachAsync()	RSetReactive. containsEach()	RSetRx. containsEach()
SMOVE	RSet. move() moveAsync()	RSetReactive. move()	RSetRx. move()
SPOP	RSet. removeRandom() removeRandomAsync()	RSetReactive. removeRandom()	RSetRx. removeRandom()
SRANDMEMBER	RSet. random() randomAsync()	RSetReactive. random()	RSetRx. random()
SREM	RSet. remove() removeAsync()	RSetReactive. remove()	RSetRx. remove()
SSCAN	RSet. iterator()	RSetReactive. iterator()	RSetRx. iterator()
SUNION	RSet. readUnion() readUnionAsync()	RSetReactive. readUnion()	RSetRx. readUnion()
SUNIONSTORE	RSet. union() unionAsync()	RSetReactive. union()	RSetRx. union()

Sorted sets

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
BZMPOP	RScoredSortedSet. pollLast() pollLastAsync() pollLastFromAny() pollLastEntriesFromAny()	RScoredSortedSetReactive. pollLast() pollLastFromAny() pollLastEntriesFromAny()	RScoredSortedSetRx. pollLast() pollLastFromAny() pollLastEntriesFromAny()
BZPOPMAX	RScoredSortedSet. pollLast() pollLastAsync()	RScoredSortedSetReactive. pollLast()	RScoredSortedSetRx. pollLast()
BZPOPMIN	RScoredSortedSet. pollFirst() pollFirstAsync()	RScoredSortedSetReactive. pollFirst()	RScoredSortedSetRx. pollFirst()
ZADD	RScoredSortedSet. add() addAsync() addAll() addAllAsync()	RScoredSortedSetReactive. add() addAll()	RScoredSortedSetRx. add() addAll()
ZCARD	RScoredSortedSet. size() sizeAsync()	RScoredSortedSetReactive. size()	RScoredSortedSetRx. size()
ZCOUNT	RScoredSortedSet. count() countAsync()	RScoredSortedSetReactive. count()	RScoredSortedSetRx. count()
ZDIFF	RScoredSortedSet. readDiff() readDiffAsync()	RScoredSortedSetReactive. readDiff()	RScoredSortedSetRx. readDiff()
ZDIFFSTORE	RScoredSortedSet. diff() diffAsync()	RScoredSortedSetReactive. diff()	RScoredSortedSetRx. diff()
ZINCRBY	RScoredSortedSet. addScore() addScoreAsync()	RScoredSortedSetReactive. addScore()	RScoredSortedSetRx. addScore()
ZINTER	RScoredSortedSet. readIntersection() readIntersectionAsync()	RScoredSortedSetReactive. readIntersection()	RScoredSortedSetRx. readIntersection()
ZINTERCARD	RScoredSortedSet. countIntersection() countIntersectionAsync()	RScoredSortedSetReactive. countIntersection()	RScoredSortedSetRx. countIntersection()
ZINTERSTORE	RScoredSortedSet. intersection() intersectionAsync()	RScoredSortedSetReactive. intersection()	RScoredSortedSetRx. intersection()
ZLEXCOUNT	RLexSortedSet. lexCount() lexCountHead() lexCountTail() lexCountAsync() lexCountHeadAsync() lexCountTailAsync()	RLexSortedSetReactive. lexCount() lexCountHead() lexCountTail()	RLexSortedSetRx. lexCount() lexCountHead() lexCountTail()
ZMPOP	RScoredSortedSet. pollFirstEntriesFromAny() pollFirstEntriesFromAnyAsync() pollLastFromAny() pollLastFromAnyAsync() pollFirstFromAny() pollFirstFromAnyAsync()	RScoredSortedSetReactive. pollFirstEntriesFromAny() pollLastFromAny() pollFirstFromAny()	RScoredSortedSetRx. pollFirstEntriesFromAny() pollLastFromAny() pollFirstFromAny()
ZMSCORE	RScoredSortedSet. getScore() getScoreAsync()	RScoredSortedSetReactive. getScore()	RScoredSortedSetRx. getScore()
ZPOPMAX	RScoredSortedSet. pollLast() pollLastAsync()	RScoredSortedSetReactive. pollLast()	RScoredSortedSetRx. pollLast()
ZPOPMIN	RScoredSortedSet. pollFirst() pollFirstAsync()	RScoredSortedSetReactive. pollFirst()	RScoredSortedSetRx. pollFirst()
ZRANDMEMBER	RScoredSortedSet. random() randomAsync()	RScoredSortedSetReactive. random()	RScoredSortedSetRx. random()
ZRANGE	RScoredSortedSet. valueRange() valueRangeAsync()	RScoredSortedSetReactive. valueRange()	RScoredSortedSetRx. valueRange()
ZRANGEBYLEX	RLexSortedSet. range() rangeHead() rangeTail() rangeAsync() rangeHeadAsync() rangeTailAsync()	RLexSortedSetReactive. range() rangeHead() rangeTail()	RLexSortedSetRx. range() rangeHead() rangeTail()
ZRANGEBYSCORE	RScoredSortedSet. valueRange() entryRange() valueRangeAsync() entryRangeAsync()	RScoredSortedSetReactive. valueRange() entryRange()	RScoredSortedSetRx. valueRange() entryRange()
ZRANGESTORE	RScoredSortedSet. rangeTo() rangeToAsync() revRangeTo() revRangeToAsync()	RScoredSortedSetReactive. rangeTo() revRangeTo()	RScoredSortedSetRx. rangeTo() revRangeTo()
ZRANK	RScoredSortedSet. rank() rankAsync()	RScoredSortedSetReactive. rank()	RScoredSortedSetRx. rank()
ZREM	RScoredSortedSet. remove() removeAll() removeAsync() removeAllAsync()	RScoredSortedSetReactive. remove() removeAll()	RScoredSortedSetRx. remove() removeAll()
ZREMRANGEBYLEX	RLexSortedSet. removeRange() removeRangeHead() removeRangeTail() removeRangeAsync() removeRangeHeadAsync() removeRangeTailAsync()	RLexSortedSetReactive. removeRange() removeRangeHead() removeRangeTail()	RLexSortedSetRx. removeRange() removeRangeHead() removeRangeTail()
ZREMRANGEBYRANK	RScoredSortedSet. removeRangeByRank() removeRangeByRankAsync()	RScoredSortedSetReactive. removeRangeByRank()	RScoredSortedSetRx. removeRangeByRank()
ZREMRANGEBYSCORE	RScoredSortedSet. removeRangeByScore() removeRangeByScoreAsync()	RScoredSortedSetReactive. removeRangeByScore()	RScoredSortedSetRx. removeRangeByScore()
ZREVRANGE	RScoredSortedSet. valueRangeReversed() valueRangeReversedAsync()	RScoredSortedSetReactive. valueRangeReversed()	RScoredSortedSetRx. valueRangeReversed()
ZREVRANGEBYLEX	RLexSortedSet. rangeReversed() rangeReversedAsync()	RLexSortedSetReactive. rangeReversed()	RLexSortedSetSetRx. rangeReversed()
ZREVRANGEBYSCORE	RScoredSortedSet. valueRangeReversed() entryRangeReversed() valueRangeReversedAsync() entryRangeReversedAsync()	RScoredSortedSetReactive. entryRangeReversed() valueRangeReversed()	RScoredSortedSetRx. entryRangeReversed() valueRangeReversed()
ZREVRANK	RScoredSortedSet. revRank() revRankAsync()	RScoredSortedSetReactive. revRank()	RScoredSortedSetRx. revRank()
ZSCORE	RScoredSortedSet. getScore() getScoreAsync()	RScoredSortedSetReactive. getScore()	RScoredSortedSetRx. getScore()
ZUNION	RScoredSortedSet. readUnion() readUnionAsync()	RScoredSortedSetReactive. readUnion()	RScoredSortedSetRx. readUnion()
ZUNIONSTORE	RScoredSortedSet. union() unionAsync()	RScoredSortedSetReactive. union()	RScoredSortedSetRx. union()

Geospatial

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
GEOADD	RGeo. add() addAsync()	RGeoReactive. add()	RGeoRx. add()
GEODIST	RGeo. dist() distAsync()	RGeoReactive. dist()	RGeoRx. dist()
GEOHASH	RGeo. hash() hashAsync()	RGeoReactive. hash()	RGeoRx. hash()
GEOPOS	RGeo. pos() posAsync()	RGeoReactive. pos()	RGeoRx. pos()
GEORADIUS	RGeo. radius() radiusAsync() radiusWithDistance() radiusWithDistanceAsync() radiusWithPosition() radiusWithPositionAsync()	RGeoReactive. radius() radiusWithDistance() radiusWithPosition()	RGeoRx. radius() radiusWithDistance() radiusWithPosition()
GEORADIUSBYMEMBER	RGeo. radiusWithDistance() radiusWithDistanceAsync()	RGeoReactive. radiusWithDistance()	RGeoRx. radiusWithDistance()
GEOSEARCH	RGeo. search() searchAsync()	RGeoReactive. search()	RGeoRx. search()
GEOSEARCHSTORE	RGeo. storeSearchTo() storeSearchToAsync()	RGeoReactive. storeSearchTo()	RGeoRx. storeSearchTo()

Streams

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
XACK	RStream. ack() ackAsync()	RStreamReactive. ack()	RStreamRx. ack()
XADD	RStream. add() addAsync()	RStreamReactive. add()	RStreamRx. add()
XAUTOCLAIM	RStream. autoClaim() autoClaimAsync()	RStreamReactive. autoClaim()	RStreamRx. autoClaim()
XCLAIM	RStream. claim() claimAsync()	RStreamReactive. claim()	RStreamRx. claim()
XDEL	RStream. remove() removeAsync()	RStreamReactive. remove()	RStreamRx. remove()
XGROUP	RStream. createGroup() removeGroup() updateGroup() createGroupAsync() removeGroupAsync() updateGroupAsync()	RStreamReactive. createGroup() removeGroup() updateGroup()	RStreamRx. createGroup() removeGroup() updateGroup()
XINFO	RStream. getInfo() listGroups() listConsumers() getInfoAsync() listGroupsAsync() listConsumersAsync()	RStreamReactive. getInfo() listGroups() listConsumers()	RStreamRx. getInfo() listGroups() listConsumers()
XLEN	RStream. size() sizeAsync()	RStreamReactive. size()	RStreamRx. size()
XNACK	RStream. nack() nackAsync()	RStreamReactive. nack()	RStreamRx. nack()
XPENDING	RStream. listPending() listPendingAsync()	RStreamReactive. listPending()	RStreamRx. listPending()
XRANGE	RStream. range() rangeAsync()	RStreamReactive. range()	RStreamRx. range()
XREAD	RStream. read() readAsync()	RStreamReactive. read()	RStreamRx. read()
XREADGROUP	RStream. readGroup() readGroupAsync()	RStreamReactive. readGroup()	RStreamRx. readGroup()
XREVRANGE	RStream. rangeReversed() rangeReversedAsync()	RStreamReactive. rangeReversed()	RStreamRx. rangeReversed()
XTRIM	RStream. trim() trimAsync()	RStreamReactive. trim()	RStreamRx. trim()

Probabilistic filters

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
BF.ADD	RBloomFilterNative. add() addAsync()	RBloomFilterNativeReactive. add()	RBloomFilterNativeRx. add()
BF.CARD	RBloomFilterNative. count() countAsync()	RBloomFilterNativeReactive. count()	RBloomFilterNativeRx. count()
BF.EXISTS	RBloomFilterNative. exists() existsAsync()	RBloomFilterNativeReactive. exists()	RBloomFilterNativeRx. exists()
BF.INFO	RBloomFilterNative. getInfo() getInfoAsync()	RBloomFilterNativeReactive. getInfo()	RBloomFilterNativeRx. getInfo()
BF.LOADCHUNK	RBloomFilterNative. loadChunk() loadChunkAsync()	RBloomFilterNativeReactive. loadChunk()	RBloomFilterNativeRx. loadChunk()
BF.RESERVE	RBloomFilterNative. init() initAsync()	RBloomFilterNativeReactive. init()	RBloomFilterNativeRx. init()
BF.SCANDUMP	RBloomFilterNative. scanDump() scanDumpAsync()	RBloomFilterNativeReactive. scanDump()	RBloomFilterNativeRx. scanDump()
CF.ADD	RCuckooFilter. add() addAsync()	RCuckooFilterReactive. add()	RCuckooFilterRx. add()
CF.ADDNX	RCuckooFilter. addIfAbsent() addIfAbsentAsync()	RCuckooFilterReactive. addIfAbsent()	RCuckooFilterRx. addIfAbsent()
CF.COUNT	RCuckooFilter. count() countAsync()	RCuckooFilterReactive. count()	RCuckooFilterRx. count()
CF.DEL	RCuckooFilter. remove() removeAsync()	RCuckooFilterReactive. remove()	RCuckooFilterRx. remove()
CF.EXISTS	RCuckooFilter. exists() existsAsync()	RCuckooFilterReactive. exists()	RCuckooFilterRx. exists()
CF.INFO	RCuckooFilter. getInfo() getInfoAsync()	RCuckooFilterReactive. getInfo()	RCuckooFilterRx. getInfo()
CF.RESERVE	RCuckooFilter. init() initAsync()	RCuckooFilterReactive. init()	RCuckooFilterRx. init()

JSON

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
JSON.ARRAPPEND	RJsonBucket. arrayAppend() arrayAppendAsync()	RJsonBucketReactive. arrayAppend()	RJsonBucketRx. arrayAppend()
JSON.ARRINDEX	RJsonBucket. arrayIndex() arrayIndexAsync()	RJsonBucketReactive. arrayIndex()	RJsonBucketRx. arrayIndex()
JSON.ARRINSERT	RJsonBucket. arrayInsert() arrayInsertAsync()	RJsonBucketReactive. arrayInsert()	RJsonBucketRx. arrayInsert()
JSON.ARRLEN	RJsonBucket. arraySize() arraySizeAsync()	RJsonBucketReactive. arraySize()	RJsonBucketRx. arraySize()
JSON.ARRPOP	RJsonBucket. arrayPollLast() arrayPollFirst() arrayPop() arrayPollLastAsync() arrayPollFirstAsync() arrayPopAsync()	RJsonBucketReactive. arrayPollLast() arrayPollFirst() arrayPop()	RJsonBucketRx. arrayPollLast() arrayPollFirst() arrayPop()
JSON.ARRTRIM	RJsonBucket. arrayTrim() arrayTrimAsync()	RJsonBucketReactive. arrayTrim()	RJsonBucketRx. arrayTrim()
JSON.CLEAR	RJsonBucket. clear() clearAsync()	RJsonBucketReactive. clear()	RJsonBucketRx. clear()
JSON.DEL	RJsonBucket. delete() deleteAsync()	RJsonBucketReactive. delete()	RJsonBucketRx. delete()
JSON.GET	RJsonBucket. get() getAsync()	RJsonBucketReactive. get()	RJsonBucketRx. get()
JSON.MERGE	RJsonBucket. merge() mergeAsync()	RJsonBucketReactive. merge()	RJsonBucketRx. merge()
JSON.MSET	RJsonBuckets. set() setAsync()	RJsonBucketsReactive. set()	RJsonBucketsRx. set()
JSON.NUMINCRBY	RJsonBucket. incrementAndGet() incrementAndGetAsync()	RJsonBucketReactive. incrementAndGet()	RJsonBucketRx. incrementAndGet()
JSON.OBJKEYS	RJsonBucket. getKeys() getKeysAsync()	RJsonBucketReactive. getKeys()	RJsonBucketRx. getKeys()
JSON.OBJLEN	RJsonBucket. countKeys() countKeysAsync()	RJsonBucketReactive. countKeys()	RJsonBucketRx. countKeys()
JSON.SET	RJsonBucket. set() setAsync()	RJsonBucketReactive. set()	RJsonBucketRx. set()
JSON.STRAPPEND	RJsonBucket. stringAppend() stringAppendAsync()	RJsonBucketReactive. stringAppend()	RJsonBucketRx. stringAppend()
JSON.STRLEN	RJsonBucket. stringSize() stringSizeAsync()	RJsonBucketReactive. stringSize()	RJsonBucketRx. stringSize()
JSON.TOGGLE	RJsonBucket. toggle() toggleAsync()	RJsonBucketReactive. toggle()	RJsonBucketRx. toggle()
JSON.TYPE	RJsonBucket. type() typeAsync()	RJsonBucketReactive. type()	RJsonBucketRx. type()

Search & query

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
FT._LIST	RSearch. getIndexes() getIndexesAsync()	RSearchReactive. getIndexes()	RSearchRx. getIndexes()
FT.AGGREGATE	RSearch. aggregate() aggregateAsync()	RSearchReactive. aggregate()	RSearchRx. aggregate()
FT.ALIASADD	RSearch. addAlias() addAliasAsync()	RSearchReactive. addAlias()	RSearchRx. addAlias()
FT.ALIASDEL	RSearch. delAlias() delAliasAsync()	RSearchReactive. delAlias()	RSearchRx. delAlias()
FT.ALIASUPDATE	RSearch. updateAlias() updateAliasAsync()	RSearchReactive. updateAlias()	RSearchRx. updateAlias()
FT.ALTER	RSearch. alter() alterAsync()	RSearchReactive. alter()	RSearchRx. alter()
FT.CONFIG GET	RSearch. getConfig() getConfigAsync()	RSearchReactive. getConfig()	RSearchRx. getConfig()
FT.CONFIG SET	RSearch. setConfig() setConfigAsync()	RSearchReactive. setConfig()	RSearchRx. setConfig()
FT.CREATE	RSearch. createIndex() createIndexAsync()	RSearchReactive. createIndex()	RSearchRx. createIndex()
FT.CURSOR DEL	RSearch. delCursor() delCursorAsync()	RSearchReactive. delCursor()	RSearchRx. delCursor()
FT.DICTADD	RSearch. addDict() addDictAsync()	RSearchReactive. addDict()	RSearchRx. addDict()
FT.DICTDEL	RSearch. delDict() delDictAsync()	RSearchReactive. delDict()	RSearchRx. delDict()
FT.DICTDUMP	RSearch. dumpDict() dumpDictAsync()	RSearchReactive. dumpDict()	RSearchRx. dumpDict()
FT.DROPINDEX	RSearch. dropIndex() dropIndexAndDocuments() dropIndexAsync() dropIndexAndDocumentsAsync()	RSearchReactive. dropIndex() dropIndexAndDocuments()	RSearchRx. dropIndex() dropIndexAndDocuments()
FT.HYBRID	RSearch. hybridSearch() hybridSearchAsync()	RSearchReactive. hybridSearch()	RSearchRx. hybridSearch()
FT.INFO	RSearch. info() infoAsync()	RSearchReactive. info()	RSearchRx. info()
FT.SEARCH	RSearch. search() searchAsync()	RSearchReactive. search()	RSearchRx. search()
FT.SPELLCHECK	RSearch. spellcheck() spellcheckAsync()	RSearchReactive. spellcheck()	RSearchRx. spellcheck()
FT.SYNDUMP	RSearch. dumpSynonyms() dumpSynonymsAsync()	RSearchReactive. dumpSynonyms()	RSearchRx. dumpSynonyms()
FT.SYNUPDATE	RSearch. updateSynonyms() updateSynonymsAsync()	RSearchReactive. updateSynonyms()	RSearchRx. updateSynonyms()

Vector sets

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
VADD	RVectorSet. add() addAsync()	RVectorSetReactive. add()	RVectorSetRx. add()
VCARD	RVectorSet. size() sizeAsync()	RVectorSetReactive. size()	RVectorSetRx. size()
VDIM	RVectorSet. dimensions() dimensionsAsync()	RVectorSetReactive. dimensions()	RVectorSetRx. dimensions()
VEMB	RVectorSet. getVector() getRawVector() getVectorAsync() getRawVectorAsync()	RVectorSetReactive. getVector() getRawVector()	RVectorSetRx. getVector() getRawVector()
VGETATTR	RVectorSet. getAttributes() getAttributesAsync()	RVectorSetReactive. getAttributes()	RVectorSetRx. getAttributes()
VINFO	RVectorSet. getInfo() getInfoAsync()	RVectorSetReactive. getInfo()	RVectorSetRx. getInfo()
VLINKS	RVectorSet. getNeighbors() getNeighborEntries() getNeighborsAsync() getNeighborEntriesAsync()	RVectorSetReactive. getNeighbors() getNeighborEntries()	RVectorSetRx. getNeighbors() getNeighborEntries()
VRANDMEMBER	RVectorSet. random() randomAsync()	RVectorSetReactive. random()	RVectorSetRx. random()
VREM	RVectorSet. remove() removeAsync()	RVectorSetReactive. remove()	RVectorSetRx. remove()
VSETATTR	RVectorSet. setAttributes() setAttributesAsync()	RVectorSetReactive. setAttributes()	RVectorSetRx. setAttributes()
VSIM	RVectorSet. getSimilar() getSimilarEntries() getSimilarAsync() getSimilarEntriesAsync()	RVectorSetReactive. getSimilar() getSimilarEntries()	RVectorSetRx. getSimilar() getSimilarEntries()

Pub/Sub

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
PSUBSCRIBE	RPatternTopic. addListener()	RPatternTopicReactive. addListener()	RPatternTopicRx. addListener()
PUBLISH	RTopic. publish()	RTopicReactive. publish()	RTopicRx. publish()
PUBSUB NUMSUB	RTopic. countSubscribers() countSubscribersAsync()	RTopicReactive. countSubscribers()	RTopicRx. countSubscribers()
PUBSUB SHARDNUMSUB	RShardedTopic. countSubscribers() countSubscribersAsync()	RShardedTopicReactive. countSubscribers()	RShardedTopicRx. countSubscribers()
PUNSUBSCRIBE	RPatternTopic. removeListener()	RPatternTopicReactive. removeListener()	RPatternTopicRx. removeListener()
SPUBLISH	RShardedTopic. publish() publishAsync()	RShardedTopicReactive. publish()	RShardedTopicRx. publish()
SSUBSCRIBE	RShardedTopic. addListener()	RShardedTopicReactive. addListener()	RShardedTopicRx. addListener()
SUBSCRIBE	RTopic. addListener()	RTopicReactive. addListener()	RTopicRx. addListener()
SUNSUBSCRIBE	RShardedTopic. removeListener() removeAllListeners()	RShardedTopicReactive. removeListener()	RShardedTopicRx. removeListener()
UNSUBSCRIBE	RTopic. removeListener()	RTopicReactive. removeListener()	RTopicRx. removeListener()

Scripting & functions

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
EVAL	RScript. eval() evalAsync()	RScriptReactive. eval()	RScriptRx. eval()
EVALSHA	RScript. evalSha() evalShaAsync()	RScriptReactive. evalSha()	RScriptRx. evalSha()
FCALL	RFunction. call() callAsync()	RFunctionReactive. call()	RFunctionRx. call()
FUNCTION DELETE	RFunction. delete() deleteAsync()	RFunctionReactive. delete()	RFunctionRx. delete()
FUNCTION DUMP	RFunction. dump() dumpAsync()	RFunctionReactive. dump()	RFunctionRx. dump()
FUNCTION FLUSH	RFunction. flush() flushAsync()	RFunctionReactive. flush()	RFunctionRx. flush()
FUNCTION KILL	RFunction. kill() killAsync()	RFunctionReactive. kill()	RFunctionRx. kill()
FUNCTION LIST	RFunction. list() listAsync()	RFunctionReactive. list()	RFunctionRx. list()
FUNCTION LOAD	RFunction. load() loadAndReplace() loadAsync() loadAndReplaceAsync()	RFunctionReactive. load() loadAndReplace()	RFunctionRx. load() loadAndReplace()
FUNCTION RESTORE	RFunction. restore() restoreAndReplace() restoreAfterFlush() restoreAsync()	RFunctionReactive. restore() restoreAndReplace() restoreAfterFlush()	RFunctionRx. restore() restoreAndReplace() restoreAfterFlush()
FUNCTION STATS	RFunction. stats() statsAsync()	RFunctionReactive. stats()	RFunctionRx. stats()
SCRIPT EXISTS	RScript. scriptExists() scriptExistsAsync()	RScriptReactive. scriptExists()	RScriptRx. scriptExists()
SCRIPT FLUSH	RScript. scriptFlush() scriptFlushAsync()	RScriptReactive. scriptFlush()	RScriptRx. scriptFlush()
SCRIPT KILL	RScript. scriptKill() scriptKillAsync()	RScriptReactive. scriptKill()	RScriptRx. scriptKill()
SCRIPT LOAD	RScript. scriptLoad() scriptLoadAsync()	RScriptReactive. scriptLoad()	RScriptRx. scriptLoad()

Transactions

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
EXEC	RBatch. execute() executeAsync()	RBatchReactive. execute()	RBatchRx. execute()
MULTI	RBatch. execute() executeAsync()	RBatchReactive. execute()	RBatchRx. execute()

Generic / keys

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
COPY	RObject. copy() copyAsync()	RObjectReactive. copy()	RObjectRx. copy()
DEL	RObject. delete() deleteAsync() RKeys. delete() deleteAsync()	RObjectReactive. delete() RKeysReactive. delete()	RObjectRx. delete() RKeysRx. delete()
DUMP	RObject. dump() dumpAsync()	RObjectReactive. dump()	RObjectRx. dump()
EXISTS	RObject. isExists() isExistsAsync()	RObjectReactive. isExists()	RObjectRx. isExists()
KEYS	RKeys. getKeysByPattern() getKeysByPatternAsync()	RKeysReactive. getKeysByPattern()	RKeysRx. getKeysByPattern()
MIGRATE	RObject. migrate() migrateAsync()	RObjectReactive. migrate()	RObjectRx. migrate()
MOVE	RObject. move() moveAsync()	RObjectReactive. move()	RObjectRx. move()
PERSIST	RExpirable. clearExpire() clearExpireAsync()	RExpirableReactive. clearExpire()	RExpirableRx. clearExpire()
PEXPIRE	RExpirable. expire() expireAsync()	RExpirableReactive. expire()	RExpirableRx. expire()
PEXPIREAT	RExpirable. expireAt() expireAtAsync()	RExpirableReactive. expireAt()	RExpirableRx. expireAt()
PEXPIRETIME	RExpirable. expireTime() expireTimeAsync()	RExpirableReactive. expireTime()	RExpirableRx. expireTime()
PTTL	RExpirable. remainTimeToLive() remainTimeToLiveAsync()	RExpirableReactive. remainTimeToLive()	RExpirableRx. remainTimeToLive()
RANDOMKEY	RKeys. randomKey() randomKeyAsync()	RKeysReactive. randomKey()	RKeysRx. randomKey()
RENAME	RObject. rename() renameAsync()	RObjectReactive. rename()	RObjectRx. rename()
RENAMENX	RObject. renamenx() renamenxAsync()	RObjectReactive. renamenx()	RObjectRx. renamenx()
RESTORE	RObject. restore() restoreAsync()	RObjectReactive. restore()	RObjectRx. restore()
SCAN	RKeys. getKeys()	RKeysReactive. getKeys()	RKeysRx. getKeys()
SORT	RList. readSort() sortTo() readSortAsync() sortToAsync()	RListReactive. readSort() sortTo()	RListRx. readSort() sortTo()
TOUCH	RObject. touch() touchAsync()	RObjectReactive. touch()	RObjectRx. touch()
TTL	RExpirable. remainTimeToLive() remainTimeToLiveAsync()	RExpirableReactive. remainTimeToLive()	RExpirableRx. remainTimeToLive()
TYPE	RKeys. getType() getTypeAsync()	RKeysReactive. getType()	RKeysRx. getType()
UNLINK	RObject. unlink() unlinkAsync()	RObjectReactive. unlink()	RObjectRx. unlink()

Connection & server

Valkey or Redis command	Sync / Async API Redisson.create(config)	Reactive API redisson.reactive()	RxJava3 API redisson.rxJava()
AUTH	Config. setPassword() setUsername()	-	-
CLIENT REPLY	BatchOptions.skipResult()	-	-
CLIENT SETNAME	Config.setClientName()	-	-
CLIENT TRACKING	RBucket .addListener(TrackingListener) RStream .addListener(TrackingListener) RScoredSortedSet .addListener(TrackingListener) RSet .addListener(TrackingListener) RMap .addListener(TrackingListener)	RBucketReactive .addListener(TrackingListener) RStreamReactive .addListener(TrackingListener) RScoredSortedSetReactive .addListener(TrackingListener) RSetReactive .addListener(TrackingListener) RMapReactive .addListener(TrackingListener)	RBucketRx .addListener(TrackingListener) RStreamRx .addListener(TrackingListener) RScoredSortedSetRx .addListener(TrackingListener) RSetRx .addListener(TrackingListener) RMapRx .addListener(TrackingListener)
CLUSTER INFO	ClusterNode.info()	-	-
CLUSTER KEYSLOT	RKeys. getSlot() getSlotAsync()	RKeysReactive. getSlot()	RKeysRx. getSlot()
CLUSTER NODES	Used in ClusterConnectionManager
CONFIG GET	RedisNode. getConfig() getConfigAsync()	-	-
CONFIG SET	RedisNode. setConfig() setConfigAsync()	-	-
DBSIZE	RKeys. count() countAsync()	RKeysReactive. count()	RKeysRx.count()
FLUSHALL	RKeys. flushall() flushallAsync()	RKeysReactive. flushall()	RKeysRx. flushall()
FLUSHDB	RKeys. flushdb() flushdbAsync()	RKeysReactive. flushdb()	RKeysRx. flushdb()
PING	Node.ping() NodesGroup.pingAll()	-	-
SELECT	Config.setDatabase()	-	-
SWAPDB	RKeys. swapdb() swapdbAsync()	RKeysReactive. swapdb()	RKeysRx. swapdb()
TIME	RedissonClient. getNodesGroup(). getNode().time() getClusterNodesGroup(). getNode().time()	-	-
WAIT	BatchOptions. sync()	BatchOptions. sync()	BatchOptions. sync()
WAITAOF	BatchOptions. syncAOF()	BatchOptions. syncAOF()	BatchOptions. syncAOF()