在Spring Boot微服务集成JedisCluster操作Redis集群

骑猪看日落 2024-04-23 02:10 78阅读 0赞

**记录**：448

**场景**：在Spring Boot微服务使用JedisCluster操作Redis集群的缓存和队列等数据类型。

**版本**：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集群。也可以使用cn.hutool.extra.spring.SpringUtil工具等从Spring 中获取JedisCluster实例操作Redis集群。

**3.使用@Autowired注入**JedisCluster**的****方式操作Redis集群**

**3.1简要说明**

使用@Autowired注入JedisCluster，操作Redis集群的增、查、改、删等操作。

**3.2操作示例**

@RestController
    @RequestMapping("/hub/example/operateJedisCluster")
    @Slf4j
    public class OperateJedisClusterController {
      @Autowired
      private JedisCluster jedisCluster;
      /**
       * 使用@Autowired注入获取JedisCluster
       */
      @GetMapping("/f01_01")
      public Object f01_01() {
          log.info("JedisCluster操作Redis集群开始...");
          // 1.增
          jedisCluster.set("J:2023060801:01", "江苏-苏州");
          // 2.查
          String result01 = jedisCluster.get("J:2023060801:01");
          log.info("查询J:2023060801:01 = " + result01.toString());
          // 3.改
          jedisCluster.set("J:2023060801:01", "江苏-南京");
          result01 = jedisCluster.get("J:2023060801:01");
          log.info("修改后,J:2023060801:01 = " + result01.toString());
          // 4.删
          long time = 8000;
          log.info("{}秒后,删除J:2023060801:01.",time/1000);
          ThreadUtil.sleep(time);
          jedisCluster.del("J:2023060801:01");
          log.info("JedisCluster操作Redis集群结束...");
          return "执行成功";
      }
    }

**3.3测试验证**

使用Postman测试。

请求RUL：http://127.0.0.1:18205/hub-205-redis/hub/example/operateJedisCluster/f01\_01

**4.使用****SpringUtil****从Spring中获取**JedisCluster**的方式****操作Redis集群**

**4.1简要说明**

使用SpringUtil从Spring中获取JedisCluster的方式，操作Redis集群的增、查、改、删等操作。

jar包：hutool-all-5.8.12.jar。

类：cn.hutool.extra.spring.SpringUtil

**4.2操作示例**

@RestController
    @RequestMapping("/hub/example/operateJedisCluster")
    @Slf4j
    public class OperateJedisClusterController {
      @Autowired
      private JedisCluster jedisCluster;
      /**
       * 使用工具获取JedisCluster
       */
      @GetMapping("/f01_02")
      public Object f01_02() {
          log.info("JedisCluster操作Redis集群开始...");
          JedisCluster jedisCluster02 = SpringUtil.getBean("jedisCluster");
          // 1.增
          jedisCluster02.set("J:2023060801:02", "江苏-苏州");
          // 2.查
          String result01 = jedisCluster02.get("J:2023060801:02");
          log.info("查询J:2023060801:02 = " + result01.toString());
          // 3.改
          jedisCluster02.set("CityInfo:suzhou01:02", "江苏-南京");
          log.info("修改后,J:2023060801:02 = " + result01.toString());
          // 4.删
          long time = 8000;
          log.info("{}秒后,删除J:2023060801:02.",time/1000);
          ThreadUtil.sleep(time);
          jedisCluster02.del("J:2023060801:02");
          log.info("JedisCluster操作Redis集群结束...");
          return "执行成功";
      }
    }

**4.3测试验证**

使用Postman测试。

请求http://127.0.0.1:18205/hub-205-redis/hub/example/operateJedisCluster/f01\_02

**5.小结**

(1)使用Jedis框架操作Redis集群和Redis单机版两种场景

操作Redis集群使用JedisCluster类，全称：redis.clients.jedis.JedisCluster。

操作Redis单机版使用Jedis类，全称：redis.clients.jedis.Jedis。

(2)JedisCluster和Jedis

JedisCluster继承BinaryJedisCluster，实现JedisClusterCommands，MultiKeyJedisClusterCommands，JedisClusterScriptingCommands接口。

Jedis继承BinaryJedis类，实现JedisCommands，MultiKeyCommands，AdvancedJedisCommands，ScriptingCommands，BasicCommands，ClusterCommands，SentinelCommands，ModuleCommands接口。

以上，感谢。

2023年6月8日