| Redis command | Sync / Async API Redisson.create(config) | Reactive API redisson.reactive() | RxJava3 API redisson.rxJava() | |
|---|---|---|---|---|
| AUTH | Config.setPassword() | - | - | |
| APPEND | RBinaryStream. getOutputStream().write() | - | - | |
| BZPOPMAX | RScoredSortedSet. pollLast() pollLastAsync() | RScoredSortedSetReactive. pollLast() | RScoredSortedSetRx. pollLast() | |
| BZPOPMIN | RScoredSortedSet. pollFirst() pollFirstAsync() | RScoredSortedSetReactive. pollFirst() | RScoredSortedSetRx. pollFirst() | |
| BZMPOP | RScoredSortedSet. pollLast() pollLastAsync() pollLastFromAny() pollLastEntriesFromAny() | RScoredSortedSetReactive. pollLast() pollLastFromAny() pollLastEntriesFromAny() | RScoredSortedSetRx. pollLast() pollLastFromAny() pollLastEntriesFromAny() | |
| BITCOUNT | RBitSet. cardinality() cardinalityAsync() | RBitSetReactive. cardinality() | RBitSetRx. cardinality() | |
| BITOP | RBitSet. or() and() xor() orAsync() andAsync() xorAsync() | RBitSetReactive. or() and() xor() | RBitSetRx. or() and() xor() | |
| BITPOS | RBitSet. length() lengthAsync() | RBitSetReactive. length() | RBitSetRx. length() | |
| 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() | |
| 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() | |
| BLMOVE | RBlockingDeque. move() moveAsync() | RBlockingDequeReactive. move() | RBlockingDequeRx. move() | |
| BRPOP | RBlockingDeque. takeLast() takeLastAsync() | RBlockingDequeReactive. takeLast() | RBlockingDequeRx. takeLast() | |
| BRPOPLPUSH | RBlockingQueue. pollLastAndOfferFirstTo() pollLastAndOfferFirstToAsync() | RBlockingQueueReactive. pollLastAndOfferFirstTo() | RBlockingQueueRx. pollLastAndOfferFirstTo() | |
| CONFIG GET | RedisNode. setConfig() setConfigAsync() | - | - | |
| CONFIG SET | RedisNode. getConfig() getConfigAsync() | - | - | |
| COPY | RObject. copy() copyAsync() | RObjectReactive. copy() | RObjectRx. copy() | |
| CLIENT SETNAME | Config.setClientName() | - | - | |
| CLIENT REPLY | BatchOptions.skipResult() | - | - | |
| 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 | |||
| DECRBY | RAtomicLong. addAndGet() addAndGetAsync() | RAtomicLongReactive. addAndGet() | RAtomicLongRx. addAndGet() | |
| DUMP | RObject. dump() dumpAsync() | RObjectReactive. dump() | RObjectRx. dump() | |
| DBSIZE | RKeys. count() countAsync() | RKeysReactive. count() | RKeysRx.count() | |
| DECR | RAtomicLong. decrementAndGet() decrementAndGetAsync() | RAtomicLongReactive. decrementAndGet() | RAtomicLongRx. decrementAndGet() | |
| DEL | RObject. delete() deleteAsync() RKeys. delete() deleteAsync() | RObjectReactive. delete() RKeysReactive. delete() | RObjectRx. delete() RKeysRx. delete() | |
| STRLEN | RBucket. size() sizeAsync() | RBucketReactive. size() | RBucketRx. size() | |
| EVAL | RScript. eval() evalAsync() | RScriptReactive. eval() | RScriptRx. eval() | |
| EVALSHA | RScript. evalSha() evalShaAsync() | RScriptReactive. evalSha() | RScriptRx. evalSha() | |
| EXEC | RBatch. execute() executeAsync() | RBatchReactive. execute() | RBatchRx. execute() | |
| EXISTS | RObject. isExists() isExistsAsync() | RObjectReactive. isExists() | RObjectRx. isExists() | |
| FLUSHALL | RKeys. flushall() flushallAsync() | RKeysReactive. flushall() | RKeysRx. flushall() | |
| FLUSHDB | RKeys. flushdb() flushdbAsync() | RKeysReactive. flushdb() | RKeysRx. flushdb() | |
| GETRANGE | RBinaryStream. getChannel().read() | RBinaryStreamReactive. read() | RBinaryStreamRx. read() | |
| 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() | |
| GEOSEARCH | RGeo. search() searchAsync() | RGeoReactive. search() | RGeoRx. search() | |
| GEOSEARCHSTORE | RGeo. storeSearchTo() storeSearchToAsync() | RGeoReactive. storeSearchTo() | RGeoRx. storeSearchTo() | |
| 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() | |
| GETBIT | RBitSet. get() getAsync() | RBitSetReactive. get() | RBitSetRx. get() | |
| GETSET | RBucket. getAndSet() getAndSetAsync() RAtomicLong. getAndSet() getAndSetAsync() RAtomicDouble. getAndSet() getAndSetAsync() | RBucketReactive. getAndSet() RAtomicLongReactive. getAndSet() RAtomicDoubleReactive. getAndSet() | RBucketRx. getAndSet() RAtomicLongRx. getAndSet() RAtomicDoubleRx. getAndSet() | |
| HDEL | RMap. fastRemove() fastRemoveAsync() | RMapReactive. fastRemove() | RMapRx. fastRemove() | |
| HEXISTS | RMap. containsKey() containsKeyAsync() | RMapReactive. containsKey() | RMapRx. containsKey() | |
| HGET | RMap. get() getAsync() | RMapReactive. get() | RMapRx. get() | |
| HSTRLEN | RMap. valueSize() valueSizeAsync() | RMapReactive. valueSize() | RMapRx. valueSize() | |
| 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() | |
| 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() | |
| HVALS | RMap. readAllValues() readAllValuesAsync() | RMapReactive. readAllValues() | RMapRx. readAllValues() | |
| INCR | RAtomicLong. incrementAndGet() incrementAndGetAsync() | RAtomicLongReactive. incrementAndGet() | RAtomicLongRx. incrementAndGet() | |
| INCRBY | RAtomicLong. addAndGet() addAndGetAsync() | RAtomicLongReactive. addAndGet() | RAtomicLongRx. addAndGet() | |
| INCRBYFLOAT | RAtomicDouble. addAndGet() addAndGetAsync() | RAtomicDoubleReactive. addAndGet() | RAtomicDoubleRx. addAndGet() | |
| 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.GET | RJsonBucket. get() getAsync() | RJsonBucketReactive. get() | RJsonBucketRx. get() | |
| JSON.NUMINCRBY | RJsonBucket. incrementAndGet() incrementAndGetAsync() | RJsonBucketReactive. incrementAndGet() | RJsonBucketRx. incrementAndGet() | |
| JSON.OBJLEN | RJsonBucket. countKeys() countKeysAsync() | RJsonBucketReactive. countKeys() | RJsonBucketRx. countKeys() | |
| JSON.OBJKEYS | RJsonBucket. getKeys() getKeysAsync() | RJsonBucketReactive. getKeys() | RJsonBucketRx. getKeys() | |
| 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() | |
| KEYS | RKeys. getKeysByPattern() getKeysByPatternAsync() | RKeysReactive. getKeysByPattern() | RKeysRx. getKeysByPattern() | |
| LINDEX | RList. get() getAsync() | RListReactive. get() | RListRx. get() | |
| 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() | |
| LRANGE | RList. readAll() readAllAsync() | RListReactive.readAll() | RListRx.readAll() | |
| LPUSHX | RDeque. addFirstIfExists() addFirstIfExistsAsync() | RDequeReactive. addFirstIfExists() | RDequeRx. addFirstIfExists() | |
| LREM | RList. fastRemove() fastRemoveAsync() | RListReactive. fastRemove() | RListRx. fastRemove() | |
| LSET | RList. fastSet() fastSetAsync() | RListReactive. fastSet() | RListRx. fastSet() | |
| LTRIM | RList. trim() trimAsync() | RListReactive. trim() | RListRx. trim() | |
| LINSERT | RList. addBefore() addAfter() addBeforeAsync() addAfterAsync() | RListReactive. addBefore() addAfter() | RListRx. addBefore() addAfter() | |
| MULTI | RBatch. execute() executeAsync() | RBatchReactive. execute() | RBatchRx. execute() | |
| MGET | RBuckets. get() getAsync() | RBucketsReactive. get() | RBucketsRx. get() | |
| MSETNX | RBuckets. trySet() trySetAsync() | RBucketsReactive. trySet() | RBucketsRx. trySet() | |
| MIGRATE | RObject. migrate() migrateAsync() | RObjectReactive. migrate() | RObjectRx. migrate() | |
| MOVE | RObject. move() moveAsync() | RObjectReactive. move() | RObjectRx. move() | |
| MSET | RBuckets. set() setAsync() | RBucketsReactive. set() | RBucketsRx. set() | |
| 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() | |
| 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() | |
| PING | Node.ping() NodesGroup.pingAll() | - | - | |
| PSUBSCRIBE | RPatternTopic. addListener() | RPatternTopicReactive. addListener() | RPatternTopicRx. addListener() | |
| PSETEX | RBucket. set() setAsync() | RBucketReactive. set() | RBucketRx. set() | |
| PTTL | RExpirable. remainTimeToLive() remainTimeToLiveAsync() | RExpirableReactive. remainTimeToLive() | RExpirableRx. remainTimeToLive() | |
| PUBLISH | RTopic. publish() | RTopicReactive. publish() | RTopicRx. publish() | |
| PUBSUB NUMSUB | RTopic. countSubscribers() countSubscribersAsync() | RTopicReactive. countSubscribers() | RTopicRx. countSubscribers() | |
| PUNSUBSCRIBE | RPatternTopic. removeListener() | RPatternTopicReactive. removeListener() | RPatternTopicRx. removeListener() | |
| RANDOMKEY | RKeys. randomKey() randomKeyAsync() | RKeysReactive. randomKey() | RKeysRx. randomKey() | |
| RESTORE | RObject. restore() restoreAsync() | RObjectReactive. restore() | RObjectRx. restore() | |
| RENAME | RObject. rename() renameAsync() | RObjectReactive. rename() | RObjectRx. rename() | |
| 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() | |
| SADD | RSet. add() addAsync() | RSetReactive. add() | RSetRx. add() | |
| SETRANGE | RBinaryStream. getChannel().write() | RBinaryStreamReactive. write() | RBinaryStreamRx. write() | |
| SCAN | RKeys. getKeys() | RKeysReactive. getKeys() | RKeysRx. getKeys() | |
| SCARD | RSet. size() sizeAsync() | RSetReactive. size() | RSetRx. size() | |
| 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() | |
| SDIFFSTORE | RSet. diff() diffAsync() | RSetReactive. diff() | RSetRx. diff() | |
| SDIFF | RSet. readDiff() readDiffAsync() | RSetReactive. readDiff() | RSetRx. readDiff() | |
| SRANDMEMBER | RSet. random() randomAsync() | RSetReactive. random() | RSetRx. random() | |
| SELECT | Config.setDatabase() | - | - | |
| SET | RBucket. set() setAsync() | RBucketReactive. set() | RBucketRx. set() | |
| SETBIT | RBitSet. set() clear() setAsync() clearAsync() | RBitSetReactive. set() clear() | RBitSetRx. set() clear() | |
| SETEX | RBucket. set() setAsync() | RBucketReactive. set() | RBucketRx. set() | |
| SETNX | RBucket. setIfAbsent() setIfAbsentAsync() | RBucketReactive. setIfAbsent() | RBucketRx. setIfAbsent() | |
| SISMEMBER | RSet. contains() containsAsync() | RSetReactive. contains() | RSetRx. contains() | |
| SINTERSTORE | RSet. intersection() intersectionAsync() | RSetReactive. intersection() | RSetRx. intersection() | |
| SINTER | RSet. readIntersection() readIntersectionAsync() | RSetReactive. readIntersection() | RSetRx. readIntersection() | |
| SMEMBERS | RSet. readAll() readAllAsync() | RSetReactive. readAll() | RSetRx. readAll() | |
| SMOVE | RSet. move() moveAsync() | RSetReactive. move() | RSetRx. move() | |
| SORT | RList. readSort() sortTo() readSortAsync() sortToAsync() | RListReactive. readSort() sortTo() | RListRx. readSort() sortTo() | |
| SPOP | RSet. removeRandom() removeRandomAsync() | RSetReactive. removeRandom() | RSetRx. removeRandom() | |
| SREM | RSet. remove() removeAsync() | RSetReactive. remove() | RSetRx. remove() | |
| SSCAN | RSet. iterator() | RSetReactive. iterator() | RSetRx. iterator() | |
| SUBSCRIBE | RTopic. addListener() | RTopicReactive. addListener() | RTopicRx. addListener() | |
| SUNION | RSet. readUnion() readUnionAsync() | RSetReactive. readUnion() | RSetRx. readUnion() | |
| SUNIONSTORE | RSet. union() unionAsync() | RSetReactive. union() | RSetRx. union() | |
| SWAPDB | RKeys. swapdb() swapdbAsync() | RKeysReactive. swapdb() | RKeysRx. swapdb() | |
| TTL | RExpirable. remainTimeToLive() remainTimeToLiveAsync() | RExpirableReactive. remainTimeToLive() | RExpirableRx. remainTimeToLive() | |
| TYPE | RKeys. getType() getTypeAsync() | RKeysReactive. getType() | RKeysRx. getType() | |
| TOUCH | RObject. touch() touchAsync() | RObjectReactive. touch() | RObjectRx. touch() | |
| UNSUBSCRIBE | RTopic. removeListener() | RTopicReactive. removeListener() | RTopicRx. removeListener() | |
| UNLINK | RObject. unlink() unlinkAsync() | RObjectReactive. unlink() | RObjectRx. unlink() | |
| WAIT | BatchOptions. sync() | BatchOptions. sync() | BatchOptions. sync() | |
| WAITAOF | BatchOptions. syncAOF() | BatchOptions. syncAOF() | BatchOptions. syncAOF() | |
| 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() | |
| ZREMRANGEBYRANK | RScoredSortedSet. removeRangeByRank() removeRangeByRankAsync() | RScoredSortedSetReactive. removeRangeByRank() | RScoredSortedSetRx. removeRangeByRank() | |
| ZREVRANGEBYLEX | RLexSortedSet. rangeReversed() rangeReversedAsync() | RLexSortedSetReactive. rangeReversed() | RLexSortedSetSetRx. rangeReversed() | |
| ZLEXCOUNT | RLexSortedSet. lexCount() lexCountHead() lexCountTail() lexCountAsync() lexCountHeadAsync() lexCountTailAsync() | RLexSortedSetReactive. lexCount() lexCountHead() lexCountTail() | RLexSortedSetRx. lexCount() lexCountHead() lexCountTail() | |
| ZRANGE | RScoredSortedSet. valueRange() valueRangeAsync() | RScoredSortedSetReactive. valueRange() | RScoredSortedSetRx. valueRange() | |
| ZRANDMEMBER | RScoredSortedSet. random() randomAsync() | RScoredSortedSetReactive. random() | RScoredSortedSetRx. random() | |
| ZREVRANGE | RScoredSortedSet. valueRangeReversed() valueRangeReversedAsync() | RScoredSortedSetReactive. valueRangeReversed() | RScoredSortedSetRx. valueRangeReversed() | |
| ZUNION | RScoredSortedSet. readUnion() readUnionAsync() | RScoredSortedSetReactive. readUnion() | RScoredSortedSetRx. readUnion() | |
| ZUNIONSTORE | RScoredSortedSet. union() unionAsync() | RScoredSortedSetReactive. union() | RScoredSortedSetRx. union() | |
| ZINTERSTORE | RScoredSortedSet. intersection() intersectionAsync() | RScoredSortedSetReactive. intersection() | RScoredSortedSetRx. intersection() | |
| ZPOPMAX | RScoredSortedSet. pollLast() pollLastAsync() | RScoredSortedSetReactive. pollLast() | RScoredSortedSetRx. pollLast() | |
| ZPOPMIN | RScoredSortedSet. pollFirst() pollFirstAsync() | RScoredSortedSetReactive. pollFirst() | RScoredSortedSetRx. pollFirst() | |
| ZMPOP | RScoredSortedSet. pollFirstEntriesFromAny() pollFirstEntriesFromAnyAsync() pollLastFromAny() pollLastFromAnyAsync() pollFirstFromAny() pollFirstFromAnyAsync() | RScoredSortedSetReactive. pollFirstEntriesFromAny() pollLastFromAny() pollFirstFromAny() | RScoredSortedSetRx. pollFirstEntriesFromAny() pollLastFromAny() pollFirstFromAny() | |
| 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() | |
| TIME | RedissonClient. getNodesGroup(). getNode().time() getClusterNodesGroup(). getNode().time() | - | - | |
| 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() | |
| ZREMRANGEBYSCORE | RScoredSortedSet. removeRangeByScore() removeRangeByScoreAsync() | RScoredSortedSetReactive. removeRangeByScore() | RScoredSortedSetRx. removeRangeByScore() | |
| 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() | |
| 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() | |
| 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() | 
 我的书签
 我的书签
                                 添加书签
 添加书签 移除书签
 移除书签