搜索

SpringBoot 项目接入 Redis 集群

互联网全栈架构

共 20696字，需浏览 42分钟

 · 2020-09-25

每天早上七点三十，准时推送干货

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

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

配置参数

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

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

修改配置参数

############### 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


import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.apache.commons.pool2.impl.GenericObjectPoolConfig;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Primary;
import org.springframework.data.redis.connection.RedisClusterConfiguration;
import org.springframework.data.redis.connection.RedisNode;
import org.springframework.data.redis.connection.jedis.JedisClientConfiguration;
import org.springframework.data.redis.connection.jedis.JedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

import java.time.Duration;
import java.util.ArrayList;
import java.util.List;

public class RedisClusterConfig {

    @Bean(name = "redisTemplate")
    @Primary
    public RedisTemplate redisClusterTemplate(@Value("${spring.custome.redis.cluster.nodes}") String host,
                                     @Value("${spring.custome.redis.cluster.password}") String password,
                                     @Value("${spring.custome.redis.cluster.timeout}") long timeout,
                                     @Value("${spring.custome.redis.cluster.max-redirects}") int maxRedirect,
                                     @Value("${spring.custome.redis.cluster.max-active}") int maxActive,
                                     @Value("${spring.custome.redis.cluster.max-wait}") int maxWait,
                                     @Value("${spring.custome.redis.cluster.max-idle}") int maxIdle,
                                     @Value("${spring.custome.redis.cluster.min-idle}") int minIdle) {

        JedisConnectionFactory connectionFactory =  jedisClusterConnectionFactory(host, password,
                timeout, maxRedirect, maxActive, maxWait, maxIdle, minIdle);
        return createRedisClusterTemplate(connectionFactory);
    }

    private JedisConnectionFactory jedisClusterConnectionFactory(String host, String password,
                                                                   long timeout, int maxRedirect, int maxActive, int maxWait, int maxIdle, int minIdle) {
        RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration();
        List
     
       nodeList = 
      new ArrayList<>();
      
        String[] cNodes = host.split(
      ",");
      
        
      //分割出集群节点
      
        
      for (String node : cNodes) {
      
            String[] hp = node.split(
      ":");
      
            nodeList.add(
      new RedisNode(hp[
      0], Integer.parseInt(hp[
      1])));
      
        }
      
        redisClusterConfiguration.setClusterNodes(nodeList);
      
        redisClusterConfiguration.setPassword(password);
      
        redisClusterConfiguration.setMaxRedirects(maxRedirect);
      

      
        
      // 连接池通用配置
      
        GenericObjectPoolConfig genericObjectPoolConfig = 
      new GenericObjectPoolConfig();
      
        genericObjectPoolConfig.setMaxIdle(maxIdle);
      
        genericObjectPoolConfig.setMaxTotal(maxActive);
      
        genericObjectPoolConfig.setMinIdle(minIdle);
      
        genericObjectPoolConfig.setMaxWaitMillis(maxWait);
      
        genericObjectPoolConfig.setTestWhileIdle(
      true);
      
        genericObjectPoolConfig.setTimeBetweenEvictionRunsMillis(
      300000);
      

      
        JedisClientConfiguration.DefaultJedisClientConfigurationBuilder builder = (JedisClientConfiguration.DefaultJedisClientConfigurationBuilder) JedisClientConfiguration
      
                .builder();
      
        builder.connectTimeout(Duration.ofSeconds(timeout));
      
        builder.usePooling();
      
        builder.poolConfig(genericObjectPoolConfig);
      
        JedisConnectionFactory connectionFactory = 
      new JedisConnectionFactory(redisClusterConfiguration, builder.build());
      
        
      // 连接池初始化
      
        connectionFactory.afterPropertiesSet();
      

      
        
      return connectionFactory;
      
    }
      

      
    
      private RedisTemplate createRedisClusterTemplate(JedisConnectionFactory redisConnectionFactory) {
      
        RedisTemplate
      
        redisTemplate = 
       new RedisTemplate<>();
       
        redisTemplate.setConnectionFactory(redisConnectionFactory);
       

       
        Jackson2JsonRedisSerializer
        jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer<>(Object.class);
        ObjectMapper om = new ObjectMapper();
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jackson2JsonRedisSerializer.setObjectMapper(om);

        StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
        // key采用String的序列化方式
        redisTemplate.setKeySerializer(stringRedisSerializer);
        // hash的key也采用String的序列化方式
        redisTemplate.setHashKeySerializer(stringRedisSerializer);
        // value序列化方式采用jackson
        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
        // hash的value序列化方式采用jackson
        redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
        redisTemplate.afterPropertiesSet();

        return redisTemplate;
    }
}


        

         
相关代码已经提交到GitHub，公众号回复【源码仓库】即可获取。这里一定要注意 Jedis 的 Spring-data-redis 的版本支持设置密码，毕竟生产环境是一定要配置密码的。

        
编写工具类
其实到这里基本上已经完成了，我们可以看到 SpringBoot 项目接入 Redis 集群还是比较简单的，而且如果之前单机环境就是采用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 hmget(String key, List
             
               values)
              {

        return getTemplate().opsForHash().multiGet(key, values);
    }
上面随机列了几个方法，更多方案等待你的探索。
总结
今天阿粉给大家介绍了一下 SpringBoot 项目如何接入 Redis 集群，需要的朋友可以参考一下，不过阿粉还是要说一下，系统的设计不能过于冗余，如果短期内还能支撑业务的发展，那就暂时不要考虑太复杂，毕竟系统的架构是需要不断的完善的，不可能刚开始的时候就设计出一套很完善的系统框架。随着业务的不断发展，当真正发现单机Redis 已经无法满足业务需求的时候再接入也不迟！
浏览 28
点赞
评论
收藏
分享

手机扫一扫分享

举报
评论
图片
表情
推荐
SpringBoot 实现图片防盗链功能
程序员的成长之路互联网/程序员/技术/资料共享 关注阅读本文大概需要 4 分钟。来自：blog.csdn.net/weixin_46157208/article/details/138051737前言出于安全考虑，我们需要后端返回的图片只允许在某个网站内展示，不想被爬虫拿到图片地
程序员的成长之路
0
大量 Java 开源项目停更...
点击关注公众号，Java 干货及时推送↓推荐阅读：投了 100 多份简历后…出品 | OSC开源社区（ID：oschina2013)Sonatype 发布了最新的一份《软件供应链状况》报告，深入探讨了如何在充满选择的世界中定义更好的软件，并探讨人工智能 (AI) 对软件开发的深远
Java技术栈
0
springboot第70集：字节跳动后端三面经，一文让你走出微服务迷雾架构周刊
创建一个使用Kubernetes (K8s) 和 Jenkins 来自动化 GitLab 前端项目打包的CI/CD流水线，需要配置多个组件。下面，我将概述一个基本的设置步骤和示例脚本，以帮助你理解如何使用这些工具整合一个自动化流程。前提条件确保你已经有：Kubernetes 集群：用于部署 Jenk
程序源代码
0
Java项目实战——打造一款股票区间交易盯盘系统
点击上方“Java进阶学习交流”，进行关注后台回复“Java”即可获赠Java学习资料今日鸡汤身无彩凤双飞翼，心有灵犀一点通。一、简介大家好，我是Snowball。今天给大家分享的内容是基于Java编程，实现股票交易相关功能开发，如果读者对股票或金融衍生物交易不太了解，又比较感兴趣的话可自行查询相关
Java进阶学习交流
0
轻松学习C#：百度行驶证C++离线SDK接入详解
效果 先看最终效果SDK 拿到完整包如图，687M解压后看看内容发现有个readme.txt，那就先看看内容1:用vs2015打开sln工程，最好用vs2015 comunity版本，可微软官网下载。2:sdk的doc目录有pdf接口文档。3:工程总入口main.cpp、请参考示例实现您的功能。4:
DotNet NB
9
【Vuejs】2023- Vue3 项目前端 CI/CD 体验
作者：PAXTONX1. 环境准备➜  app-cicd node --versionv18.0.0➜  app-cicd npm --version9.6.62. 安装2.1 初始化选项项目初始化选择。➜ &
前端自习课
10
Redis 是怎么从单体架构发展到分布式缓存的？
图解学习网站：https://xiaolincoding.comRedis 架构是如何一步一步发展到今天的样子的？2010 年 - 单体 RedisRedis 1.0 于 2010 年发布，当时的架构非常简单。它通常用作业务应用程序的缓存。不过，Redis 将数据存储在内存中。当我们重启 Redis
小林coding
10
小美播报|网络文学IP微短剧扶持项目在无锡发布
小美播报福建广电网络集团召开2024年第一季度经营分析会4月16日，福建广电网络集团在莆田召开第一季度经营分析会，总结分析一季度经营成效，部署安排第二季度工作任务，要求持续深化拓展“深学争优、敢为争先、实干争效”行动部署，确保“双过半”目标实现。点击查看详情广西广电网络公司与华数集团举行战略合作协议
流媒体网
0
得物面试：Redis 内存碎片是什么？如何清理？
JavaGuide官方网站：javaguide.cn这是一道不是特别高频但很重要的 Redis 面试题，属于 Redis 性能优化的范畴。Redis 内存碎片相关的问题在得物、美团、阿里、字节、携程等公司的后端面试中都曾出现过，还是建议认真准备一下。即使不是准备面试，日常开发也是能够用到的！什么是内
JavaGuide
0
性能爆表：SpringBoot利用ThreadPoolTaskExecutor批量插入百万级数据实测！
关注我们,设为星标,每天7:40不见不散,架构路上与您共享回复架构师获取资源大家好，我是你们的朋友架构君，一个会写代码吟诗的架构师。来源：azdebug.blog.csdn.net/article/details/103697108前言具体实现细节测试结果总结前言开发目的： 提高百万级数据
Java架构师社区
0
点赞
评论
收藏
分享

手机扫一扫分享

举报