SpringBoot 项目接入 Redis 集群

SpringBoot 项目接入 Redis 集群

Hello 大家好，我是鸭血粉丝，Redis 想必大家一定不会陌生，平常工作中或多或少都会用到，不管是用来存储登录信息还是用来缓存热点数据，对我们来说都是很有帮助的。但是 Redis 的集群估计并不是每个人都会用到，因为很多业务场景或者系统都是一些简单的管理系统，并不会需要用到 Redis 的集群环境。

阿粉之前也是这样，项目中用的的 Redis 是个单机环境，但是最近随着终端量的上升，慢慢的发现单机已经快支撑不住的，所以思考再三决定将 Redis 的环境升级成集群。下面阿粉给大家介绍一下在升级的过程中项目中需要调整的地方，这篇文章不涉及集群的搭建和配置，感兴趣的同学自行搜索。

配置参数

因为这篇文章不介绍 Redis 集群的搭建，这里我们假设已经有了一个 Redis 的集群环境，我们项目中需要调整以下几个部分

修改配置参数，集群的节点和密码配置;确保引入的 Jedis 版本支持设置密码，spring-data-redis 1.8 以上，SpringBoot 1.5 以上才支持设置密码;注入 RedisTemplate;编写工具类;

修改配置参数

############### Redis 集群配置 ######################### spring.custome.redis.cluster.nodes=172.20.0.1:7001,172.20.0.2:7002,172.20.0.3:7003 spring.custome.redis.cluster.max-redirects=3 spring.custome.redis.cluster.max-active=500 spring.custome.redis.cluster.max-wait=-1 spring.custome.redis.cluster.max-idle=500 spring.custome.redis.cluster.min-idle=20 spring.custome.redis.cluster.timeout=3000 spring.custome.redis.cluster.password=redis.cluster.password

引入依赖(如果需要)

确保 SpringBoot 的版本大于 1.4.x 如果不是的话，采用如下配置，先排除 SpringBoot 中旧版本 Jedis 和 spring-data-redis，再依赖高版本的 Jedis 和 spring-data-redis。

             org.springframework.boot             spring-boot-starter-data-redis                                                                redis.clients                     jedis                                                       org.springframework.data                     spring-data-redis                                                                      redis.clients             jedis             2.9.0                               org.springframework.data             spring-data-redis             1.8.0.RELEASE         

注入 RedisTemplate

注入 RedisTemplate 我们需要三个组件，分别是JedisConnectionFactory 、RedisClusterConfiguration、JedisPoolConfig，下面是注入RedisTempalte 的代码。先根据配置创建 JedisConnectFactory 同时需要配置 RedisClusterConfiguration、JedisPoolConfig，最后将JedisConnectionFactory 返回用于创建RedisTemplate

编写工具类

/**      *  删除KEY      * @param key      * @return      */     public boolean delete(String key) {         try {             return getTemplate().delete(key);         } catch (Exception e) {             log.error("redis hasKey() is error");             return false;         }     }      /**      * 普通缓存获取      *      * @param key 键      * @return 值      */     public Object get(String key) {          return key == null ? null : getTemplate().opsForValue().get(key);     }      /**      * 普通缓存放入      *      * @param key   键      * @param value 值      * @return true成功 false失败      */     public boolean set(String key, Object value) {          try {             getTemplate().opsForValue().set(key, value);             return true;         } catch (Exception e) {             log.error("redis set() is error");             return false;         }      }      /**      * 普通缓存放入并设置时间      *      * @param key   键      * @param value 值      * @param time  时间(秒) time要大于0 如果time小于等于0 将设置无限期      * @return true成功 false 失败      */     public boolean set(String key, Object value, long time) {         try {             if (time > 0) {                 getTemplate().opsForValue().set(key, value, time, TimeUnit.SECONDS);             } else {                 set(key, value);             }             return true;         } catch (Exception e) {             log.error("redis set() is error");             return false;         }     }      /**      * 计数器      *      * @param key 键      * @return 值      */     public Long incr(String key) {          return getTemplate().opsForValue().increment(key);     }      public Long incrBy(String key, long step) {          return getTemplate().opsForValue().increment(key, step);     }      /**      * HashGet      *      * @param key  键 不能为null      * @param item 项 不能为null      * @return 值      */     public Object hget(String key, String item) {          return getTemplate().opsForHash().get(key, item);     }      /**      * 获取hashKey对应的所有键值      *      * @param key 键      * @return 对应的多个键值      */     public Map hmget(String key) {          return getTemplate().opsForHash().entries(key);     }      /**      * 获取hashKey对应的批量键值      * @param key      * @param values      * @return      */     public List