环境准备

首先我们需要准备一套redis集群，可以参考我写的文章：https://blog.csdn.net/m0_51510236/article/details/132684529。这次我已经准备好了一个集群，如图（一个多主多从的redis集群）：
在这里插入图片描述

本片文章使用的代码仓库地址：https://gitcode.net/m0_51510236/redis-cluster-example

SpringBoot整合Redis集群

新建项目

我们来新建一个SpringBoot项目来连接这个集群，来到spring initializr进行初始化：
在这里插入图片描述

然后我们将其导入开发工具，如图：
在这里插入图片描述

修改SpringBoot配置文件

编辑 application.yaml 文件，文件内容为：

# 设置端口
server:
  port: 8080

spring:
  redis:
    cluster:
      # 设置redis集群当中都有哪些节点，注意修改为你自己的节点地址
      nodes:
        - 192.168.1.171:6379
        - 192.168.1.172:6379
        - 192.168.1.173:6379
        - 192.168.1.174:6379
        - 192.168.1.175:6379
        - 192.168.1.176:6379

编写代码测试

我们将编写一个控制器来测试这个集群

编写DTO

我们先编写一个存储到redis的DTO类 RedisValueDTO.java：

package city.yueyang.redis.entity;

import java.io.Serializable;

/**
 * <p>
 * 存储Redis值类型的数据传输类
 * </p>
 *
 * @author XiaoHH
 * @version 1.0.0
 * @date 2023-09-06 星期三 11:21:28
 * @file RedisValueDTO.java
 */
public class RedisValueDTO implements Serializable {

    /**
     * Redis的Key
     */
    private String key;

    /**
     * 设置到Redis当中的值
     */
    private String value;

    public String getKey() {
        return key;
    }

    public void setKey(String key) {
        this.key = key;
    }

    public String getValue() {
        return value;
    }

    public void setValue(String value) {
        this.value = value;
    }
}

编写Controller

编写一个可以设置和获取redis值的Controller类 RedisController.java：

package city.yueyang.redis.controller;

import city.yueyang.redis.entity.RedisValueDTO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*;

/**
 * <p>
 * 操作Redis的Controller
 * </p>
 *
 * @author XiaoHH
 * @version 1.0.0
 * @date 2023-09-06 星期三 11:49:01
 * @file RedisController.java
 */
@RestController
@RequestMapping("/redis")
public class RedisController {

    /**
     * 注入Redis的操作对象
     */
    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    /**
     * 设置一个值到Redis当中
     *
     * @param value 设置的内容对象
     * @return 返回Success
     */
    @PostMapping
    public String set(@RequestBody RedisValueDTO value) {
        this.redisTemplate.opsForValue().set(value.getKey(), value.getValue());
        return "Success";
    }

    /**
     * 根据key在Redis当中获取一个值
     *
     * @param key redis的key
     * @return 缓存当中的值
     */
    @GetMapping("/{key}")
    public String get(@PathVariable("key") String key) {
        return this.redisTemplate.opsForValue().get(key);
    }
}

此时项目结构为：
在这里插入图片描述

代码仓库地址：https://gitcode.net/m0_51510236/redis-cluster-example

测试编写的代码

我们直接使用开发工具 idea 自带的http工具进行测试吧，测试代码如下：

### 设置的值的内容
POST http://localhost:8080/redis
Content-Type: application/json

{
  "key": "k1",
  "value": "v1"
}

### 获取值的内容
GET http://localhost:8080/redis/k1

我们测试第一个设置值，可以看到返回Success：
在这里插入图片描述