Redisson--Redis命令与Redisson方法对应

Redis command

Sync / Async Api
Redisson.create(config)

Reactive Api
Redisson.createReactive(config)

AUTH

Config.setPassword()

-

APPEND

RBinaryStream.
getOutputStream().write()

-

BZPOPMAX

RScoredSortedSet.
pollLast()
pollLastAsync()

RScoredSortedSetReactive.
pollLast()

BZPOPMIN

RScoredSortedSet.
pollFirst()
pollFirstAsync()

RScoredSortedSetReactive.
pollFirst()

BITCOUNT

RBitSet.
cardinality()
cardinalityAsync()

RBitSetReactive.
cardinality()

BITOP

RBitSet.
or()
and()
xor()
orAsync()
andAsync()
xorAsync()

RBitSetReactive.
or()
and()
xor()

BITPOS

RBitSet.
length()
lengthAsync()

RBitSetReactive.
length()

BLPOP

RBlockingQueue.
take()
poll()
pollFromAny()
takeAsync()
pollAsync()
pollFromAnyAsync()

RBlockingQueueReactive.
take()
poll()
pollFromAny()

BRPOP

RBlockingDeque.
takeLast()
takeLastAsync()

RBlockingDequeReactive.
takeLast()

BRPOPLPUSH

RBlockingQueue.
pollLastAndOfferFirstTo()
pollLastAndOfferFirstToAsync()

RBlockingQueueReactive.
pollLastAndOfferFirstTo()

CONFIG GET

RedisNode.
setConfig()
setConfigAsync()

-

CONFIG SET

RedisNode.
getConfig()
getConfigAsync()

-

COPY

RObject.
copy()
copyAsync()

RObjectReactive.
copy()

CLIENT SETNAME

Config.setClientName()

-

CLIENT REPLY

BatchOptions.skipResult()

-

CLUSTER INFO

ClusterNode.info()

-

CLUSTER KEYSLOT

RKeys.
getSlot()
getSlotAsync()

RKeysReactive.
getSlot()

CLUSTER NODES

Used in ClusterConnectionManager

DECRBY

RAtomicLong.
addAndGet()
addAndGetAsync()

RAtomicLongReactive.
addAndGet()

DUMP

RObject.
dump()
dumpAsync()

RObjectReactive.
dump()

DBSIZE

RKeys.
count()
countAsync()

RKeysReactive.
count()

DECR

RAtomicLong.
decrementAndGet()
decrementAndGetAsync()

RAtomicLongReactive.
decrementAndGet()

DEL

RObject.
delete()
deleteAsync()

RKeys.
delete()
deleteAsync()

RObjectReactive.
delete()

RKeysReactive.
delete()

STRLEN

RBucket.
size()
sizeAsync()

RBucketReactive.
size()

EVAL

RScript.
eval()
evalAsync()

RScriptReactive.
eval()

EVALSHA

RScript.
evalSha()
evalShaAsync()

RScriptReactive.
evalSha()

EXEC

RBatch.
execute()
executeAsync()

RBatchReactive.
execute()

EXISTS

RObject.
isExists()
isExistsAsync()

RObjectReactive.
isExists()

FLUSHALL

RKeys.
flushall()
flushallAsync()

RKeysReactive.
flushall()

FLUSHDB

RKeys.
flushdb()
flushdbAsync()

RKeysReactive.
flushdb()

GETRANGE

RBinaryStream.
getChannel().read()

RBinaryStreamReactive.
read()

GEOADD

RGeo.
add()
addAsync()

RGeoReactive.
add()

GEODIST

RGeo.
dist()
distAsync()

RGeoReactive.
dist()

GEOHASH

RGeo.
hash()
hashAsync()

RGeoReactive.
hash()

GEOPOS

RGeo.
pos()
posAsync()

RGeoReactive.
pos()

GEORADIUS

RGeo.
radius()
radiusAsync()
radiusWithDistance()
radiusWithDistanceAsync()
radiusWithPosition()
radiusWithPositionAsync()

RGeoReactive.
radius()
radiusWithDistance()
radiusWithPosition()

GET

RBucket.
get()
getAsync()

RBinaryStream.
get()
getAsync()

RBucketReactive.
get()

RBinaryStreamReactive.
get()

GETBIT

RBitSet.
get()
getAsync()

RBitSetReactive.
get()

GETSET

RBucket.
getAndSet()
getAndSetAsync()

RAtomicLong.
getAndSet()
getAndSetAsync()

RAtomicDouble.
getAndSet()
getAndSetAsync()

RBucketReactive.
getAndSet()

RAtomicLongReactive.
getAndSet()

RAtomicDoubleReactive.
getAndSet()

HDEL

RMap.
fastRemove()
fastRemoveAsync()

RMapReactive.
fastRemove()

HEXISTS

RMap.
containsKey()
containsKeyAsync()

RMapReactive.
containsKey()

HGET

RMap.
get()
getAsync()

RMapReactive.
get()

HSTRLEN

RMap.
valueSize()
valueSizeAsync()

RMapReactive.
valueSize()

HGETALL

RMap.
readAllEntrySet()
readAllEntrySetAsync()

RMapReactive.
readAllEntrySet()

HINCRBY

RMap.
addAndGet()
addAndGetAsync()

RMapReactive.
addAndGet()

HINCRBYFLOAT

RMap.
addAndGet()
addAndGetAsync()

RMapReactive.
addAndGet()

HKEYS

RMap.
readAllKeySet()
readAllKeySetAsync()

RMapReactive.
readAllKeySet()

HLEN

RMap.
size()
sizeAsync()

RMapReactive.
size()

HMGET

RMap.
getAll()
getAllAsync()

RMapReactive.
getAll()

HMSET

RMap.
putAll()
putAllAsync()

RMapReactive.
putAll()

HSCAN

RMap.
keySet().iterator()
values().iterator()
entrySet().iterator()

RMapReactive.
keyIterator()
valueIterator()
entryIterator()

HSET

RMap.
fastPut()
fastPutAsync()

RMapReactive.
fastPut()

HSETNX

RMap.
fastPutIfAbsent()
fastPutIfAbsentAsync()

RMapReactive.
fastPutIfAbsent()

HVALS

RMap.
readAllValues()
readAllValuesAsync()

RMapReactive.
readAllValues()

INCR

RAtomicLong.
incrementAndGet()
incrementAndGetAsync()

RAtomicLongReactive.
incrementAndGet()

INCRBY

RAtomicLong.
addAndGet()
addAndGetAsync()

RAtomicLongReactive.
addAndGet()

INCRBYFLOAT

RAtomicDouble.
addAndGet()
addAndGetAsync()

RAtomicDoubleReactive.
addAndGet()

KEYS

RKeys.
getKeysByPattern()
getKeysByPatternAsync()

RKeysReactive.
getKeysByPattern()

LINDEX

RList.
get()
getAsync()

RListReactive.
get()

LLEN

RList.
size()
sizeAsync()

RListReactive.
size()

LPOP

RQueue.
poll()
pollAsync()

RQueueReactive.
poll()

LPUSH

RDeque.
addFirst()
addFirstAsync()

RDequeReactive.
addFirst()

LRANGE

RList.
readAll()
readAllAsync()

RListReactive.readAll()

LPUSHX

RDeque.
addFirstIfExists()
addFirstIfExistsAsync()

RDequeReactive.
addFirstIfExists()

LREM

RList.
fastRemove()
fastRemoveAsync()

RListReactive.
fastRemove()

LSET

RList.
fastSet()
fastSetAsync()

RListReactive.
fastSet()

LTRIM

RList.
trim()
trimAsync()

RListReactive.
trim()

LINSERT

RList.
addBefore()
addAfter()
addBeforeAsync()
addAfterAsync()

RListReactive.
addBefore()
addAfter()

MULTI

RBatch.
execute()
executeAsync()

RBatchReactive.
execute()

MGET

RBuckets.
get()
getAsync()

RBucketsReactive.
get()

MSETNX

RBuckets.
trySet()
trySetAsync()

RBucketsReactive.
trySet()

MIGRATE

RObject.
migrate()
migrateAsync()

RObjectReactive.
migrate()

MOVE

RObject.
move()
moveAsync()

RObjectReactive.
move()

MSET

RBuckets.
set()
setAsync()

RBucketsReactive.
set()

PERSIST

RExpirable.
clearExpire()
clearExpireAsync()

RExpirableReactive.
clearExpire()

PEXPIRE

RExpirable.
expire()
expireAsync()

RExpirableReactive.
expire()

PEXPIREAT

RExpirable.
expireAt()
expireAtAsync()

RExpirableReactive.
expireAt()

PFADD

RHyperLogLog.
add()
addAsync()
addAll()
addAllAsync()

RHyperLogLogReactive.
add()

addAll()

PFCOUNT

RHyperLogLog.
count()
countAsync()
countWith()
countWithAsync()

RHyperLogLogReactive.
count()
countWith()

PFMERGE

RHyperLogLog.
mergeWith()
mergeWithAsync()

RHyperLogLogReactive.
mergeWith()

PING

Node.ping()
NodesGroup.pingAll()

-

PSUBSCRIBE

RPatternTopic.
addListener()

RPatternTopicReactive.
addListener()

PSETEX

RBucket.
set()
setAsync()

RBucketReactive.
set()

PTTL

RExpirable.
remainTimeToLive()
remainTimeToLiveAsync()

RExpirableReactive.
remainTimeToLive()

PUBLISH

RTopic.
publish()

RTopicReactive.
publish()

PUBSUB NUMSUB

RTopic.
countSubscribers()
countSubscribersAsync()

RTopicReactive.
countSubscribers()

PUNSUBSCRIBE

RPatternTopic.
removeListener()

RPatternTopicReactive.
removeListener()

RANDOMKEY

RKeys.
randomKey()
randomKeyAsync()

RKeysReactive.
randomKey()

RESTORE

RObject.
restore()
restoreAsync()

RObjectReactive.
restore()

RENAME

RObject.
rename()
renameAsync()

RObjectReactive.
rename()

RPOP

RDeque.
pollLast()
removeLast()
pollLastAsync()
removeLastAsync()

RDequeReactive.
pollLast()
removeLast()

RPOPLPUSH

RDeque.
pollLastAndOfferFirstTo()
pollLastAndOfferFirstToAsync()

RDequeReactive.
pollLastAndOfferFirstTo()

RPUSH

RList.
add()
addAsync()

RListReactive.
add()

RPUSHX

RDeque.
addLastIfExists()
addLastIfExistsAsync()

RListReactive.
addLastIfExists()

SADD

RSet.
add()
addAsync()

RSetReactive.
add()

SETRANGE

RBinaryStream.
getChannel().write()

RBinaryStreamReactive.
write()

SCAN

RKeys.
getKeys()

RKeysReactive.
getKeys()

SCARD

RSet.
size()
sizeAsync()

RSetReactive.
size()

SCRIPT EXISTS

RScript.
scriptExists()
scriptExistsAsync()

RScriptReactive.
scriptExists()

SCRIPT FLUSH

RScript.
scriptFlush()
scriptFlushAsync()

RScriptReactive.
scriptFlush()

SCRIPT KILL

RScript.
scriptKill()
scriptKillAsync()

RScriptReactive.
scriptKill()

SCRIPT LOAD

RScript.
scriptLoad()
scriptLoadAsync()

RScriptReactive.
scriptLoad()

SDIFFSTORE

RSet.
diff()
diffAsync()

RSetReactive.
diff()

SDIFF

RSet.
readDiff()
readDiffAsync()

RSetReactive.
readDiff()

SRANDMEMBER

RSet.
random()
randomAsync()

RSetReactive.
random()

SELECT

Config.setDatabase()

-

SET

RBucket.
set()
setAsync()

RBucketReactive.
set()

SETBIT

RBitSet.
set()
clear()
setAsync()
clearAsync()

RBitSetReactive.
set()
clear()

SETEX

RBucket.
set()
setAsync()

RBucketReactive.
set()

SETNX

RBucket.
trySet()
trySetAsync()

RBucketReactive.
trySet()

SISMEMBER

RSet.
contains()
containsAsync()

RSetReactive.
contains()

SINTERSTORE

RSet.
intersection()
intersectionAsync()

RSetReactive.
intersection()

SINTER

RSet.
readIntersection()
readIntersectionAsync()

RSetReactive.
readIntersection()

SMEMBERS

RSet.
readAll()
readAllAsync()

RSetReactive.
readAll()

SMOVE

RSet.
move()
moveAsync()

RSetReactive.
move()

SORT

RList.
readSort()
sortTo()
readSortAsync()
sortToAsync()

RListReactive.
readSort()
sortTo()

SPOP

RSet.
removeRandom()
removeRandomAsync()

RSetReactive.
removeRandom()

SREM

RSet.
remove()
removeAsync()

RSetReactive.
remove()

SSCAN

RSet.
iterator()

RSetReactive.
iterator()

SUBSCRIBE

RTopic.
addListener()

RTopicReactive.
addListener()

SUNION

RSet.
readUnion()
readUnionAsync()

RSetReactive.
readUnion()

SUNIONSTORE

RSet.
union()
unionAsync()

RSetReactive.
union()

SWAPDB

RKeys.
swapdb()
swapdbAsync()

RKeysReactive.
swapdb()

TTL

RExpirable.
remainTimeToLive()
remainTimeToLiveAsync()

RExpirableReactive.
remainTimeToLive()

TYPE

RKeys.
getType()
getTypeAsync()

RKeysReactive.
getType()

TOUCH

RObject.
touch()
touchAsync()

RObjectReactive.
touch()

UNSUBSCRIBE

RTopic.
removeListener()

RTopicReactive.
removeListener()

UNLINK

RObject.
unlink()
unlinkAsync()

RObjectReactive.
unlink()

WAIT

BatchOptions.
syncSlaves()

BatchOptions.
syncSlaves()

ZADD

RScoredSortedSet.
add()
addAsync()

RScoredSortedSetReactive.
add()

ZCARD

RScoredSortedSet.
size()
sizeAsync()

RScoredSortedSetReactive.
size()

ZCOUNT

RScoredSortedSet.
count()
countAsync()

RScoredSortedSetReactive.
count()

ZINCRBY

RScoredSortedSet.
addScore()
addScoreAsync()

RScoredSortedSetReactive.
addScore()

ZREMRANGEBYRANK

RScoredSortedSet.
removeRangeByRank()
removeRangeByRankAsync()

RScoredSortedSetReactive.
removeRangeByRank()

ZREVRANGEBYLEX

RLexSortedSet.
rangeReversed()
rangeReversedAsync()

RLexSortedSetReactive.
rangeReversed()

ZLEXCOUNT

RLexSortedSet.
lexCount()
lexCountHead()
lexCountTail()
lexCountAsync()
lexCountHeadAsync()
lexCountTailAsync()

RLexSortedSetReactive.
lexCount()
lexCountHead()
lexCountTail()

ZRANGE

RScoredSortedSet.
valueRange()
valueRangeAsync()

RScoredSortedSetReactive.
valueRange()

ZREVRANGE

RScoredSortedSet.
valueRangeReversed()
valueRangeReversedAsync()

RScoredSortedSetReactive.
valueRangeReversed()

ZUNIONSTORE

RScoredSortedSet.
union()
unionAsync()

RScoredSortedSetReactive.
union()

ZINTERSTORE

RScoredSortedSet.
intersection()
intersectionAsync()

RScoredSortedSetReactive.
intersection()

ZRANGEBYLEX

RLexSortedSet.
range()
rangeHead()
rangeTail()
rangeAsync()
rangeHeadAsync()
rangeTailAsync()

RLexSortedSetReactive.
range()
rangeHead()
rangeTail()

ZRANGEBYSCORE

RScoredSortedSet.
valueRange()
entryRange()
valueRangeAsync()
entryRangeAsync()

RScoredSortedSetReactive.
valueRange()
entryRange()

TIME

RedissonClient.
getNodesGroup().
getNode().time()
getClusterNodesGroup().
getNode().time()

-

ZRANK

RScoredSortedSet.
rank()
rankAsync()

RScoredSortedSetReactive.
rank()

ZREM

RScoredSortedSet.
remove()
removeAll()
removeAsync()
removeAllAsync()

RScoredSortedSetReactive.
remove()
removeAll()

ZREMRANGEBYLEX

RLexSortedSet.
removeRange()
removeRangeHead()
removeRangeTail()
removeRangeAsync()
removeRangeHeadAsync()
removeRangeTailAsync()

RLexSortedSetReactive.
removeRange()
removeRangeHead()
removeRangeTail()

ZREMRANGEBYSCORE

RScoredSortedSet.
removeRangeByScore()
removeRangeByScoreAsync()

RScoredSortedSetReactive.
removeRangeByScore()

ZREVRANGEBYSCORE

RScoredSortedSet.
valueRangeReversed()
entryRangeReversed()
valueRangeReversedAsync()
entryRangeReversedAsync()

RScoredSortedSetReactive.
entryRangeReversed()
valueRangeReversed()

ZREVRANK

RScoredSortedSet.
revRank()
revRankAsync()

RScoredSortedSetReactive.
revRank()

ZSCORE

RScoredSortedSet.
getScore()
getScoreAsync()

RScoredSortedSetReactive.
getScore()

ZPOPMAX

RScoredSortedSet.
pollLast()
pollLastAsync()

RScoredSortedSetReactive.
pollLast()

ZPOPMIN

RScoredSortedSet.
pollFirst()
pollFirstAsync()

RScoredSortedSetReactive.
pollFirst()

XACK

RStream.
ack()
ackAsync()

RStreamReactive.
ack()

XADD

RStream.
add()
addAsync()

RStreamReactive.
add()

XCLAIM

RStream.
claim()
claimAsync()

RStreamReactive.
claim()

XDEL

RStream.
remove()
removeAsync()

RStreamReactive.
remove()

XGROUP

RStream.
createGroup()
removeGroup()
updateGroup()
createGroupAsync()
removeGroupAsync()
updateGroupAsync()

RStreamReactive.
createGroup()
removeGroup()
updateGroup()

XINFO

RStream.
getInfo()
listGroups()
listConsumers()
getInfoAsync()
listGroupsAsync()
listConsumersAsync()

RStreamReactive.
getInfo()
listGroups()
listConsumers()

XLEN

RStream.
size()
sizeAsync()

RStreamReactive.
size()

XPENDING

RStream.
listPending()
listPendingAsync()

RStreamReactive.
listPending()

XRANGE

RStream.
range()
rangeAsync()

RStreamReactive.
range()

XREAD

RStream.
read()
readAsync()

RStreamReactive.
read()

XREADGROUP

RStream.
readGroup()
readGroupAsync()

RStreamReactive.
readGroup()

XREVRANGE

RStream.
rangeReversed()
rangeReversedAsync()

RStreamReactive.
rangeReversed()