二、Redis 的整合与使用：Redis 集群

<dependency>
    <groupId>redis.clients</groupId>
    <artifactId>jedis</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.data</groupId>
    <artifactId>spring-data-redis</artifactId>
</dependency>
<dependency>
    <groupId>org.apache.commons</groupId>
    <artifactId>commons-pool2</artifactId>
</dependency>

spring:
  redis:
    cluster:
      ports:
        - 8001
        - 8002
        - 8003
        - 8004
        - 8005
        - 8006
      host: 192.168.60.133
      poolConfig:
        max-total: 8
        max-idle: 8
        max-wait-millis: -1
        min-idle: 0

• 如果是 Spring Boot 2.x 或 3.x 版本则需要使用如下配置结构。spring.data.redis 是从 Spring Boot 2.x 版本开始引入的新的配置前缀，也用于配置 Redis 的相关参数。

spring:
  data:
    redis:
      database: 0
      cluster:
        nodes:
          - 192.168.121.128:8001
          - 192.168.121.128:8002
          - 192.168.121.128:8003
          - 192.168.121.128:8004
          - 192.168.121.128:8005
          - 192.168.121.128:8006
      password: 123
      jedis:
        pool:
          max-active: 8
          max-idle: 8
          max-wait: -1ms
          min-idle: 0

@Configuration
@ConfigurationProperties("spring.redis.cluster")
public class RedisConfig {
    /**
        通过 @ConfigurationProperties 注解声明配置文件前缀，将配置文件中定义的 ports 数组、host
        及连接池配置信息都将被注入 port、host、poolConfig 三个属性中。
     **/
    List<Integer> ports;
    String host;
    JedisPoolConfig poolConfig;

    // 配置 RedisClusterConfiguration 实例
    @Bean
    RedisClusterConfiguration redisClusterConfiguration() {
        RedisClusterConfiguration configuration = new RedisClusterConfiguration();
        List<RedisNode> nodes = new ArrayList<>();
        for (Integer port : ports) {
            nodes.add(new RedisNode(host, port));
        }
        configuration.setPassword(RedisPassword.of("123")); // 设置 Redis 登录密码
        configuration.setClusterNodes(nodes); // 设置 Redis 节点信息
        return configuration;
    }

    // 根据 RedisClusterConfiguration 实例以及连接池配置信息创建 Jedis 连接工厂 JedisConnectionFactory
    @Bean
    JedisConnectionFactory jedisConnectionFactory() {
        JedisConnectionFactory factory
                = new JedisConnectionFactory(redisClusterConfiguration(),poolConfig);
        return factory;
    }

    // 根据 JedisConnectionFactory 创建 RedisTemplate，同时配置 key 和 value 序列号方式。
    @Bean
    RedisTemplate redisTemplate() {
        RedisTemplate redisTemplate = new RedisTemplate();
        redisTemplate.setConnectionFactory(jedisConnectionFactory());
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());
        return redisTemplate;
    }

    // 根据 JedisConnectionFactory 创建 StringRedisTemplate，同时配置 key 和 value 序列号方式。
    @Bean
    StringRedisTemplate stringRedisTemplate() {
        StringRedisTemplate stringRedisTemplate
                = new StringRedisTemplate(jedisConnectionFactory());
        stringRedisTemplate.setKeySerializer(new StringRedisSerializer());
        stringRedisTemplate.setKeySerializer(new StringRedisSerializer());
        return stringRedisTemplate;
    }

    public List<Integer> getPorts() {
        return ports;
    }

    public void setPorts(List<Integer> ports) {
        this.ports = ports;
    }

    public String getHost() {
        return host;
    }

    public void setHost(String host) {
        this.host = host;
    }

    public JedisPoolConfig getPoolConfig() {
        return poolConfig;
    }

    public void setPoolConfig(JedisPoolConfig poolConfig) {
        this.poolConfig = poolConfig;
    }
}

2，使用样例

@Getter
@Setter
@ToString
public class User implements Serializable {
    private Integer id;
    private String name;
    private Integer age;
}

@RestController
public class HelloController {

    @Autowired
    RedisTemplate redisTemplate; //默认提供的用来操作对象的redis操作实例

    @Autowired
    StringRedisTemplate stringRedisTemplate; //默认提供的用来操作字符串的redis操作实例

    @RequestMapping("/test")
    public void test() {
        //保存一个字符串
        ValueOperations<String, String> ops1 = stringRedisTemplate.opsForValue();
        ops1.set("message", "欢迎访问 hangge.com");

        //读取一个字符串
        String message = ops1.get("message");
        System.out.println("读取一个字符串：" + message);

        //保存一个对象
        ValueOperations ops2 = redisTemplate.opsForValue();
        User u1 = new User();
        u1.setId(1);
        u1.setName("hangge");
        u1.setAge(100);
        ops2.set("user", u1);

        //读取一个对象
        User u2 = (User) ops2.get("user");
        System.out.println("读取一个对象：" + u2.toString());
    }
}