Redisson--使用/教程/实例

小咪咪 2022-09-15 05:46 609阅读 0赞

原文网址：[Redisson--使用/教程/实例\_IT利刃出鞘的博客-CSDN博客][Redisson--_IT_-CSDN]

# **简介** #

**说明**

本文用实例介绍Redisson的用法。

Redis的客户端有RedisTemplate、Jedis、Redisson等。Redisson是最好的客户端，原因如下：

1.  简单好用。
    
    1.  它实现了JDK里的List、Set、Map等接口，可以用操作JDK的类的方式操作Redis。
2.  分布式锁很完美。
    
    1.  它在锁的续期、可重入、释放等处理的很好。详见：[Redisson原理--续期/释放/互斥/可重入\_IT利刃出鞘的博客-CSDN博客][Redisson_--_IT_-CSDN]

**官网**

git文档：[https://github.com/redisson/redisson/wiki][https_github.com_redisson_redisson_wiki]  
git：[https://github.com/redisson/redisson][https_github.com_redisson_redisson]  
官网：[https://redisson.org/][https_redisson.org]

**Redisson功能**

*  支持同步/异步/异步流/管道流方式连接
 *  多样化数据序列化
 *  集合数据分片
 *  分布式对象
 *  分布式集合
 *  分布式锁和同步器
 *  分布式服务
 *  独立节点模式
 *  三方框架整合

# 依赖 #

<dependency>
 <groupId>org.redisson</groupId>
 <artifactId>redisson-spring-boot-starter</artifactId>
 <version>3.16.1</version>
 </dependency>

当然，只引用Redisson也可以。（但这样配置繁琐，本文不使用此法）

<dependency>
 <groupId>org.redisson</groupId>
 <artifactId>redisson</artifactId>
 <version>3.8.2</version>
 </dependency>

# 配置 #

**官网**

[2. 配置方法 · redisson/redisson Wiki · GitHub][2. _ _ redisson_redisson Wiki _ GitHub]（官网wiki的配置文档）

**简介**

以下方法的推荐度由高到低。

对于配置文件方案，引入的依赖必须是redisson-spring-boot-starter；对于配置类配置方案，引入的依赖可以是redisson-spring-boot-starter也可以是redisson。

**法1：application.yml**

spring:
      redis:
        host: 
        port: 
        database: 
        password: 
        cluster:
          nodes: 
        sentinel:
          master: 
          nodes: 
        ssl: 
        timeout:

上边这个redis的通用配置基本够用了。可对Redisson进行更加详细的配置：哨兵、集群等

spring:
 redis:
 host: 
 port: 
 database: 
 password: 
 cluster:
 nodes: 
 sentinel:
 master: 
 nodes: 
 ssl: 
 timeout: 
 redisson:
 clusterServersConfig:
 idleConnectionTimeout: 10000
 connectTimeout: 10000
 timeout: 3000
 retryAttempts: 3
 retryInterval: 1500
 password: null
 subscriptionsPerConnection: 5
 clientName: null
 loadBalancer: !<org.redisson.connection.balancer.RoundRobinLoadBalancer> {}
 slaveSubscriptionConnectionMinimumIdleSize: 1
 slaveSubscriptionConnectionPoolSize: 50
 slaveConnectionMinimumIdleSize: 32
 slaveConnectionPoolSize: 64
 masterConnectionMinimumIdleSize: 32
 masterConnectionPoolSize: 64
 readMode: "SLAVE"
 nodeAddresses:
 - "redis://127.0.0.1:7004"
 - "redis://127.0.0.1:7001"
 - "redis://127.0.0.1:7000"
 scanInterval: 1000
 threads: 0
 nettyThreads: 0
 codec: !<org.redisson.codec.JsonJacksonCodec> {}
 "transportMode":"NIO"

**法2：将redisson配置单独拿出来**

需要在Resource目录下创建redisson.yml。

redisson配置文件优先级高于springboot配置文件优先级；

application.yml

spring:
      redis:
        host: 
        port: 
        database: 
        password: 
        cluster:
          nodes: 
        sentinel:
          master: 
          nodes: 
        ssl: 
        timeout: 
        redisson:
          config: classpath:redisson.yml

redisson.yml

clusterServersConfig:
 idleConnectionTimeout: 10000
 connectTimeout: 10000
 timeout: 3000
 retryAttempts: 3
 retryInterval: 1500
 password: null
 subscriptionsPerConnection: 5
 clientName: null
 loadBalancer: !<org.redisson.connection.balancer.RoundRobinLoadBalancer> {}
 slaveSubscriptionConnectionMinimumIdleSize: 1
 slaveSubscriptionConnectionPoolSize: 50
 slaveConnectionMinimumIdleSize: 32
 slaveConnectionPoolSize: 64
 masterConnectionMinimumIdleSize: 32
 masterConnectionPoolSize: 64
 readMode: "SLAVE"
 nodeAddresses:
 - "redis://127.0.0.1:7004"
 - "redis://127.0.0.1:7001"
 - "redis://127.0.0.1:7000"
 scanInterval: 1000
 threads: 0
 nettyThreads: 0
 codec: !<org.redisson.codec.JsonJacksonCodec> {}
 "transportMode":"NIO"

**法3：编写配置类（不推荐）**

需要在Resource目录下创建redisson.yml。

@Configuration
    public class RedssonConfig {
        @Bean(destroyMethod="shutdown")
        public RedissonClient redisson() throws IOException {
            RedissonClient redisson = Redisson.create(
                    Config.fromYAML(new ClassPathResource("redisson-single.yml").getInputStream()));
            return redisson;
        }
    }

上边这种方法已经违背配置大于编程了。

**法4：用代码配置（不推荐）**

import org.redisson.Redisson;
    import org.redisson.api.RedissonClient;
    import org.redisson.config.Config;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    @Configuration
    public class RedissonConfig {
        @Bean
        public RedissonClient redissonClient() {
    		//指定编码，默认编码为org.redisson.codec.JsonJacksonCodec   
    		//config.setCodec(new org.redisson.client.codec.StringCodec());  
    		
    		config.useSingleServer().setAddress("redis://127.0.0.1:6379");  
    		config.useSingleServer().setClientName("root");
    		config.useSingleServer().setPassword("abcabc");
    		 
            return Redisson.create(config);
        }
    }

# 实例 #

**其他网址**

[2-(1)、SpringBoot整合redisson实现分布式锁 - 简书][2-_1_SpringBoot_redisson_ -]  
[（Redis使用系列） Springboot 整合Redisson 实现分布式锁 七-CSDN博客][Redis_ Springboot _Redisson _ _-CSDN]  
[SpringBoot集成redisson分布式锁 - 自行车上的程序员 - 博客园][SpringBoot_redisson_ - _ -]

**代码**

package com.xiaoliu.redission.lock;
    
    import org.redisson.api.RLock;
    import org.redisson.api.RedissonClient;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.data.redis.core.StringRedisTemplate;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    @RestController
    public class ShopCartController {
        @Autowired
        private StringRedisTemplate stringRedisTemplate;
    
        @Autowired
        private RedissonClient redissonClient;
    
        private static final String product="MoonCake";
    
        @GetMapping("/submitOrder")
        public String submitOrder(){
            RLock lock = redissonClient.getLock(product);
    
            try {
                lock.lock();//阻塞
    //            boolean b = lock.tryLock();//非阻塞
                int stock = Integer.parseInt(stringRedisTemplate.opsForValue().get("stock"));
                if (stock>0){
                    //下单
                    stock-=1;
                    stringRedisTemplate.opsForValue().set("stock", String.valueOf(stock));
                    System.out.println("扣减成功，库存stock："+stock);
                }else {
                    //没库存
                    System.out.println("扣减失败，库存不足");
                }
            } finally {
                lock.unlock();//释放锁
            }
            return "end";
        }
    }

# 常用操作 #

**获得Redisson客户端**

@Autowired
    private RedissonClient redissonClient;

**根据key获得value**

**所有get开头的方法：**如果key不存在会在保存时以此key为key保存。

<table> 
 <tbody> 
 <tr> 
 <td>方法</td> 
 <td>返回类型</td> 
 </tr> 
 <tr> 
 <td>getSet("xxx")</td> 
 <td>RSet&lt;SomeObject&gt;</td> 
 </tr> 
 <tr> 
 <td>getList("xxx")</td> 
 <td>RList&lt;SomeObject&gt;</td> 
 </tr> 
 <tr> 
 <td>getMap("anyMap");</td> 
 <td>RMap&lt;String, SomeObject&gt;</td> 
 </tr> 
 <tr> 
 <td>getSetMultimap("myMultimap");</td> 
 <td>RSetMultimap&lt;SimpleKey, SimpleValue&gt;</td> 
 </tr> 
 <tr> 
 <td>getSortedSet("anySet");</td> 
 <td>RSortedSet&lt;Integer&gt;</td> 
 </tr> 
 <tr> 
 <td>getScoredSortedSet("simple");</td> 
 <td>RScoredSortedSet&lt;SomeObject&gt;</td> 
 </tr> 
 <tr> 
 <td>getLexSortedSet("simple");</td> 
 <td>RLexSortedSet set</td> 
 </tr> 
 <tr> 
 <td>getQueue("anyQueue");</td> 
 <td>RQueue&lt;SomeObject&gt;</td> 
 </tr> 
 <tr> 
 <td>getDeque("anyDeque");</td> 
 <td>RDeque&lt;SomeObject&gt;</td> 
 </tr> 
 <tr> 
 <td>getBlockingQueue("anyQueue");</td> 
 <td>BlockingQueue&lt;SomeObject&gt;</td> 
 </tr> 
 <tr> 
 <td>getBoundedBlockingQueue("anyQueue");</td> 
 <td>RBoundedBlockingQueue&lt;SomeObject&gt;</td> 
 </tr> 
 <tr> 
 <td>getBlockingDeque("anyDeque");</td> 
 <td>RBlockingDeque&lt;Integer&gt;</td> 
 </tr> 
 <tr> 
 <td>getBlockingFairQueue("myQueue");</td> 
 <td>RBlockingFairQueue</td> 
 </tr> 
 <tr> 
 <td>getBlockingFairDeque("myDeque");</td> 
 <td>RBlockingFairDeque</td> 
 </tr> 
 <tr> 
 <td>getDelayedQueue(distinationQueue);</td> 
 <td>RDelayedQueue&lt;String</td> 
 </tr> 
 <tr> 
 <td>getPriorityQueue("anyQueue");</td> 
 <td>RPriorityQueue&lt;Integer&gt;</td> 
 </tr> 
 <tr> 
 <td>getPriorityDeque("anyQueue");</td> 
 <td>RPriorityDeque&lt;Integer&gt;</td> 
 </tr> 
 <tr> 
 <td>getPriorityBlockingQueue("anyQueue");</td> 
 <td>RPriorityBlockingQueue&lt;Integer&gt;</td> 
 </tr> 
 <tr> 
 <td>RPriorityBlockingDeque&lt;Integer&gt;</td> 
 <td>getPriorityBlockingDeque("anyQueue");</td> 
 </tr> 
 </tbody> 
</table>

**将key-value写回Redis**

所有添加都会自动将值写回Redis。例如：

RSet<String> set = redisson.getSet("anySet");
 set.add("Tony");

# **所有方法** #

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaXlpbmcwY2FuZ2xhbmc_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaXlpbmcwY2FuZ2xhbmc_size_16_color_FFFFFF_t_70 1][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaXlpbmcwY2FuZ2xhbmc_size_16_color_FFFFFF_t_70 2][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaXlpbmcwY2FuZ2xhbmc_size_16_color_FFFFFF_t_70 3][]

# 过期时间 #

**所有的类型都有过期时间**，例如：

RSet<String> set = redisson.getSet("anySet");
 set.add("Tony");
 set.expire(3, TimeUnit.MINUTES);

**过期时间在类型为空时是无效的**，例如：

RSet<String> set = redisson.getSet("anySet");
 set.expire(3, TimeUnit.MINUTES);
 set.add("Tony");

**也可以给某一个值设置过期时间**

RSetCache<String> set = redisson.getSetCache("anySet");
 // ttl = 10 seconds
 set.add("abc", 10, TimeUnit.SECONDS);

# Redis命令与Redisson方法对应 #

<table> 
 <thead> 
 <tr> 
 <th>Redis command</th> 
 <th>Sync / Async Api Redisson.create(config)</th> 
 <th>Reactive Api Redisson.createReactive(config)</th> 
 <th>RxJava2 Api Redisson.createRx(config)</th> 
 </tr> 
 </thead> 
 <tbody> 
 <tr> 
 <td>AUTH</td> 
 <td>Config.setPassword()</td> 
 <td>-</td> 
 <td>-</td> 
 </tr> 
 <tr> 
 <td>APPEND</td> 
 <td>RBinaryStream. getOutputStream().write()</td> 
 <td>-</td> 
 <td>-</td> 
 </tr> 
 <tr> 
 <td>BZPOPMAX</td> 
 <td>RScoredSortedSet. pollLast() pollLastAsync()</td> 
 <td>RScoredSortedSetReactive. pollLast()</td> 
 <td>RScoredSortedSetRx. pollLast()</td> 
 </tr> 
 <tr> 
 <td>BZPOPMIN</td> 
 <td>RScoredSortedSet. pollFirst() pollFirstAsync()</td> 
 <td>RScoredSortedSetReactive. pollFirst()</td> 
 <td>RScoredSortedSetRx. pollFirst()</td> 
 </tr> 
 <tr> 
 <td>BITCOUNT</td> 
 <td>RBitSet. cardinality() cardinalityAsync()</td> 
 <td>RBitSetReactive. cardinality()</td> 
 <td>RBitSetRx. cardinality()</td> 
 </tr> 
 <tr> 
 <td>BITOP</td> 
 <td>RBitSet. or() and() xor() orAsync() andAsync() xorAsync()</td> 
 <td>RBitSetReactive. or() and() xor()</td> 
 <td>RBitSetRx. or() and() xor()</td> 
 </tr> 
 <tr> 
 <td>BITPOS</td> 
 <td>RBitSet. length() lengthAsync()</td> 
 <td>RBitSetReactive. length()</td> 
 <td>RBitSetRx. length()</td> 
 </tr> 
 <tr> 
 <td>BLPOP</td> 
 <td>RBlockingQueue. take() poll() pollFromAny() takeAsync() pollAsync() pollFromAnyAsync()</td> 
 <td>RBlockingQueueReactive. take() poll() pollFromAny()</td> 
 <td>RBlockingQueueRx. take() poll() pollFromAny()</td> 
 </tr> 
 <tr> 
 <td>BRPOP</td> 
 <td>RBlockingDeque. takeLast() takeLastAsync()</td> 
 <td>RBlockingDequeReactive. takeLast()</td> 
 <td>RBlockingDequeRx. takeLast()</td> 
 </tr> 
 <tr> 
 <td>BRPOPLPUSH</td> 
 <td>RBlockingQueue. pollLastAndOfferFirstTo() pollLastAndOfferFirstToAsync()</td> 
 <td>RBlockingQueueReactive. pollLastAndOfferFirstTo()</td> 
 <td>RBlockingQueueRx. pollLastAndOfferFirstTo()</td> 
 </tr> 
 <tr> 
 <td>CONFIG GET</td> 
 <td>RedisNode. setConfig() setConfigAsync()</td> 
 <td>-</td> 
 <td>-</td> 
 </tr> 
 <tr> 
 <td>CONFIG SET</td> 
 <td>RedisNode. getConfig() getConfigAsync()</td> 
 <td>-</td> 
 <td>-</td> 
 </tr> 
 <tr> 
 <td>COPY</td> 
 <td>RObject. copy() copyAsync()</td> 
 <td>RObjectReactive. copy()</td> 
 <td>RObjectRx. copy()</td> 
 </tr> 
 <tr> 
 <td>CLIENT SETNAME</td> 
 <td>Config.setClientName()</td> 
 <td>-</td> 
 <td>-</td> 
 </tr> 
 <tr> 
 <td>CLIENT REPLY</td> 
 <td>BatchOptions.skipResult()</td> 
 <td>-</td> 
 <td>-</td> 
 </tr> 
 <tr> 
 <td>CLUSTER INFO</td> 
 <td>ClusterNode.info()</td> 
 <td>-</td> 
 <td>-</td> 
 </tr> 
 <tr> 
 <td>CLUSTER KEYSLOT</td> 
 <td>RKeys. getSlot() getSlotAsync()</td> 
 <td>RKeysReactive. getSlot()</td> 
 <td>RKeysRx. getSlot()</td> 
 </tr> 
 <tr> 
 <td>CLUSTER NODES</td> 
 <td>Used in ClusterConnectionManager</td> 
 <td></td> 
 <td></td> 
 </tr> 
 <tr> 
 <td>DECRBY</td> 
 <td>RAtomicLong. addAndGet() addAndGetAsync()</td> 
 <td>RAtomicLongReactive. addAndGet()</td> 
 <td>RAtomicLongRx. addAndGet()</td> 
 </tr> 
 <tr> 
 <td>DUMP</td> 
 <td>RObject. dump() dumpAsync()</td> 
 <td>RObjectReactive. dump()</td> 
 <td>RObjectRx. dump()</td> 
 </tr> 
 <tr> 
 <td>DBSIZE</td> 
 <td>RKeys. count() countAsync()</td> 
 <td>RKeysReactive. count()</td> 
 <td>RKeysRx.count()</td> 
 </tr> 
 <tr> 
 <td>DECR</td> 
 <td>RAtomicLong. decrementAndGet() decrementAndGetAsync()</td> 
 <td>RAtomicLongReactive. decrementAndGet()</td> 
 <td>RAtomicLongRx. decrementAndGet()</td> 
 </tr> 
 <tr> 
 <td>DEL</td> 
 <td>RObject. delete() deleteAsync() RKeys. delete() deleteAsync()</td> 
 <td>RObjectReactive. delete() RKeysReactive. delete()</td> 
 <td>RObjectRx. delete() RKeysRx. delete()</td> 
 </tr> 
 <tr> 
 <td>STRLEN</td> 
 <td>RBucket. size() sizeAsync()</td> 
 <td>RBucketReactive. size()</td> 
 <td>RBucketRx. size()</td> 
 </tr> 
 <tr> 
 <td>EVAL</td> 
 <td>RScript. eval() evalAsync()</td> 
 <td>RScriptReactive. eval()</td> 
 <td>RScriptRx. eval()</td> 
 </tr> 
 <tr> 
 <td>EVALSHA</td> 
 <td>RScript. evalSha() evalShaAsync()</td> 
 <td>RScriptReactive. evalSha()</td> 
 <td>RScriptRx. evalSha()</td> 
 </tr> 
 <tr> 
 <td>EXEC</td> 
 <td>RBatch. execute() executeAsync()</td> 
 <td>RBatchReactive. execute()</td> 
 <td>RBatchRx. execute()</td> 
 </tr> 
 <tr> 
 <td>EXISTS</td> 
 <td>RObject. isExists() isExistsAsync()</td> 
 <td>RObjectReactive. isExists()</td> 
 <td>RObjectRx. isExists()</td> 
 </tr> 
 <tr> 
 <td>FLUSHALL</td> 
 <td>RKeys. flushall() flushallAsync()</td> 
 <td>RKeysReactive. flushall()</td> 
 <td>RKeysRx. flushall()</td> 
 </tr> 
 <tr> 
 <td>FLUSHDB</td> 
 <td>RKeys. flushdb() flushdbAsync()</td> 
 <td>RKeysReactive. flushdb()</td> 
 <td>RKeysRx. flushdb()</td> 
 </tr> 
 <tr> 
 <td>GETRANGE</td> 
 <td>RBinaryStream. getChannel().read()</td> 
 <td>RBinaryStreamReactive. read()</td> 
 <td>RBinaryStreamRx. read()</td> 
 </tr> 
 <tr> 
 <td>GEOADD</td> 
 <td>RGeo. add() addAsync()</td> 
 <td>RGeoReactive. add()</td> 
 <td>RGeoRx. add()</td> 
 </tr> 
 <tr> 
 <td>GEODIST</td> 
 <td>RGeo. dist() distAsync()</td> 
 <td>RGeoReactive. dist()</td> 
 <td>RGeoRx. dist()</td> 
 </tr> 
 <tr> 
 <td>GEOHASH</td> 
 <td>RGeo. hash() hashAsync()</td> 
 <td>RGeoReactive. hash()</td> 
 <td>RGeoRx. hash()</td> 
 </tr> 
 <tr> 
 <td>GEOPOS</td> 
 <td>RGeo. pos() posAsync()</td> 
 <td>RGeoReactive. pos()</td> 
 <td>RGeoRx. pos()</td> 
 </tr> 
 <tr> 
 <td>GEORADIUS</td> 
 <td>RGeo. radius() radiusAsync() radiusWithDistance() radiusWithDistanceAsync() radiusWithPosition() radiusWithPositionAsync()</td> 
 <td>RGeoReactive. radius() radiusWithDistance() radiusWithPosition()</td> 
 <td>RGeoRx. radius() radiusWithDistance() radiusWithPosition()</td> 
 </tr> 
 <tr> 
 <td>GET</td> 
 <td>RBucket. get() getAsync() RBinaryStream. get() getAsync()</td> 
 <td>RBucketReactive. get() RBinaryStreamReactive. get()</td> 
 <td>RBucketRx. get() RBinaryStreamRx. get()</td> 
 </tr> 
 <tr> 
 <td>GETBIT</td> 
 <td>RBitSet. get() getAsync()</td> 
 <td>RBitSetReactive. get()</td> 
 <td>RBitSetRx. get()</td> 
 </tr> 
 <tr> 
 <td>GETSET</td> 
 <td>RBucket. getAndSet() getAndSetAsync() RAtomicLong. getAndSet() getAndSetAsync() RAtomicDouble. getAndSet() getAndSetAsync()</td> 
 <td>RBucketReactive. getAndSet() RAtomicLongReactive. getAndSet() RAtomicDoubleReactive. getAndSet()</td> 
 <td>RBucketRx. getAndSet() RAtomicLongRx. getAndSet() RAtomicDoubleRx. getAndSet()</td> 
 </tr> 
 <tr> 
 <td>HDEL</td> 
 <td>RMap. fastRemove() fastRemoveAsync()</td> 
 <td>RMapReactive. fastRemove()</td> 
 <td>RMapRx. fastRemove()</td> 
 </tr> 
 <tr> 
 <td>HEXISTS</td> 
 <td>RMap. containsKey() containsKeyAsync()</td> 
 <td>RMapReactive. containsKey()</td> 
 <td>RMapRx. containsKey()</td> 
 </tr> 
 <tr> 
 <td>HGET</td> 
 <td>RMap. get() getAsync()</td> 
 <td>RMapReactive. get()</td> 
 <td>RMapRx. get()</td> 
 </tr> 
 <tr> 
 <td>HSTRLEN</td> 
 <td>RMap. valueSize() valueSizeAsync()</td> 
 <td>RMapReactive. valueSize()</td> 
 <td>RMapRx. valueSize()</td> 
 </tr> 
 <tr> 
 <td>HGETALL</td> 
 <td>RMap. readAllEntrySet() readAllEntrySetAsync()</td> 
 <td>RMapReactive. readAllEntrySet()</td> 
 <td>RMapRx. readAllEntrySet()</td> 
 </tr> 
 <tr> 
 <td>HINCRBY</td> 
 <td>RMap. addAndGet() addAndGetAsync()</td> 
 <td>RMapReactive. addAndGet()</td> 
 <td>RMapRx. addAndGet()</td> 
 </tr> 
 <tr> 
 <td>HINCRBYFLOAT</td> 
 <td>RMap. addAndGet() addAndGetAsync()</td> 
 <td>RMapReactive. addAndGet()</td> 
 <td>RMapRx. addAndGet()</td> 
 </tr> 
 <tr> 
 <td>HKEYS</td> 
 <td>RMap. readAllKeySet() readAllKeySetAsync()</td> 
 <td>RMapReactive. readAllKeySet()</td> 
 <td>RMapRx. readAllKeySet()</td> 
 </tr> 
 <tr> 
 <td>HLEN</td> 
 <td>RMap. size() sizeAsync()</td> 
 <td>RMapReactive. size()</td> 
 <td>RMapRx. size()</td> 
 </tr> 
 <tr> 
 <td>HMGET</td> 
 <td>RMap. getAll() getAllAsync()</td> 
 <td>RMapReactive. getAll()</td> 
 <td>RMapRx. getAll()</td> 
 </tr> 
 <tr> 
 <td>HMSET</td> 
 <td>RMap. putAll() putAllAsync()</td> 
 <td>RMapReactive. putAll()</td> 
 <td>RMapRx. putAll()</td> 
 </tr> 
 <tr> 
 <td>HSCAN</td> 
 <td>RMap. keySet().iterator() values().iterator() entrySet().iterator()</td> 
 <td>RMapReactive. keyIterator() valueIterator() entryIterator()</td> 
 <td>RMapRx. keyIterator() valueIterator() entryIterator()</td> 
 </tr> 
 <tr> 
 <td>HSET</td> 
 <td>RMap. fastPut() fastPutAsync()</td> 
 <td>RMapReactive. fastPut()</td> 
 <td>RMapRx. fastPut()</td> 
 </tr> 
 <tr> 
 <td>HSETNX</td> 
 <td>RMap. fastPutIfAbsent() fastPutIfAbsentAsync()</td> 
 <td>RMapReactive. fastPutIfAbsent()</td> 
 <td>RMapRx. fastPutIfAbsent()</td> 
 </tr> 
 <tr> 
 <td>HVALS</td> 
 <td>RMap. readAllValues() readAllValuesAsync()</td> 
 <td>RMapReactive. readAllValues()</td> 
 <td>RMapRx. readAllValues()</td> 
 </tr> 
 <tr> 
 <td>INCR</td> 
 <td>RAtomicLong. incrementAndGet() incrementAndGetAsync()</td> 
 <td>RAtomicLongReactive. incrementAndGet()</td> 
 <td>RAtomicLongRx. incrementAndGet()</td> 
 </tr> 
 <tr> 
 <td>INCRBY</td> 
 <td>RAtomicLong. addAndGet() addAndGetAsync()</td> 
 <td>RAtomicLongReactive. addAndGet()</td> 
 <td>RAtomicLongRx. addAndGet()</td> 
 </tr> 
 <tr> 
 <td>INCRBYFLOAT</td> 
 <td>RAtomicDouble. addAndGet() addAndGetAsync()</td> 
 <td>RAtomicDoubleReactive. addAndGet()</td> 
 <td>RAtomicDoubleRx. addAndGet()</td> 
 </tr> 
 <tr> 
 <td>KEYS</td> 
 <td>RKeys. getKeysByPattern() getKeysByPatternAsync()</td> 
 <td>RKeysReactive. getKeysByPattern()</td> 
 <td>RKeysRx. getKeysByPattern()</td> 
 </tr> 
 <tr> 
 <td>LINDEX</td> 
 <td>RList. get() getAsync()</td> 
 <td>RListReactive. get()</td> 
 <td>RListRx. get()</td> 
 </tr> 
 <tr> 
 <td>LLEN</td> 
 <td>RList. size() sizeAsync()</td> 
 <td>RListReactive. size()</td> 
 <td>RListRx. size()</td> 
 </tr> 
 <tr> 
 <td>LPOP</td> 
 <td>RQueue. poll() pollAsync()</td> 
 <td>RQueueReactive. poll()</td> 
 <td>RQueueRx. poll()</td> 
 </tr> 
 <tr> 
 <td>LPUSH</td> 
 <td>RDeque. addFirst() addFirstAsync()</td> 
 <td>RDequeReactive. addFirst()</td> 
 <td></td> 
 </tr> 
 <tr> 
 <td>LRANGE</td> 
 <td>RList. readAll() readAllAsync()</td> 
 <td>RListReactive.readAll()</td> 
 <td>RListRx.readAll()</td> 
 </tr> 
 <tr> 
 <td>LPUSHX</td> 
 <td>RDeque. addFirstIfExists() addFirstIfExistsAsync()</td> 
 <td>RDequeReactive. addFirstIfExists()</td> 
 <td>RDequeRx. addFirstIfExists()</td> 
 </tr> 
 <tr> 
 <td>LREM</td> 
 <td>RList. fastRemove() fastRemoveAsync()</td> 
 <td>RListReactive. fastRemove()</td> 
 <td>RListRx. fastRemove()</td> 
 </tr> 
 <tr> 
 <td>LSET</td> 
 <td>RList. fastSet() fastSetAsync()</td> 
 <td>RListReactive. fastSet()</td> 
 <td>RListRx. fastSet()</td> 
 </tr> 
 <tr> 
 <td>LTRIM</td> 
 <td>RList. trim() trimAsync()</td> 
 <td>RListReactive. trim()</td> 
 <td>RListRx. trim()</td> 
 </tr> 
 <tr> 
 <td>LINSERT</td> 
 <td>RList. addBefore() addAfter() addBeforeAsync() addAfterAsync()</td> 
 <td>RListReactive. addBefore() addAfter()</td> 
 <td>RListRx. addBefore() addAfter()</td> 
 </tr> 
 <tr> 
 <td>MULTI</td> 
 <td>RBatch. execute() executeAsync()</td> 
 <td>RBatchReactive. execute()</td> 
 <td>RBatchRx. execute()</td> 
 </tr> 
 <tr> 
 <td>MGET</td> 
 <td>RBuckets. get() getAsync()</td> 
 <td>RBucketsReactive. get()</td> 
 <td>RBucketsRx. get()</td> 
 </tr> 
 <tr> 
 <td>MSETNX</td> 
 <td>RBuckets. trySet() trySetAsync()</td> 
 <td>RBucketsReactive. trySet()</td> 
 <td>RBucketsRx. trySet()</td> 
 </tr> 
 <tr> 
 <td>MIGRATE</td> 
 <td>RObject. migrate() migrateAsync()</td> 
 <td>RObjectReactive. migrate()</td> 
 <td>RObjectRx. migrate()</td> 
 </tr> 
 <tr> 
 <td>MOVE</td> 
 <td>RObject. move() moveAsync()</td> 
 <td>RObjectReactive. move()</td> 
 <td>RObjectRx. move()</td> 
 </tr> 
 <tr> 
 <td>MSET</td> 
 <td>RBuckets. set() setAsync()</td> 
 <td>RBucketsReactive. set()</td> 
 <td>RBucketsRx. set()</td> 
 </tr> 
 <tr> 
 <td>PERSIST</td> 
 <td>RExpirable. clearExpire() clearExpireAsync()</td> 
 <td>RExpirableReactive. clearExpire()</td> 
 <td>RExpirableRx. clearExpire()</td> 
 </tr> 
 <tr> 
 <td>PEXPIRE</td> 
 <td>RExpirable. expire() expireAsync()</td> 
 <td>RExpirableReactive. expire()</td> 
 <td>RExpirableRx. expire()</td> 
 </tr> 
 <tr> 
 <td>PEXPIREAT</td> 
 <td>RExpirable. expireAt() expireAtAsync()</td> 
 <td>RExpirableReactive. expireAt()</td> 
 <td>RExpirableRx. expireAt()</td> 
 </tr> 
 <tr> 
 <td>PFADD</td> 
 <td>RHyperLogLog. add() addAsync() addAll() addAllAsync()</td> 
 <td>RHyperLogLogReactive. add() addAll()</td> 
 <td>RHyperLogLogRx. add() addAll()</td> 
 </tr> 
 <tr> 
 <td>PFCOUNT</td> 
 <td>RHyperLogLog. count() countAsync() countWith() countWithAsync()</td> 
 <td>RHyperLogLogReactive. count() countWith()</td> 
 <td>RHyperLogLogRx. count() countWith()</td> 
 </tr> 
 <tr> 
 <td>PFMERGE</td> 
 <td>RHyperLogLog. mergeWith() mergeWithAsync()</td> 
 <td>RHyperLogLogReactive. mergeWith()</td> 
 <td>RHyperLogLogRx. mergeWith()</td> 
 </tr> 
 <tr> 
 <td>PING</td> 
 <td>Node.ping() NodesGroup.pingAll()</td> 
 <td>-</td> 
 <td>-</td> 
 </tr> 
 <tr> 
 <td>PSUBSCRIBE</td> 
 <td>RPatternTopic. addListener()</td> 
 <td>RPatternTopicReactive. addListener()</td> 
 <td>RPatternTopicRx. addListener()</td> 
 </tr> 
 <tr> 
 <td>PSETEX</td> 
 <td>RBucket. set() setAsync()</td> 
 <td>RBucketReactive. set()</td> 
 <td>RBucketRx. set()</td> 
 </tr> 
 <tr> 
 <td>PTTL</td> 
 <td>RExpirable. remainTimeToLive() remainTimeToLiveAsync()</td> 
 <td>RExpirableReactive. remainTimeToLive()</td> 
 <td>RExpirableRx. remainTimeToLive()</td> 
 </tr> 
 <tr> 
 <td>PUBLISH</td> 
 <td>RTopic. publish()</td> 
 <td>RTopicReactive. publish()</td> 
 <td>RTopicRx. publish()</td> 
 </tr> 
 <tr> 
 <td>PUBSUB NUMSUB</td> 
 <td>RTopic. countSubscribers() countSubscribersAsync()</td> 
 <td>RTopicReactive. countSubscribers()</td> 
 <td>RTopicRx. countSubscribers()</td> 
 </tr> 
 <tr> 
 <td>PUNSUBSCRIBE</td> 
 <td>RPatternTopic. removeListener()</td> 
 <td>RPatternTopicReactive. removeListener()</td> 
 <td>RPatternTopicRx. removeListener()</td> 
 </tr> 
 <tr> 
 <td>RANDOMKEY</td> 
 <td>RKeys. randomKey() randomKeyAsync()</td> 
 <td>RKeysReactive. randomKey()</td> 
 <td>RKeysRx. randomKey()</td> 
 </tr> 
 <tr> 
 <td>RESTORE</td> 
 <td>RObject. restore() restoreAsync()</td> 
 <td>RObjectReactive. restore()</td> 
 <td>RObjectRx. restore()</td> 
 </tr> 
 <tr> 
 <td>RENAME</td> 
 <td>RObject. rename() renameAsync()</td> 
 <td>RObjectReactive. rename()</td> 
 <td>RObjectRx. rename()</td> 
 </tr> 
 <tr> 
 <td>RPOP</td> 
 <td>RDeque. pollLast() removeLast() pollLastAsync() removeLastAsync()</td> 
 <td>RDequeReactive. pollLast() removeLast()</td> 
 <td>RDequeRx. pollLast() removeLast()</td> 
 </tr> 
 <tr> 
 <td>RPOPLPUSH</td> 
 <td>RDeque. pollLastAndOfferFirstTo() pollLastAndOfferFirstToAsync()</td> 
 <td>RDequeReactive. pollLastAndOfferFirstTo()</td> 
 <td>RDequeRx. pollLastAndOfferFirstTo()</td> 
 </tr> 
 <tr> 
 <td>RPUSH</td> 
 <td>RList. add() addAsync()</td> 
 <td>RListReactive. add()</td> 
 <td>RListRx. add()</td> 
 </tr> 
 <tr> 
 <td>RPUSHX</td> 
 <td>RDeque. addLastIfExists() addLastIfExistsAsync()</td> 
 <td>RListReactive. addLastIfExists()</td> 
 <td>RListRx. addLastIfExists()</td> 
 </tr> 
 <tr> 
 <td>SADD</td> 
 <td>RSet. add() addAsync()</td> 
 <td>RSetReactive. add()</td> 
 <td>RSetRx. add()</td> 
 </tr> 
 <tr> 
 <td>SETRANGE</td> 
 <td>RBinaryStream. getChannel().write()</td> 
 <td>RBinaryStreamReactive. write()</td> 
 <td>RBinaryStreamRx. write()</td> 
 </tr> 
 <tr> 
 <td>SCAN</td> 
 <td>RKeys. getKeys()</td> 
 <td>RKeysReactive. getKeys()</td> 
 <td>RKeysRx. getKeys()</td> 
 </tr> 
 <tr> 
 <td>SCARD</td> 
 <td>RSet. size() sizeAsync()</td> 
 <td>RSetReactive. size()</td> 
 <td>RSetRx. size()</td> 
 </tr> 
 <tr> 
 <td>SCRIPT EXISTS</td> 
 <td>RScript. scriptExists() scriptExistsAsync()</td> 
 <td>RScriptReactive. scriptExists()</td> 
 <td>RScriptRx. scriptExists()</td> 
 </tr> 
 <tr> 
 <td>SCRIPT FLUSH</td> 
 <td>RScript. scriptFlush() scriptFlushAsync()</td> 
 <td>RScriptReactive. scriptFlush()</td> 
 <td>RScriptRx. scriptFlush()</td> 
 </tr> 
 <tr> 
 <td>SCRIPT KILL</td> 
 <td>RScript. scriptKill() scriptKillAsync()</td> 
 <td>RScriptReactive. scriptKill()</td> 
 <td>RScriptRx. scriptKill()</td> 
 </tr> 
 <tr> 
 <td>SCRIPT LOAD</td> 
 <td>RScript. scriptLoad() scriptLoadAsync()</td> 
 <td>RScriptReactive. scriptLoad()</td> 
 <td>RScriptRx. scriptLoad()</td> 
 </tr> 
 <tr> 
 <td>SDIFFSTORE</td> 
 <td>RSet. diff() diffAsync()</td> 
 <td>RSetReactive. diff()</td> 
 <td>RSetRx. diff()</td> 
 </tr> 
 <tr> 
 <td>SDIFF</td> 
 <td>RSet. readDiff() readDiffAsync()</td> 
 <td>RSetReactive. readDiff()</td> 
 <td>RSetRx. readDiff()</td> 
 </tr> 
 <tr> 
 <td>SRANDMEMBER</td> 
 <td>RSet. random() randomAsync()</td> 
 <td>RSetReactive. random()</td> 
 <td>RSetRx. random()</td> 
 </tr> 
 <tr> 
 <td>SELECT</td> 
 <td>Config.setDatabase()</td> 
 <td>-</td> 
 <td>-</td> 
 </tr> 
 <tr> 
 <td>SET</td> 
 <td>RBucket. set() setAsync()</td> 
 <td>RBucketReactive. set()</td> 
 <td>RBucketRx. set()</td> 
 </tr> 
 <tr> 
 <td>SETBIT</td> 
 <td>RBitSet. set() clear() setAsync() clearAsync()</td> 
 <td>RBitSetReactive. set() clear()</td> 
 <td>RBitSetRx. set() clear()</td> 
 </tr> 
 <tr> 
 <td>SETEX</td> 
 <td>RBucket. set() setAsync()</td> 
 <td>RBucketReactive. set()</td> 
 <td>RBucketRx. set()</td> 
 </tr> 
 <tr> 
 <td>SETNX</td> 
 <td>RBucket. trySet() trySetAsync()</td> 
 <td>RBucketReactive. trySet()</td> 
 <td>RBucketRx. trySet()</td> 
 </tr> 
 <tr> 
 <td>SISMEMBER</td> 
 <td>RSet. contains() containsAsync()</td> 
 <td>RSetReactive. contains()</td> 
 <td>RSetRx. contains()</td> 
 </tr> 
 <tr> 
 <td>SINTERSTORE</td> 
 <td>RSet. intersection() intersectionAsync()</td> 
 <td>RSetReactive. intersection()</td> 
 <td>RSetRx. intersection()</td> 
 </tr> 
 <tr> 
 <td>SINTER</td> 
 <td>RSet. readIntersection() readIntersectionAsync()</td> 
 <td>RSetReactive. readIntersection()</td> 
 <td>RSetRx. readIntersection()</td> 
 </tr> 
 <tr> 
 <td>SMEMBERS</td> 
 <td>RSet. readAll() readAllAsync()</td> 
 <td>RSetReactive. readAll()</td> 
 <td>RSetRx. readAll()</td> 
 </tr> 
 <tr> 
 <td>SMOVE</td> 
 <td>RSet. move() moveAsync()</td> 
 <td>RSetReactive. move()</td> 
 <td>RSetRx. move()</td> 
 </tr> 
 <tr> 
 <td>SORT</td> 
 <td>RList. readSort() sortTo() readSortAsync() sortToAsync()</td> 
 <td>RListReactive. readSort() sortTo()</td> 
 <td>RListRx. readSort() sortTo()</td> 
 </tr> 
 <tr> 
 <td>SPOP</td> 
 <td>RSet. removeRandom() removeRandomAsync()</td> 
 <td>RSetReactive. removeRandom()</td> 
 <td>RSetRx. removeRandom()</td> 
 </tr> 
 <tr> 
 <td>SREM</td> 
 <td>RSet. remove() removeAsync()</td> 
 <td>RSetReactive. remove()</td> 
 <td>RSetRx. remove()</td> 
 </tr> 
 <tr> 
 <td>SSCAN</td> 
 <td>RSet. iterator()</td> 
 <td>RSetReactive. iterator()</td> 
 <td>RSetRx. iterator()</td> 
 </tr> 
 <tr> 
 <td>SUBSCRIBE</td> 
 <td>RTopic. addListener()</td> 
 <td>RTopicReactive. addListener()</td> 
 <td>RTopicRx. addListener()</td> 
 </tr> 
 <tr> 
 <td>SUNION</td> 
 <td>RSet. readUnion() readUnionAsync()</td> 
 <td>RSetReactive. readUnion()</td> 
 <td>RSetRx. readUnion()</td> 
 </tr> 
 <tr> 
 <td>SUNIONSTORE</td> 
 <td>RSet. union() unionAsync()</td> 
 <td>RSetReactive. union()</td> 
 <td>RSetRx. union()</td> 
 </tr> 
 <tr> 
 <td>SWAPDB</td> 
 <td>RKeys. swapdb() swapdbAsync()</td> 
 <td>RKeysReactive. swapdb()</td> 
 <td>RKeysRx. swapdb()</td> 
 </tr> 
 <tr> 
 <td>TTL</td> 
 <td>RExpirable. remainTimeToLive() remainTimeToLiveAsync()</td> 
 <td>RExpirableReactive. remainTimeToLive()</td> 
 <td>RExpirableRx. remainTimeToLive()</td> 
 </tr> 
 <tr> 
 <td>TYPE</td> 
 <td>RKeys. getType() getTypeAsync()</td> 
 <td>RKeysReactive. getType()</td> 
 <td>RKeysRx. getType()</td> 
 </tr> 
 <tr> 
 <td>TOUCH</td> 
 <td>RObject. touch() touchAsync()</td> 
 <td>RObjectReactive. touch()</td> 
 <td>RObjectRx. touch()</td> 
 </tr> 
 <tr> 
 <td>UNSUBSCRIBE</td> 
 <td>RTopic. removeListener()</td> 
 <td>RTopicReactive. removeListener()</td> 
 <td>RTopicRx. removeListener()</td> 
 </tr> 
 <tr> 
 <td>UNLINK</td> 
 <td>RObject. unlink() unlinkAsync()</td> 
 <td>RObjectReactive. unlink()</td> 
 <td>RObjectRx. unlink()</td> 
 </tr> 
 <tr> 
 <td>WAIT</td> 
 <td>BatchOptions. syncSlaves()</td> 
 <td>BatchOptions. syncSlaves()</td> 
 <td>BatchOptions. syncSlaves()</td> 
 </tr> 
 <tr> 
 <td>ZADD</td> 
 <td>RScoredSortedSet. add() addAsync()</td> 
 <td>RScoredSortedSetReactive. add()</td> 
 <td>RScoredSortedSetRx. add()</td> 
 </tr> 
 <tr> 
 <td>ZCARD</td> 
 <td>RScoredSortedSet. size() sizeAsync()</td> 
 <td>RScoredSortedSetReactive. size()</td> 
 <td>RScoredSortedSetRx. size()</td> 
 </tr> 
 <tr> 
 <td>ZCOUNT</td> 
 <td>RScoredSortedSet. count() countAsync()</td> 
 <td>RScoredSortedSetReactive. count()</td> 
 <td>RScoredSortedSetRx. count()</td> 
 </tr> 
 <tr> 
 <td>ZINCRBY</td> 
 <td>RScoredSortedSet. addScore() addScoreAsync()</td> 
 <td>RScoredSortedSetReactive. addScore()</td> 
 <td>RScoredSortedSetRx. addScore()</td> 
 </tr> 
 <tr> 
 <td>ZREMRANGEBYRANK</td> 
 <td>RScoredSortedSet. removeRangeByRank() removeRangeByRankAsync()</td> 
 <td>RScoredSortedSetReactive. removeRangeByRank()</td> 
 <td>RScoredSortedSetRx. removeRangeByRank()</td> 
 </tr> 
 <tr> 
 <td>ZREVRANGEBYLEX</td> 
 <td>RLexSortedSet. rangeReversed() rangeReversedAsync()</td> 
 <td>RLexSortedSetReactive. rangeReversed()</td> 
 <td>RLexSortedSetSetRx. rangeReversed()</td> 
 </tr> 
 <tr> 
 <td>ZLEXCOUNT</td> 
 <td>RLexSortedSet. lexCount() lexCountHead() lexCountTail() lexCountAsync() lexCountHeadAsync() lexCountTailAsync()</td> 
 <td>RLexSortedSetReactive. lexCount() lexCountHead() lexCountTail()</td> 
 <td>RLexSortedSetRx. lexCount() lexCountHead() lexCountTail()</td> 
 </tr> 
 <tr> 
 <td>ZRANGE</td> 
 <td>RScoredSortedSet. valueRange() valueRangeAsync()</td> 
 <td>RScoredSortedSetReactive. valueRange()</td> 
 <td>RScoredSortedSetRx. valueRange()</td> 
 </tr> 
 <tr> 
 <td>ZREVRANGE</td> 
 <td>RScoredSortedSet. valueRangeReversed() valueRangeReversedAsync()</td> 
 <td>RScoredSortedSetReactive. valueRangeReversed()</td> 
 <td>RScoredSortedSetRx. valueRangeReversed()</td> 
 </tr> 
 <tr> 
 <td>ZUNIONSTORE</td> 
 <td>RScoredSortedSet. union() unionAsync()</td> 
 <td>RScoredSortedSetReactive. union()</td> 
 <td>RScoredSortedSetRx. union()</td> 
 </tr> 
 <tr> 
 <td>ZINTERSTORE</td> 
 <td>RScoredSortedSet. intersection() intersectionAsync()</td> 
 <td>RScoredSortedSetReactive. intersection()</td> 
 <td>RScoredSortedSetRx. intersection()</td> 
 </tr> 
 <tr> 
 <td>ZRANGEBYLEX</td> 
 <td>RLexSortedSet. range() rangeHead() rangeTail() rangeAsync() rangeHeadAsync() rangeTailAsync()</td> 
 <td>RLexSortedSetReactive. range() rangeHead() rangeTail()</td> 
 <td>RLexSortedSetRx. range() rangeHead() rangeTail()</td> 
 </tr> 
 <tr> 
 <td>ZRANGEBYSCORE</td> 
 <td>RScoredSortedSet. valueRange() entryRange() valueRangeAsync() entryRangeAsync()</td> 
 <td>RScoredSortedSetReactive. valueRange() entryRange()</td> 
 <td>RScoredSortedSetRx. valueRange() entryRange()</td> 
 </tr> 
 <tr> 
 <td>TIME</td> 
 <td>RedissonClient. getNodesGroup(). getNode().time() getClusterNodesGroup(). getNode().time()</td> 
 <td>-</td> 
 <td>-</td> 
 </tr> 
 <tr> 
 <td>ZRANK</td> 
 <td>RScoredSortedSet. rank() rankAsync()</td> 
 <td>RScoredSortedSetReactive. rank()</td> 
 <td>RScoredSortedSetRx. rank()</td> 
 </tr> 
 <tr> 
 <td>ZREM</td> 
 <td>RScoredSortedSet. remove() removeAll() removeAsync() removeAllAsync()</td> 
 <td>RScoredSortedSetReactive. remove() removeAll()</td> 
 <td>RScoredSortedSetRx. remove() removeAll()</td> 
 </tr> 
 <tr> 
 <td>ZREMRANGEBYLEX</td> 
 <td>RLexSortedSet. removeRange() removeRangeHead() removeRangeTail() removeRangeAsync() removeRangeHeadAsync() removeRangeTailAsync()</td> 
 <td>RLexSortedSetReactive. removeRange() removeRangeHead() removeRangeTail()</td> 
 <td>RLexSortedSetRx. removeRange() removeRangeHead() removeRangeTail()</td> 
 </tr> 
 <tr> 
 <td>ZREMRANGEBYSCORE</td> 
 <td>RScoredSortedSet. removeRangeByScore() removeRangeByScoreAsync()</td> 
 <td>RScoredSortedSetReactive. removeRangeByScore()</td> 
 <td>RScoredSortedSetRx. removeRangeByScore()</td> 
 </tr> 
 <tr> 
 <td>ZREVRANGEBYSCORE</td> 
 <td>RScoredSortedSet. valueRangeReversed() entryRangeReversed() valueRangeReversedAsync() entryRangeReversedAsync()</td> 
 <td>RScoredSortedSetReactive. entryRangeReversed() valueRangeReversed()</td> 
 <td>RScoredSortedSetRx. entryRangeReversed() valueRangeReversed()</td> 
 </tr> 
 <tr> 
 <td>ZREVRANK</td> 
 <td>RScoredSortedSet. revRank() revRankAsync()</td> 
 <td>RScoredSortedSetReactive. revRank()</td> 
 <td>RScoredSortedSetRx. revRank()</td> 
 </tr> 
 <tr> 
 <td>ZSCORE</td> 
 <td>RScoredSortedSet. getScore() getScoreAsync()</td> 
 <td>RScoredSortedSetReactive. getScore()</td> 
 <td>RScoredSortedSetRx. getScore()</td> 
 </tr> 
 <tr> 
 <td>ZPOPMAX</td> 
 <td>RScoredSortedSet. pollLast() pollLastAsync()</td> 
 <td>RScoredSortedSetReactive. pollLast()</td> 
 <td>RScoredSortedSetRx. pollLast()</td> 
 </tr> 
 <tr> 
 <td>ZPOPMIN</td> 
 <td>RScoredSortedSet. pollFirst() pollFirstAsync()</td> 
 <td>RScoredSortedSetReactive. pollFirst()</td> 
 <td>RScoredSortedSetRx. pollFirst()</td> 
 </tr> 
 <tr> 
 <td>XACK</td> 
 <td>RStream. ack() ackAsync()</td> 
 <td>RStreamReactive. ack()</td> 
 <td>RStreamRx. ack()</td> 
 </tr> 
 <tr> 
 <td>XADD</td> 
 <td>RStream. add() addAsync()</td> 
 <td>RStreamReactive. add()</td> 
 <td>RStreamRx. add()</td> 
 </tr> 
 <tr> 
 <td>XCLAIM</td> 
 <td>RStream. claim() claimAsync()</td> 
 <td>RStreamReactive. claim()</td> 
 <td>RStreamRx. claim()</td> 
 </tr> 
 <tr> 
 <td>XDEL</td> 
 <td>RStream. remove() removeAsync()</td> 
 <td>RStreamReactive. remove()</td> 
 <td>RStreamRx. remove()</td> 
 </tr> 
 <tr> 
 <td>XGROUP</td> 
 <td>RStream. createGroup() removeGroup() updateGroup() createGroupAsync() removeGroupAsync() updateGroupAsync()</td> 
 <td>RStreamReactive. createGroup() removeGroup() updateGroup()</td> 
 <td>RStreamRx. createGroup() removeGroup() updateGroup()</td> 
 </tr> 
 <tr> 
 <td>XINFO</td> 
 <td>RStream. getInfo() listGroups() listConsumers() getInfoAsync() listGroupsAsync() listConsumersAsync()</td> 
 <td>RStreamReactive. getInfo() listGroups() listConsumers()</td> 
 <td>RStreamRx. getInfo() listGroups() listConsumers()</td> 
 </tr> 
 <tr> 
 <td>XLEN</td> 
 <td>RStream. size() sizeAsync()</td> 
 <td>RStreamReactive. size()</td> 
 <td>RStreamRx. size()</td> 
 </tr> 
 <tr> 
 <td>XPENDING</td> 
 <td>RStream. listPending() listPendingAsync()</td> 
 <td>RStreamReactive. listPending()</td> 
 <td>RStreamRx. listPending()</td> 
 </tr> 
 <tr> 
 <td>XRANGE</td> 
 <td>RStream. range() rangeAsync()</td> 
 <td>RStreamReactive. range()</td> 
 <td>RStreamRx. range()</td> 
 </tr> 
 <tr> 
 <td>XREAD</td> 
 <td>RStream. read() readAsync()</td> 
 <td>RStreamReactive. read()</td> 
 <td>RStreamRx. read()</td> 
 </tr> 
 <tr> 
 <td>XREADGROUP</td> 
 <td>RStream. readGroup() readGroupAsync()</td> 
 <td>RStreamReactive. readGroup()</td> 
 <td>RStreamRx. readGroup()</td> 
 </tr> 
 <tr> 
 <td>XREVRANGE</td> 
 <td>RStream. rangeReversed() rangeReversedAsync()</td> 
 <td>RStreamReactive. rangeReversed()</td> 
 <td>RStreamRx. rangeReversed()</td> 
 </tr> 
 <tr> 
 <td>XTRIM</td> 
 <td>RStream. trim() trimAsync()</td> 
 <td>RStreamReactive. trim()</td> 
 <td>RStreamRx. trim()</td> 
 </tr> 
 </tbody> 
</table>

# 其他网址 #

[Redisson最新版starter模式集成\_明洋的专栏-CSDN博客\_redisson-spring-boot-starter][Redisson_starter_-CSDN_redisson-spring-boot-starter]  
[最简单的spring-boot-starter-redisson发布啦！ | 纳兰小筑][spring-boot-starter-redisson_ _]

[Redisson--_IT_-CSDN]: https://knife.blog.csdn.net/article/details/120677466
[Redisson_--_IT_-CSDN]: https://knife.blog.csdn.net/article/details/120475560
[https_github.com_redisson_redisson_wiki]: https://github.com/redisson/redisson/wiki
[https_github.com_redisson_redisson]: https://github.com/redisson/redisson
[https_redisson.org]: https://redisson.org/
[2. _ _ redisson_redisson Wiki _ GitHub]: https://github.com/redisson/redisson/wiki/2.-%E9%85%8D%E7%BD%AE%E6%96%B9%E6%B3%95
[2-_1_SpringBoot_redisson_ -]: https://www.jianshu.com/p/2fa105e671ac
[Redis_ Springboot _Redisson _ _-CSDN]: https://blog.csdn.net/qq_35387940/article/details/106100438
[SpringBoot_redisson_ - _ -]: https://www.cnblogs.com/yangzhilong/p/7605807.html
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaXlpbmcwY2FuZ2xhbmc_size_16_color_FFFFFF_t_70]: /images/20220828/007531140bce430cb9b74f235c754353.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaXlpbmcwY2FuZ2xhbmc_size_16_color_FFFFFF_t_70 1]: /images/20220828/f1dd7d4e162f45b0b1e160ca9a2982c0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaXlpbmcwY2FuZ2xhbmc_size_16_color_FFFFFF_t_70 2]: /images/20220828/9416be5cf9cf4bf79c1d62b971a8cad9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2ZlaXlpbmcwY2FuZ2xhbmc_size_16_color_FFFFFF_t_70 3]: /images/20220828/ca3cbfec71b840fbad421ec3d81d9b42.png
[Redisson_starter_-CSDN_redisson-spring-boot-starter]: https://blog.csdn.net/yaomingyang/article/details/104965570
[spring-boot-starter-redisson_ _]: https://www.naah69.com/post/2019-07-28-spring-boot-starter-redisson/