在Spring Boot微服务使用JedisCluster操作Redis集群Zset(有序集合)

小鱼儿 2024-04-23 02:15 6阅读 0赞

**记录**：453

**场景**：在Spring Boot微服务使用JedisCluster操作Redis集群的Redis集群Zset(有序集合)数据类型。

**版本**：JDK 1.8,Spring Boot 2.6.3,redis-6.2.5,jedis-3.7.1。

**1.微服务中****配置Redis信息**

**1.1在pom.xml添加依赖**

pom.xml文件：

<dependency>
      <groupId>redis.clients</groupId>
      <artifactId>jedis</artifactId>
      <version>3.7.1</version>
    </dependency>

解析：在Spring Boot中默认集成jedis，使用无需加版本号，本例版本3.7.1是Spring Boot 2.6.3对应的版本。

**1.2在application.yml中配置Redis集群信息**

(1)application.yml配置内容

hub:
      example:
        redis:
          jedis-cluster:
            password: demo12345678
            connection-timeout: 60000
            so-timeout: 1000
            max-attempts: 100
            nodes:
              - 192.168.19.161:27001
              - 192.168.19.161:27002
              - 192.168.19.162:27001
              - 192.168.19.162:27002
              - 192.168.19.163:27001
              - 192.168.19.163:27002

(2)解析

在application.yml中配置内容是自定义的，对应自定义配置类JedisClusterProperties。

类全称：com.hub.example.config.JedisClusterProperties。

自定义配置类使用如下注解生效：

@ConfigurationProperties(prefix = "hub.example.redis.jedis-cluster")

**1.3加载简要逻辑**

Spring Boot微服务在启动时，自动注解机制会读取application.yml的配置信息注入到自定义配置类JedisClusterProperties对象的对应属性。因此，在Spring环境中就能取到Redis集群的配置信息。

Spring从JedisClusterProperties对象中取配置注入到JedisCluster客户端中。因此，JedisCluster客户端就能对Redis集群做增、删、改、查等操作。

**2.配置JedisCluster**

JedisCluster是jedis框架中封装的操作Redis的客户端。

类全称：redis.clients.jedis.JedisCluster

**2.1配置JedisClusterProperties**

JedisClusterProperties是自定义配置了，作用是加载application.yml中Redis集群的配置信息。

使用@ConfigurationProperties注解生效，使用注解的prefix指定配置application.yml中前缀。

@Component
    @ConfigurationProperties(prefix = "hub.example.redis.jedis-cluster")
    public class JedisClusterProperties {
      private List<String> nodes;
      private String password;
      private int connectionTimeout;
      private int soTimeout;
      private int maxAttempts;
      public List<String> getNodes() {
          return nodes;
      }
      public void setNodes(List<String> nodes) {
          this.nodes = nodes;
      }
      public String getPassword() {
          return password;
      }
      public void setPassword(String password) {
          this.password = password;
      }
      public int getConnectionTimeout() {
          return connectionTimeout;
      }
      public void setConnectionTimeout(int connectionTimeout) {
          this.connectionTimeout = connectionTimeout;
      }
      public int getSoTimeout() {
          return soTimeout;
      }
      public void setSoTimeout(int soTimeout) {
          this.soTimeout = soTimeout;
      }
      public int getMaxAttempts() {
          return maxAttempts;
      }
      public void setMaxAttempts(int maxAttempts) {
          this.maxAttempts = maxAttempts;
      }
    }

**2.2配置JedisCluster**

@Configuration
    public class JedisClusterConfig {
      @Autowired
      JedisClusterProperties jedisClusterProperties;
      @Bean("jedisCluster")
      public JedisCluster getJedisCluster(JedisPoolConfig jedisPoolConfigCluster) {
        List<String> nodesList = jedisClusterProperties.getNodes();
        Set<HostAndPort> nodesSet = new HashSet<>();
        for (String ipAndPort : nodesList) {
            String[] ipAndPortPair = ipAndPort.split(":");
            nodesSet.add(new HostAndPort(ipAndPortPair[0].trim(), Integer.parseInt(ipAndPortPair[1].trim())));
        }
      
        return new JedisCluster(nodesSet,
                jedisClusterProperties.getConnectionTimeout(),
                jedisClusterProperties.getSoTimeout(),
                jedisClusterProperties.getMaxAttempts(),
                jedisClusterProperties.getPassword(),
                jedisPoolConfigCluster
        );
      }
      @Bean("jedisPoolConfigCluster")
      public JedisPoolConfig jedisPoolConfigCluster() {
        JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
        jedisPoolConfig.setMaxTotal(30);
        jedisPoolConfig.setMaxIdle(30);
        jedisPoolConfig.setMinIdle(1);
        jedisPoolConfig.setNumTestsPerEvictionRun(-1);
        jedisPoolConfig.setTestOnBorrow(true);
        jedisPoolConfig.setTestOnReturn(false);
        jedisPoolConfig.setBlockWhenExhausted(false);
        return jedisPoolConfig;
      }
    }

**2.3解析**

配置JedisCluster后，在Spring环境中，使用@Autowired注解注入JedisCluster实例操作Redis集群。

**3.使用Jedis操作Redis集群Zset(有序集合)**

**3.1简要说明**

使用JedisCluster操作集群Zset(有序集合)，常用操作：增、查、改、删、设置超时等。

**3.2操作示例**

@RestController
    @RequestMapping("/hub/example/operateJedisCluster")
    @Slf4j
    public class OperateJedisClusterController {
      @Autowired
      private JedisCluster jedisCluster;
     /**
       * 使用JedisCluster操作Redis集群Zset(有序集合)类型数据
       */
      @GetMapping("/f06")
      public Object f06() {
          log.info("JedisCluster操作Redis集群开始...");
          // 1.增
          // 1.1写入一条数据
          jedisCluster.zadd("J:2023060806:01", 30, "苏州");
          jedisCluster.zadd("J:2023060806:02", 30, "苏州");
          // 1.1写入批量数据
          Map<String, Double> scoreMembers = new HashMap<>();
          scoreMembers.put("苏州-姑苏", 35D);
          scoreMembers.put("苏州-工业园区", 60D);
          scoreMembers.put("苏州-吴江", 99D);
          jedisCluster.zadd("J:2023060806:01", scoreMembers);
          // 2.查
          // 2.1查询指定索引范围内的值
          Set<String> result01 = jedisCluster.zrange("J:2023060806:01", 2, 3);
          // 2.2查询指定Score范围内的值
          Set<String> result02 = jedisCluster.zrangeByScore("J:2023060806:01", 1, 40);
          // 2.3取出最大值
          Tuple max = jedisCluster.zpopmax("J:2023060806:01");
          log.info("取出最大值value = {},score={}", max.getElement(), max.getScore());
          // 2.4取出最小值
          Tuple min = jedisCluster.zpopmin("J:2023060806:01");
          log.info("取出最小值value = {},score={}", min.getElement(), min.getScore());
          // 3.删
          long time = 8000;
          log.info("{}秒后,删除J:2023060806:02", time / 1000);
          ThreadUtil.sleep(time);
          jedisCluster.del("J:2023060806:02");
          // 4.设置超时
          jedisCluster.expire("J:2023060806:01", 600L);
          log.info("JedisCluster操作Redis集群结束...");
          return "执行成功";
      }
    }

**3.3测试验证**

使用Postman测试。

请求RUL：http://127.0.0.1:18205/hub-205-redis/hub/example/operateJedisCluster/f06

以上，感谢。

2023年6月8日