Redisson--Redis命令与Redisson方法对应__redisson和redis区别

link之家

链接快照平台

输入网页链接，自动生成快照
标签化管理网页链接

简介

说明

本文介绍Redis命令与Redisson（RedissonClient）方法的对应关系。

官网

https://github.com/redisson/redisson/wiki/11.-Redis-commands-mapping

对应关系表

Redis command	Sync / Async Api Redisson.create(config)	Reactive Api Redisson.createReactive(config)	RxJava2 Api Redisson.createRx(config)
AUTH	Config.setPassword()	-	-
APPEND	RBinaryStream. getOutputStream().write()	-	-
BZPOPMAX	RScoredSortedSet. pollLast() pollLastAsync()	RScoredSortedSetReactive. pollLast()	RScoredSortedSetRx. pollLast()
BZPOPMIN	RScoredSortedSet. pollFirst() pollFirstAsync()	RScoredSortedSetReactive. pollFirst()	RScoredSortedSetRx. pollFirst()
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()
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()
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()	-	-
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()
GET	RBucket. get() getAsync() RBinaryStream. get() getAsync()	RBucketReactive. get() RBinaryStreamReactive. get()	RBucketRx. get() RBinaryStreamRx. get()
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()
HSCAN	RMap. keySet().iterator() values().iterator() entrySet().iterator()	RMapReactive. keyIterator() valueIterator() entryIterator()	RMapRx. keyIterator() valueIterator() entryIterator()
HSET	RMap. fastPut() fastPutAsync()	RMapReactive. fastPut()	RMapRx. fastPut()
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()
KEYS	RKeys. getKeysByPattern() getKeysByPatternAsync()	RKeysReactive. getKeysByPattern()	RKeysRx. getKeysByPattern()
LINDEX	RList. get() getAsync()	RListReactive. get()	RListRx. get()
LLEN	RList. size() sizeAsync()	RListReactive. size()	RListRx. size()
LPOP	RQueue. poll() pollAsync()	RQueueReactive. poll()	RQueueRx. poll()
LPUSH	RDeque. addFirst() addFirstAsync()	RDequeReactive. 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()
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. trySet() trySetAsync()	RBucketReactive. trySet()	RBucketRx. trySet()
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. syncSlaves()	BatchOptions. syncSlaves()	BatchOptions. syncSlaves()
ZADD	RScoredSortedSet. add() addAsync()	RScoredSortedSetReactive. add()	RScoredSortedSetRx. add()
ZCARD	RScoredSortedSet. size() sizeAsync()	RScoredSortedSetReactive. size()	RScoredSortedSetRx. size()
ZCOUNT	RScoredSortedSet. count() countAsync()	RScoredSortedSetReactive. count()	RScoredSortedSetRx. count()
ZINCRBY	RScoredSortedSet. addScore() addScoreAsync()	RScoredSortedSetReactive. addScore()	RScoredSortedSetRx. addScore()
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()
ZREVRANGE	RScoredSortedSet. valueRangeReversed() valueRangeReversedAsync()	RScoredSortedSetReactive. valueRangeReversed()	RScoredSortedSetRx. valueRangeReversed()
ZUNIONSTORE	RScoredSortedSet. union() unionAsync()	RScoredSortedSetReactive. union()	RScoredSortedSetRx. union()
ZINTERSTORE	RScoredSortedSet. intersection() intersectionAsync()	RScoredSortedSetReactive. intersection()	RScoredSortedSetRx. intersection()
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()
ZPOPMAX	RScoredSortedSet. pollLast() pollLastAsync()	RScoredSortedSetReactive. pollLast()	RScoredSortedSetRx. pollLast()
ZPOPMIN	RScoredSortedSet. pollFirst() pollFirstAsync()	RScoredSortedSetReactive. pollFirst()	RScoredSortedSetRx. pollFirst()
XACK	RStream. ack() ackAsync()	RStreamReactive. ack()	RStreamRx. ack()
XADD	RStream. add() addAsync()	RStreamReactive. add()	RStreamRx. add()
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()