記錄：448

場景：在Spring Boot微服務(wù)使用JedisCluster操作Redis集群的緩存和隊(duì)列等數(shù)據(jù)類型。

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

1.微服務(wù)中配置Redis信息

1.1在pom.xml添加依賴

pom.xml文件：

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

解析：在Spring?Boot中默認(rèn)集成jedis，使用無需加版本號，本例版本3.7.1是Spring?Boot 2.6.3對應(yīng)的版本。

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

(1)application.yml配置內(nèi)容

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中配置內(nèi)容是自定義的，對應(yīng)自定義配置類JedisClusterProperties。

類全稱：com.hub.example.config.JedisClusterProperties。

自定義配置類使用如下注解生效：

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

1.3加載簡要邏輯

Spring Boot微服務(wù)在啟動時，自動注解機(jī)制會讀取application.yml的配置信息注入到自定義配置類JedisClusterProperties對象的對應(yīng)屬性。因此，在Spring環(huán)境中就能取到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環(huán)境中，可以使用@Autowired注解注入JedisCluster實(shí)例操作Redis集群。也可以使用cn.hutool.extra.spring.SpringUtil工具等從Spring 中獲取JedisCluster實(shí)例操作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集群結(jié)束...");
      return "執(zhí)行成功";
  }
}

3.3測試驗(yàn)證

使用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集群結(jié)束...");
      return "執(zhí)行成功";
  }
}

4.3測試驗(yàn)證

使用Postman測試。

請求http://127.0.0.1:18205/hub-205-redis/hub/example/operateJedisCluster/f01_02

5.小結(jié)

(1)使用Jedis框架操作Redis集群和Redis單機(jī)版兩種場景

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

操作Redis單機(jī)版使用Jedis類，全稱：redis.clients.jedis.Jedis。

(2)JedisCluster和Jedis

JedisCluster繼承BinaryJedisCluster，實(shí)現(xiàn)JedisClusterCommands，MultiKeyJedisClusterCommands，JedisClusterScriptingCommands接口。

Jedis繼承BinaryJedis類，實(shí)現(xiàn)JedisCommands，MultiKeyCommands，AdvancedJedisCommands，ScriptingCommands，BasicCommands，ClusterCommands，SentinelCommands，ModuleCommands接口。

以上，感謝。

2023年6月8日文章來源地址http://www.zghlxwxcb.cn/news/detail-487019.html

到了這里，關(guān)于在Spring Boot微服務(wù)集成JedisCluster操作Redis集群的文章就介紹完了。如果您還想了解更多內(nèi)容，請?jiān)谟疑辖撬阉鱐OY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！