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

浅浅的花香味﹌ 2022-05-22 03:21 171阅读 0赞

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

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

<table style="border-spacing:0px;width:852px;color:rgb(51,51,51);font-size:14px;background-color:rgb(255,255,255);"> 
 <tbody> 
 <tr> 
 <td style="margin:0px;">#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 style="height:200px;"> 
 <tbody> 
 <tr> 
 <td>/** * 提供集群部署的情况下面的redisTemplate支持 * @param factory * @return */ @Bean("redisTemplate") &nbsp; &nbsp; public RedisTemplate&lt;Object, Object&gt; redisTemplate(RedisConnectionFactory factory) { &nbsp; &nbsp; &nbsp; &nbsp; RedisTemplate&lt;Object, Object&gt; redisTemplate = new RedisTemplate&lt;Object, Object&gt;(); &nbsp; &nbsp; &nbsp; &nbsp; redisTemplate.setConnectionFactory(factory); &nbsp; &nbsp; &nbsp; &nbsp; Jackson2JsonRedisSerializer&lt;Object&gt; serializer = new Jackson2JsonRedisSerializer&lt;Object&gt;(Object.class); &nbsp; &nbsp; &nbsp; &nbsp; ObjectMapper om = new ObjectMapper(); &nbsp; &nbsp; &nbsp; &nbsp; om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); &nbsp; &nbsp; &nbsp; &nbsp; om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL); &nbsp; &nbsp; &nbsp; &nbsp; serializer.setObjectMapper(om); &nbsp; &nbsp; &nbsp; &nbsp; redisTemplate.setKeySerializer(serializer); &nbsp; &nbsp; &nbsp; &nbsp; redisTemplate.setValueSerializer(serializer); &nbsp; &nbsp; &nbsp; &nbsp; redisTemplate.afterPropertiesSet(); &nbsp; &nbsp; &nbsp; &nbsp; //redisTemplate.setEnableTransactionSupport(true); &nbsp; &nbsp; &nbsp; &nbsp; return redisTemplate; &nbsp; &nbsp; } /** &nbsp; &nbsp; &nbsp;* jedis 连接池 &nbsp; &nbsp; &nbsp;* @return &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; private JedisPoolConfig jedisPoolConfig() { &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; return config; &nbsp; &nbsp; } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @Bean(name = "redisCacheManager") &nbsp; &nbsp; public CacheManager cacheManager(RedisTemplate&lt;Object, Object&gt; redisTemplate) { &nbsp; &nbsp; &nbsp; &nbsp; RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate); &nbsp; &nbsp; &nbsp; &nbsp; cacheManager.setDefaultExpiration(1800); &nbsp; &nbsp; &nbsp; &nbsp; return cacheManager; &nbsp; &nbsp; } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; /** &nbsp; &nbsp; &nbsp;* redisCluster配置 &nbsp; &nbsp; &nbsp;* &nbsp; &nbsp; &nbsp;* @return &nbsp; &nbsp; &nbsp;*/ &nbsp; &nbsp; @Bean &nbsp; &nbsp; public RedisClusterConfiguration redisProperties() { &nbsp; &nbsp; &nbsp; &nbsp; Map&lt;String, Object&gt; source = new HashMap&lt;String, Object&gt;(); &nbsp; &nbsp; &nbsp; &nbsp; source.put("spring.redis.cluster.nodes", redisConfig.getCluster().getNodes()); &nbsp; &nbsp; &nbsp; &nbsp; source.put("spring.redis.cluster.timeout", redisConfig.getCluster().getConnectionTimeOut()); &nbsp; &nbsp; &nbsp; &nbsp; return new RedisClusterConfiguration(new MapPropertySource("RedisProperties", source)); &nbsp; &nbsp; } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @Bean("jedisConnFactory") &nbsp; &nbsp; public JedisConnectionFactory jedisConnectionFactory() { &nbsp; &nbsp; &nbsp; &nbsp; //redis cluster &nbsp; &nbsp; &nbsp; &nbsp; JedisConnectionFactory factory = new JedisConnectionFactory(redisProperties(),jedisPoolConfig()); &nbsp; &nbsp; &nbsp; &nbsp; return factory; &nbsp; &nbsp; }</td> 
 </tr> 
 </tbody> 
</table>

4，controller测试

<table style="height:200px;"> 
 <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.data.redis.core.RedisTemplate; 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.ResponseBody; import org.springframework.web.bind.annotation.RestController; import com.alibaba.fastjson.JSON; import com.dream21th.dream21thredis.dto.Student; import com.dream21th.dream21thredis.result.Result; import io.swagger.annotations.Api; import lombok.extern.slf4j.Slf4j; @Slf4j @RestController @RequestMapping("/redisTemplate") @Api(tags="redisTemplate操作") public class RedisTemplateController { &nbsp; &nbsp; @Autowired private RedisTemplate&lt;Object, Object&gt; redisTemplate; &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/{key}/{value}") @ResponseBody public Result redisTemplate(@PathVariable("key") String key,@PathVariable("value") String value){ log.info("键：【{}】，值：【{}】",key,value); &nbsp; &nbsp; redisTemplate.opsForValue().set(key, value); return Result.success(redisTemplate.opsForValue().get(key)); } &nbsp; &nbsp; &nbsp; &nbsp; @PostMapping("/{key}") @ResponseBody public Result&lt;Student&gt; redisTemplateObject(@PathVariable("key") String key,@RequestBody Student student){ log.info("键：【{}】，值：【{}】",key,JSON.toJSONString(student)); &nbsp; &nbsp; redisTemplate.opsForValue().set(key, student); return Result.success((Student)redisTemplate.opsForValue().get(key)); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/list/{keyList}") @ResponseBody public Result&lt;List&lt;Student&gt;&gt; redisTemplateList(@PathVariable("keyList") String keyList,@RequestBody List&lt;Student&gt; student){ log.info("键：【{}】，值：【{}】",keyList,JSON.toJSONString(student)); &nbsp; &nbsp; redisTemplate.opsForValue().set(keyList, student); return Result.success((List&lt;Student&gt;)redisTemplate.opsForValue().get(keyList)); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/decrInc/{key}/{num}") @ResponseBody public Result&lt;Integer&gt; redisTemplatedecrInc(@PathVariable("key") String key,@PathVariable("num") String num){ log.info("键：【{}】",key); redisTemplate.opsForValue().set(key, 1000); &nbsp; &nbsp; log.info("加1后的值：【{}】",redisTemplate.opsForValue().increment(key, 1)); &nbsp; &nbsp; log.info("减10后的值：【{}】",redisTemplate.opsForValue().increment(key, -10)); return Result.success((Integer)redisTemplate.opsForValue().get(key)); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/map/{key1}/{key2}") @ResponseBody public Result redisTemplateMap(@PathVariable("key1") String key1,@PathVariable("key2") String key2,@RequestBody Map map){ log.info("键1：【{}】,键2：【{}】，值：【{}】",key1,key2,JSON.toJSONString(map)); &nbsp; &nbsp; redisTemplate.opsForHash().put(key1, key2, map); return Result.success(redisTemplate.opsForHash().get(key1, key2)); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/mapdelete/{key1}/{key2}") @ResponseBody public Result redisTemplateMapdelete(@PathVariable("key1") String key1,@PathVariable("key2") String key2){ log.info("键1：【{}】,键2：【{}】",key1,key2); return Result.success(redisTemplate.opsForHash().delete(key1, key2)); } &nbsp; &nbsp;&nbsp; &nbsp; &nbsp; @PostMapping("/list/{key1}/{key2}") @ResponseBody public Result redisTemplateList(@PathVariable("key1") String key1,@PathVariable("key2") String key2){ log.info("键1：【{}】,键2：【{}】",key1,key2); redisTemplate.opsForList().leftPush(key1, key2); return Result.success(redisTemplate.opsForList().range(key1, 0, -1)); } &nbsp; &nbsp;&nbsp; }</td> 
 </tr> 
 </tbody> 
</table>