环境准备
首先我们需要准备一套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：
我们测试第一个获取值的内容，可以看到成功的获取了我们设置的值 v1：
SpringBoot整合Redis就到此结束了。
