SpringBoot实战之16 整合redis哨兵

迈不过友情╰ 2022-05-18 04:15 299阅读 0赞

前言

对springboot整合redis感兴趣的可以参考此篇博客 SpringBoot实战之13 整合redis

对spring整合redis感兴趣的参考这里 spring实战3 spring整合单例redis

spring整合哨兵参考这里 spring实战4 spring整合redis哨兵

本篇介绍springboot整合哨兵模式

开始

建项目

新建springboot-redis-sentinel项目

添加maven依赖

  1. <dependency>
  2.     <groupId>org.springframework.boot</groupId>
  3.     <artifactId>spring-boot-starter-web</artifactId>
  4. </dependency>
  5. <dependency>
  6.     <groupId>org.springframework.boot</groupId>
  7.     <artifactId>spring-boot-starter-data-redis</artifactId>
  8. </dependency>
  9. <dependency>
  10.     <groupId>org.springframework.boot</groupId>
  11.     <artifactId>spring-boot-starter-test</artifactId>
  12. </dependency>
  13. <dependency>
  14.     <groupId>redis.clients</groupId>
  15.     <artifactId>jedis</artifactId>
  16. </dependency>
  17. <dependency>
  18.     <groupId>com.fasterxml.jackson.core</groupId>
  19.     <artifactId>jackson-databind</artifactId>
  20. </dependency>
  21. <dependency>
  22.     <groupId>com.hsy.java</groupId>
  23.     <artifactId>java-util</artifactId>
  24. </dependency>

配置文件

新建redis.properties redis配置文件

  1. #Matser的ip地址
  2. redis.host=172.16.191.102
  3. #端口号
  4. redis.port=6379
  5. #如果有密码
  6. redis.password=123456
  7. # 数据库索引
  8. redis.database=0
  9. #客户端超时时间单位是毫秒 默认是2000
  10. redis.timeout=10000  
  12. #最大空闲数
  13. redis.pool.maxIdle=300  
  14. #连接池的最大数据库连接数。设为0表示无限制,如果是jedis 2.4以后用redis.maxTotal
  15. #redis.pool.maxActive=600
  16. #控制一个pool可分配多少个jedis实例,用来替换上面的redis.maxActive,如果是jedis 2.4以后用该属性
  17. redis.pool.maxTotal=1000  
  18. #最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。
  19. redis.pool.maxWaitMillis=1000  
  20. #连接的最小空闲时间 默认1800000毫秒(30分钟)
  21. redis.pool.minEvictableIdleTimeMillis=300000  
  22. #每次释放连接的最大数目,默认3
  23. redis.pool.numTestsPerEvictionRun=1024  
  24. #逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1
  25. redis.pool.timeBetweenEvictionRunsMillis=30000  
  26. #是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个
  27. redis.pool.testOnBorrow=true  
  28. #在空闲时检查有效性, 默认false
  29. redis.pool.testWhileIdle=true  
  31. #redis集群配置
  32. # spring.redis.spool.cluster.nodes=192.168.177.128:7001,192.168.177.128:7002,192.168.177.128:7003,192.168.177.128:7004,192.168.177.128:7005,192.168.177.128:7006
  33. # spring.redis.pool.cluster.max-redirects=3
  35. #哨兵模式
  36. redis.sentinel.master.name=mymaster
  37. redis.sentinel.host1=172.16.191.102
  38. redis.sentinel.port1=26379
  39. redis.sentinel.host2=172.16.191.102
  40. redis.sentinel.port2=26380
  41. redis.sentinel.host3=172.16.191.102
  42. redis.sentinel.port3=26381

新建application.yml

  1. spring:
  2.   redis:
  3.     sentinel:
  4.       master: mymaster
  5.       nodes: 172.16.191.102:26379,172.16.191.102:26380,172.16.191.102:26381
  6. server:
  7.   port: 10003

redis配置及序列化方式

  1. @Configuration
  2. @PropertySource("classpath:config/redis.properties")
  3. public class RedisConfig2 { 
  4.     @Value("${redis.host}")
  5.     private String host;
  6.     @Value("${redis.port}")
  7.     private Integer port;
  8.     @Value("${redis.password}")
  9.     private String password;
  10.     @Value("${redis.database}")
  11.     private Integer database;
  12.     @Value("${redis.timeout}")
  13.     private Integer timeout;
  15.     @Value("${redis.pool.maxIdle}")
  16.     private Integer maxIdle;
  18.     @Value("${redis.pool.maxTotal}")
  19.     private Integer maxTotal;
  21.     @Value("${redis.pool.maxWaitMillis}")
  22.     private Integer maxWaitMillis;
  24.     @Value("${redis.pool.minEvictableIdleTimeMillis}")
  25.     private Integer minEvictableIdleTimeMillis;
  27.     @Value("${redis.pool.numTestsPerEvictionRun}")
  28.     private Integer numTestsPerEvictionRun;
  30.     @Value("${redis.pool.timeBetweenEvictionRunsMillis}")
  31.     private long timeBetweenEvictionRunsMillis;
  33.     @Value("${redis.pool.testOnBorrow}")
  34.     private boolean testOnBorrow;
  36.     @Value("${redis.pool.testWhileIdle}")
  37.     private boolean testWhileIdle;
  39.     /** * JedisPoolConfig 连接池 * @return */
  40.     @Bean
  41.     public JedisPoolConfig jedisPoolConfig() {
  42.         JedisPoolConfig jedisPoolConfig = new JedisPoolConfig();
  43.         // 最大空闲数
  44.         jedisPoolConfig.setMaxIdle(maxIdle);
  45.         // 连接池的最大数据库连接数
  46.         jedisPoolConfig.setMaxTotal(maxTotal);
  47.         // 最大建立连接等待时间
  48.         jedisPoolConfig.setMaxWaitMillis(maxWaitMillis);
  49.         // 逐出连接的最小空闲时间 默认1800000毫秒(30分钟)
  50.         jedisPoolConfig.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
  51.         // 每次逐出检查时 逐出的最大数目 如果为负数就是 : 1/abs(n), 默认3
  52.         jedisPoolConfig.setNumTestsPerEvictionRun(numTestsPerEvictionRun);
  53.         // 逐出扫描的时间间隔(毫秒) 如果为负数,则不运行逐出线程, 默认-1
  54.         jedisPoolConfig.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
  55.         // 是否在从池中取出连接前进行检验,如果检验失败,则从池中去除连接并尝试取出另一个
  56.         jedisPoolConfig.setTestOnBorrow(testOnBorrow);
  57.         // 在空闲时检查有效性, 默认false
  58.         jedisPoolConfig.setTestWhileIdle(testWhileIdle);
  59.         return jedisPoolConfig;
  60.     }
  61.     /** * 单机版配置 * @Title: JedisConnectionFactory * @param @param jedisPoolConfig * @param @return * @return JedisConnectionFactory * @autor lpl * @date 2018年2月24日 * @throws */
  62.     @Bean
  63.     public JedisConnectionFactory jedisConnectionFactory(JedisPoolConfig jedisPoolConfig){
  64.         JedisConnectionFactory jedisConnectionFactory = new JedisConnectionFactory(jedisPoolConfig);
  65.         jedisConnectionFactory.setUsePool(true);
  66.         //连接池
  67.         jedisConnectionFactory.setPoolConfig(jedisPoolConfig);
  68.         //IP地址
  69.         jedisConnectionFactory.setHostName(host);
  70.         //端口号
  71.         jedisConnectionFactory.setPort(port);
  72.         //如果Redis设置有密码
  73.         jedisConnectionFactory.setPassword(password);
  74.         // 设置数据库索引号
  75.         jedisConnectionFactory.setDatabase(database);
  76.         //客户端超时时间单位是毫秒
  77.         jedisConnectionFactory.setTimeout(timeout);
  78.         return jedisConnectionFactory;
  79.     }
  81.     /** * 实例化 RedisTemplate 对象 * * @return */
  82.     @Bean
  83.     public RedisTemplate<String, Object> functionDomainRedisTemplate(RedisConnectionFactory redisConnectionFactory) {
  84.         RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
  85.         initDomainRedisTemplate(redisTemplate, redisConnectionFactory);
  86.         return redisTemplate;
  87.     }
  88.     /** * 设置数据存入 redis 的序列化方式,并开启事务 * * @param redisTemplate * @param factory */
  89.     private void initDomainRedisTemplate(RedisTemplate<String, Object> redisTemplate, RedisConnectionFactory factory) {
  90.         //如果不配置Serializer，那么存储的时候缺省使用String，如果用User类型存储，那么会提示错误User can't cast to String！
  91.         redisTemplate.setKeySerializer(new StringRedisSerializer());
  92.         redisTemplate.setHashKeySerializer(new StringRedisSerializer());
  94.         // GenericJackson2JsonRedisSerializer序列化方式
  95.         //redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer());
  96.         //redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());
  98.         // Jackson2JsonRedisSerializer序列化方式
  99.         Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
  100.         ObjectMapper objectMapper = new ObjectMapper();
  101.         objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
  102.         objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
  104.         jackson2JsonRedisSerializer.setObjectMapper(objectMapper);
  105.         //set value serializer
  106.         redisTemplate.setDefaultSerializer(jackson2JsonRedisSerializer);
  107.         // 开启事务
  108.         redisTemplate.setEnableTransactionSupport(true);
  109.         redisTemplate.setConnectionFactory(factory);
  110.         redisTemplate.afterPropertiesSet();
  111.     }
  112. }

增删改查

编写crud文件，由于我封装了redis得增删改查，此处仅需要简单的继承即可

  1. @Repository(value = "redisRepository")
  2. public class RedisRepository extends AbstractSpringRedisCacheEnhance { 
  4.     @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection")
  5.     @Autowired
  6.     RedisTemplate<String, Object> redisTemplate;
  8.     @Override
  9.     public StringRedisTemplate getStringRedisTemplate() {
  10.         return null;
  11.     }
  13.     @Override
  14.     public RedisTemplate<String, Object> getRedisTemplate() {
  15.         return redisTemplate;
  16.     }
  17. }

至此，springboot集成redis哨兵模式已经完成。

总结

springboot集成redis哨兵，我也没有找到更全面的资料，上述整合方式也是我摸索而出，

反正效果已经有了，至于其理论仍需要后续研究更新此博客。

源码

springboot-redis-sentinel

发表评论

表情：
评论列表 （有 0 条评论，299人围观）

还没有评论，来说两句吧...

相关阅读