Jedis操作单节点redis，集群及redisTemplate操作redis集群（二）

╰+攻爆jí腚メ 2022-05-22 03:15 249阅读 0赞

1，码云上面地址：https://gitee.com/dream21th/dream21th-redis

2，application.properties配置文件信息如下

<table> 
 <tbody> 
 <tr> 
 <td>#redisCluter redis.cluster.nodes=192.168.1.102:7000,192.168.1.102:7001,192.168.1.102:7002,192.168.1.102:7003,192.168.1.102:7004,192.168.1.102:7005 redis.cluster.testOnReturn=true redis.cluster.maxIdle=10 redis.cluster.minIdle=2 redis.cluster.maxWaitMills=3000 redis.cluster.testOnBorrow=true redis.cluster.maxTotal=4 redis.cluster.connectionTimeOut=30000</td> 
 </tr> 
 </tbody> 
</table>

3，配置文件如下

<table> 
 <tbody> 
 <tr> 
 <td> /** * redis集群模式 * @return */ @Bean public JedisCluster getJedisCluster() { &nbsp; &nbsp; &nbsp; &nbsp; JedisPoolConfig config = new JedisPoolConfig(); &nbsp; &nbsp; &nbsp; &nbsp; config.setMaxTotal(redisConfig.getCluster().getMaxTotal()); &nbsp; &nbsp; &nbsp; &nbsp; config.setMaxIdle(redisConfig.getCluster().getMaxIdle()); &nbsp; &nbsp; &nbsp; &nbsp; config.setMaxWaitMillis(redisConfig.getCluster().getMaxWaitMills()); &nbsp; &nbsp; &nbsp; &nbsp; config.setTestOnBorrow(redisConfig.getCluster().getTestOnBorrow()); &nbsp; &nbsp; &nbsp; &nbsp; List&lt;String&gt; node=Arrays.asList(redisConfig.getCluster().getNodes().split(",")); &nbsp; &nbsp; &nbsp; &nbsp; // 集群模式 &nbsp; &nbsp; &nbsp; &nbsp; JedisPoolConfig poolConfig = new JedisPoolConfig(); &nbsp; &nbsp; &nbsp; &nbsp; Set&lt;HostAndPort&gt; nodes = new HashSet&lt;HostAndPort&gt;(); &nbsp; &nbsp; &nbsp; &nbsp; node.forEach(n-&gt;{ &nbsp; &nbsp; &nbsp; &nbsp; String[] ip=n.split(":"); &nbsp; &nbsp; &nbsp; &nbsp; HostAndPort hostAndPort = new HostAndPort(ip[0],Integer.parseInt(ip[1])); &nbsp; &nbsp; &nbsp; &nbsp; nodes.add(hostAndPort); &nbsp; &nbsp; &nbsp; &nbsp; }); &nbsp; &nbsp; &nbsp; &nbsp; JedisCluster jedisCluster = new JedisCluster(nodes, poolConfig); &nbsp; &nbsp; &nbsp; &nbsp; return jedisCluster; &nbsp; &nbsp; }</td> 
 </tr> 
 </tbody> 
</table>

4，对外提供的方法

<table style="height:200px;"> 
 <tbody> 
 <tr> 
 <td>package com.dream21th.dream21thredis.redis; import java.util.List; import java.util.Map; import java.util.Set; import com.dream21th.dream21thredis.key.KeyPrefix; /** &nbsp;*&nbsp; &nbsp;* @author dream21th&nbsp; &nbsp;采用jedis操作redis数据库提供的方法 &nbsp;* &nbsp;*/ public interface IJedisClient { /** * 获取缓存&nbsp; &nbsp; * @param prefix&nbsp; &nbsp;键的前缀 * @param key&nbsp; &nbsp; &nbsp; 键的值 * @param clazz&nbsp; &nbsp; 获取对象类型 * @return */ public &lt;T&gt; T get(KeyPrefix prefix, String key,&nbsp; Class&lt;T&gt; clazz); /** * 设置缓存 * @param prefix&nbsp; &nbsp;键的前缀 * @param key&nbsp; &nbsp; &nbsp; 键的值 * @param value&nbsp; &nbsp; 设置的值 * @return */ public &lt;T&gt; boolean set(KeyPrefix prefix, String key,&nbsp; T value); /** * 判断缓存是否存在 * @param prefix * @param key * @return */ public &lt;T&gt; boolean exists(KeyPrefix prefix, String key); /** * 键的值加1 * @param prefix * @param key * @return */ public &lt;T&gt; Long incr(KeyPrefix prefix, String key); /** * 键的值减1 * @param prefix * @param key * @return */ public &lt;T&gt; Long decr(KeyPrefix prefix, String key); /** * 获取缓存 * @param key 键 * @return 值 */ public String get(String key); /** * 获取缓存 * @param key 键 * @return 值 */ public Object getObject(String key); /** * 获取缓存 * @param key 键 * @return 值 */ public &lt;T&gt; T getT(String key); /** * 设置缓存 * @param key 键 * @param value 值 * @param cacheSeconds 超时时间，0为不超时 * @return */ public String set(String key, String value, int cacheSeconds); /** * 设置缓存 * @param key 键 * @param value 值 * @param cacheSeconds 超时时间，0为不超时 * @return */ public String setObject(String key, Object value, int cacheSeconds); /** * 设置缓存 * @param key 键 * @param value 值 * @param cacheSeconds 超时时间，0为不超时 * @return */ public &lt;T&gt; String setT(String key, T value, int cacheSeconds); /** * 获取List缓存 * @param key 键 * @return 值 */ public List&lt;String&gt; getList(String key); /** * 获取List缓存 * @param key 键 * @return 值 */ public List&lt;Object&gt; getObjectList(String key); /** * 设置List缓存 * @param key 键 * @param value 值 * @param cacheSeconds 超时时间，0为不超时 * @return */ public long setList(String key, List&lt;String&gt; value, int cacheSeconds); /** * 设置List缓存 * @param key 键 * @param value 值 * @param cacheSeconds 超时时间，0为不超时 * @return */ public long setObjectList(String key, List&lt;Object&gt; value, int cacheSeconds); /** * 向List缓存中添加值 * @param key 键 * @param value 值 * @return */ public long listAdd(String key, String... value); /** * 向List缓存中添加值 * @param key 键 * @param value 值 * @return */ public long listObjectAdd(String key, Object... value); /** * 获取缓存 * @param key 键 * @return 值 */ public Set&lt;String&gt; getSet(String key); /** * 获取缓存 * @param key 键 * @return 值 */ public Set&lt;Object&gt; getObjectSet(String key); /** * 设置Set缓存 * @param key 键 * @param value 值 * @param cacheSeconds 超时时间，0为不超时 * @return */ public long setSet(String key, Set&lt;String&gt; value, int cacheSeconds); /** * 设置Set缓存 * @param key 键 * @param value 值 * @param cacheSeconds 超时时间，0为不超时 * @return */ public long setObjectSet(String key, Set&lt;Object&gt; value, int cacheSeconds); /** * 向Set缓存中添加值 * @param key 键 * @param value 值 * @return */ public long setSetAdd(String key, String... value); /** * 向Set缓存中添加值 * @param key 键 * @param value 值 * @return */ public long setSetObjectAdd(String key, Object... value); /** * 获取Map缓存 * @param key 键 * @return 值 */ public Map&lt;String, String&gt; getMap(String key); /** * 获取Map缓存 * @param key 键 * @return 值 */ public Map&lt;String, Object&gt; getObjectMap(String key); /** * 设置Map缓存 * @param key 键 * @param value 值 * @param cacheSeconds 超时时间，0为不超时 * @return */ public String setMap(String key, Map&lt;String, String&gt; value, int cacheSeconds); /** * 设置Map缓存 * @param key 键 * @param value 值 * @param cacheSeconds 超时时间，0为不超时 * @return */ public String setObjectMap(String key, Map&lt;String, Object&gt; value, int cacheSeconds); /** * 向Map缓存中添加值 * @param key 键 * @param value 值 * @return */ public String mapPut(String key, Map&lt;String, String&gt; value); /** * 向Map缓存中添加值 * @param key 键 * @param value 值 * @return */ public String mapObjectPut(String key, Map&lt;String, Object&gt; value); /** * 移除Map缓存中的值 * @param key 键 * @param value 值 * @return */ public long mapRemove(String key, String mapKey); /** * 移除Map缓存中的值 * @param key 键 * @param value 值 * @return */ public long mapObjectRemove(String key, String mapKey); /** * 判断Map缓存中的Key是否存在 * @param key 键 * @param value 值 * @return */ public boolean mapExists(String key, String mapKey); /** * 判断Map缓存中的Key是否存在 * @param key 键 * @param value 值 * @return */ public boolean mapObjectExists(String key, String mapKey); /** * 删除缓存 * @param key 键 * @return */ public long del(String key); /** * 删除缓存 * @param key 键 * @return */ public long delObject(String key); /** * 缓存是否存在 * @param key 键 * @return */ public boolean exists(String key); /** * 缓存是否存在 * @param key 键 * @return */ public boolean existsObject(String key); }</td> 
 </tr> 
 </tbody> 
</table>

5，controller测试（与单节点方法一样的测试）

<table> 
 <tbody> 
 <tr> 
 <td>package com.dream21th.dream21thredis.controller; import java.util.List; import java.util.Map; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import com.dream21th.dream21thredis.dto.Person; import com.dream21th.dream21thredis.dto.Student; import com.dream21th.dream21thredis.key.UserKey; import com.dream21th.dream21thredis.redis.IJedisClient; import com.dream21th.dream21thredis.result.Result; import com.dream21th.dream21thredis.service.RedisService; import io.swagger.annotations.Api; import io.swagger.annotations.ApiOperation; import lombok.extern.slf4j.Slf4j; @Slf4j @RestController @RequestMapping("/mutilNode") @Api(tags="多节点redis操作") public class RedisMutilNodeController { @Autowired private IJedisClient jedisClusterClient; @Autowired private RedisService redisService; &nbsp; &nbsp; @PostMapping("/mapTest/{key}") &nbsp; &nbsp; @ApiOperation(value = "map测试", notes = "map测试") public Result&lt;Map&lt;String,String&gt;&gt; mapTest(@PathVariable("key") String key,@RequestBody Map&lt;String,String&gt; map){ jedisClusterClient.setMap(key, map,0); return Result.success(jedisClusterClient.getMap(key)); } &nbsp; &nbsp; @PostMapping("/listTest/{key}") public Result&lt;List&lt;String&gt;&gt; ListTest(@PathVariable("key") String key,@RequestBody List&lt;String&gt; list){ jedisClusterClient.setList(key, list, 0); return Result.success(jedisClusterClient.getList(key)); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/listTestObj/{key}") public Result&lt;List&lt;Object&gt;&gt; listTestObj(@PathVariable("key") String key,@RequestBody List&lt;Object&gt; list){ jedisClusterClient.setObjectList(key, list, 0); return Result.success(jedisClusterClient.getObjectList(key)); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/listTestT") public&nbsp; Result&lt;Student&gt; listTestT(@RequestBody Student t){ jedisClusterClient.set(UserKey.getById, "name",t); log.info("键值是否存在：{}",jedisClusterClient.exists(UserKey.getById, "name")); redisService.getResult(); return Result.success(jedisClusterClient.get(UserKey.getById, "name",Student.class)); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/decIcrTest") public&nbsp; Result&lt;Long&gt; decIcrTest(long num){ jedisClusterClient.set(UserKey.getById, "count",num); log.info("键值是否存在：{}",jedisClusterClient.exists(UserKey.getById, "count")); log.info("加1后值：{}",jedisClusterClient.incr(UserKey.getById, "count")); log.info("减1后值：{}",jedisClusterClient.decr(UserKey.getById, "count")); return Result.success(jedisClusterClient.get(UserKey.getById, "count",Long.class)); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/testObj") public&nbsp; Result&lt;Student&gt; testObj(@RequestBody Student t){ &nbsp; &nbsp; jedisClusterClient.setObject("student", t, 0); return Result.success((Student)jedisClusterClient.getObject("student")); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/testT") public&nbsp; Result&lt;Student&gt; testT(@RequestBody Student t){ &nbsp; &nbsp; jedisClusterClient.setObject("student", t, 0); return Result.success(jedisClusterClient.getT("student")); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/testT1") public&nbsp; Result&lt;Person&gt; testT1(@RequestBody Person t){ &nbsp; &nbsp; jedisClusterClient.setT("person", t, 0); return Result.success(jedisClusterClient.getT("person")); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/testList") public&nbsp; Result&lt;List&lt;Student&gt;&gt; testList(@RequestBody Student t){ return Result.success(redisService.getList()); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/mapTestT") &nbsp; &nbsp; @ApiOperation(value = "传入对象，以map获取值", notes = "传入对象，以map获取值") public&nbsp; Result&lt;Map&gt; mapTestT(@RequestBody Student t){ jedisClusterClient.set(UserKey.getById, "map",t); log.info("键值是否存在：{}",jedisClusterClient.exists(UserKey.getById, "map")); redisService.getResult(); return Result.success(jedisClusterClient.get(UserKey.getById, "map",Map.class)); } }</td> 
 </tr> 
 </tbody> 
</table>

6,测试结果

![70][]

[70]: /images/20220522/a6164a0403e149a08ad8c94383b069c7.png