springboot+redistemplate 集群配置

redisConfig 配置类


package com.zhouzhou.springredistemplatedemo.controller;import io.lettuce.core.cluster.ClusterClientOptions;
import io.lettuce.core.cluster.ClusterTopologyRefreshOptions;
import org.springframework.boot.autoconfigure.data.redis.RedisProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisClusterConfiguration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.connection.RedisPassword;
import org.springframework.data.redis.connection.lettuce.LettuceClientConfiguration;
import org.springframework.data.redis.connection.lettuce.LettuceConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;import javax.annotation.Resource;
import java.time.Duration;@Configuration
public class RedisConfig {@Resourceprivate RedisProperties redisProperties;/*** 对象 redistemplate** @param factory* @return*/@Bean(name = "redisTemplate")public RedisTemplate<String, Student> redisTemplate(RedisConnectionFactory factory) {RedisTemplate<String, Student> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(factory); // 设置工厂redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer()); // 设置 value 为jackson序列化redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer()); // 设置 hashvalue 为jackson序列化// redisTemplate.afterPropertiesSet(); //非spring注入，需要加上这一句return redisTemplate;}/*** 字符串 redistemplate** @param factory* @return*/@Bean(name = "stringRedisTemplate")public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory factory) {StringRedisTemplate redisTemplate = new StringRedisTemplate(factory);redisTemplate.setConnectionFactory(factory); // 设置工厂redisTemplate.setKeySerializer(new StringRedisSerializer());redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer()); // 设置 value 为jackson序列化redisTemplate.setHashKeySerializer(new StringRedisSerializer());redisTemplate.setHashValueSerializer(new GenericJackson2JsonRedisSerializer()); // 设置 hashvalue 为jackson序列化// redisTemplate.afterPropertiesSet(); //非spring注入，需要加上这一句return redisTemplate;}/*** 集群才需要配置,单机配置会报错* @return*/@Beanpublic RedisConnectionFactory redisConnectionFactory() {RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration(redisProperties.getCluster().getNodes());redisClusterConfiguration.setPassword(RedisPassword.of(redisProperties.getPassword()));//开始自适应集群拓扑刷新ClusterTopologyRefreshOptions clusterTopologyRefreshOptions = ClusterTopologyRefreshOptions.builder().enableAdaptiveRefreshTrigger(ClusterTopologyRefreshOptions.RefreshTrigger.MOVED_REDIRECT,ClusterTopologyRefreshOptions.RefreshTrigger.PERSISTENT_RECONNECTS,ClusterTopologyRefreshOptions.RefreshTrigger.ASK_REDIRECT).adaptiveRefreshTriggersTimeout(Duration.ofSeconds(30)).build();ClusterClientOptions clusterClientOptions = ClusterClientOptions.builder().validateClusterNodeMembership(false).topologyRefreshOptions(clusterTopologyRefreshOptions).build();LettuceClientConfiguration lettuceClientConfiguration = LettuceClientConfiguration.builder().clientOptions(clusterClientOptions).build();return new LettuceConnectionFactory(redisClusterConfiguration, lettuceClientConfiguration);}
}

springboot+redistemplate 集群配置相关推荐

【SpringBoot】SpringBoot + Redis集群配置(项目记录)
开发过程中首次使用了redis,也是一点一点边学边开发,期间遇到了一些坑所以做下记录防止以后忘记. 首先代码里只用到了单机版的redis,但因为后续数据量的问题改成了集群版,这里记录集群版的基本配置, ...
springBoot整合redis集群配置
最近发现这篇博客阅读量比较大,今天特意抽空创建了一个可运行的开源项目. 项目的代码和之前的博客内容相比,做了些优化,请大家参考项目源码. 开源项目源码: springboot-redis-cluste ...
springBoot整合redis单节点、redis哨兵、redis集群配置及redisClient区别
springBoot整合redis单节点.redis哨兵.redis集群配置,redisClient jedis lettuce 区别? 1.springboot 整合redis单机模式: sprin ...
基于redis的cas集群配置(转)
1.cas ticket统一存储做cas集群首先需要将ticket拿出来,做统一存储,以便每个节点访问到的数据一致.官方提供基于memcached的方案,由于项目需要,需要做计入redis,根据官方 ...
Redis整合springboot实现集群模式
整体结构 Redis.config package com.cc.springredis.config;import com.cc.springredis.RedisUtil; import org. ...
windows版本下的 redis 集群配置
windows下的redis配置 https://www.cnblogs.com/thirteen-zxh/p/9187875.html ( 集群后篇) https://www.cnblogs.com ...
分布式与微服务系列（三）、SpringBoot+Zookeeper集群+Nginx反向代理+Dubbo分布式托管（提供者、消费者）
SpringBoot+Zookeeper集群+Nginx反向代理+Dubbo分布式托管(提供者.消费者) 一.软件架构和微服务需求 1.1.微服务需求 1.2.框架选择 1.3.集群分布(下面为此图实 ...
SpringCloud实现Redis集群配置
在配置文件中添加以下 spring:redis:cluster:# 各 Redis 节点信息nodes: 密码# 执行命令超时时间command-timeout: 15000# 重试次数max-att ...
Hadoop集群配置（最全面总结）
Hadoop集群配置(最全面总结) 通常,集群里的一台机器被指定为 NameNode,另一台不同的机器被指定为JobTracker.这些机器是masters.余下的机器即作为DataNode也作为Ta ...

springboot+redistemplate 集群配置

redisConfig 配置类

springboot+redistemplate 集群配置相关推荐

最新文章

热门文章