springboot redis cluster集群的配置方法
发表于:2025-01-28 作者:千家信息网编辑
千家信息网最后更新 2025年01月28日,本篇内容主要讲解"springboot redis cluster集群的配置方法",感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习"springboot red
千家信息网最后更新 2025年01月28日springboot redis cluster集群的配置方法
本篇内容主要讲解"springboot redis cluster集群的配置方法",感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习"springboot redis cluster集群的配置方法"吧!
上代码:
import org.springframework.beans.factory.annotation.Value; import org.springframework.cache.CacheManager; import org.springframework.cache.annotation.CachingConfigurerSupport; import org.springframework.cache.annotation.EnableCaching; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.env.MapPropertySource; import org.springframework.data.redis.cache.RedisCacheManager; import org.springframework.data.redis.connection.RedisClusterConfiguration; import org.springframework.data.redis.connection.jedis.JedisConnectionFactory; 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 com.gta.yyyf.commons.utils.SpringContextHolder;import redis.clients.jedis.JedisPoolConfig;import java.util.HashMap; import java.util.Map;@Configuration @EnableCaching public class RedisClusterConfig extends CachingConfigurerSupport { private JedisPoolConfig poolConfig(int maxIdle, int maxTotal, long maxWaitMillis, boolean testOnBorrow, boolean testOnReturn) { JedisPoolConfig jedisPoolConfig = new JedisPoolConfig(); jedisPoolConfig.setMaxIdle(maxIdle); jedisPoolConfig.setMaxTotal(maxTotal); jedisPoolConfig.setMaxWaitMillis(maxWaitMillis); jedisPoolConfig.setTestOnBorrow(testOnBorrow); jedisPoolConfig.setTestOnReturn(testOnReturn); return jedisPoolConfig; } private RedisClusterConfiguration redisCluterConfig(String clusterNodes) { Mapsource = new HashMap<>(); source.put("spring.redis.cluster.nodes", clusterNodes); return new RedisClusterConfiguration(new MapPropertySource("RedisClusterConfiguration", source)); } @Bean(name = "redisConnectionFactory") public JedisConnectionFactory redisConnectionFactory(@Value("${spring.redis.cluster.maxIdle}") int maxIdle, @Value("${spring.redis.cluster.maxTotal}") int maxTotal, @Value("${spring.redis.cluster.maxWaitMillis}") long maxWaitMillis, @Value("${spring.redis.cluster.testOnBorrow}") boolean testOnBorrow, @Value("${spring.redis.cluster.testOnReturn}") boolean testOnReturn, @Value("${spring.redis.cluster.nodes}") String clusterNodes, @Value("${spring.redis.cluster.password}") String password) { JedisConnectionFactory connectionFactory = new JedisConnectionFactory( redisCluterConfig(clusterNodes), poolConfig(maxIdle, maxTotal, maxWaitMillis, testOnBorrow, testOnReturn)); connectionFactory.setPassword(password); return connectionFactory; } @Bean(name = "stringRedisCluterTemplate") public StringRedisTemplate stringRedisTemplate() { StringRedisTemplate template = new StringRedisTemplate(); JedisConnectionFactory jedisConnectionFactory = SpringContextHolder.getBean("redisConnectionFactory"); template.setConnectionFactory(jedisConnectionFactory); return template; } @Bean("redisCluterTemplate") public RedisTemplate redisTemplate(JedisConnectionFactory factory) { RedisTemplate template = new RedisTemplate<>(); template.setConnectionFactory(factory); StringRedisSerializer keySerializer = new StringRedisSerializer(); GenericJackson2JsonRedisSerializer valueSerializer = new GenericJackson2JsonRedisSerializer(); template.setKeySerializer(keySerializer); template.setHashKeySerializer(keySerializer); template.setValueSerializer(valueSerializer); template.setHashValueSerializer(valueSerializer); template.afterPropertiesSet(); return template; } @Bean public CacheManager cacheManager(RedisTemplate redisTemplate) { RedisCacheManager manager = new RedisCacheManager(redisTemplate); manager.setDefaultExpiration(10); return manager; }}配置文件:spring.redis.cluster.nodes=127.0.0.1:6379,127.0.0.1:6380,127.0.0.1:6381,127.0.0.1:6379,127.0.0.1:6380,127.0.0.1:6381 spring.redis.cluster.timeout=2000 spring.redis.cluster.max-redirects=100 spring.redis.cluster.password=123456 spring.redis.cluster.maxIdle=200 spring.redis.cluster.maxTotal=1000 spring.redis.cluster.maxWaitMillis=2000 spring.redis.cluster.testOnBorrow=true spring.redis.cluster.testOnReturn=truespring.redis.cluster.connectionTimeout=60000 spring.redis.cluster.soTimeout=2000 spring.redis.cluster.maxAttempts=5
到此,相信大家对"springboot redis cluster集群的配置方法"有了更深的了解,不妨来实际操作一番吧!这里是网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!
方法
配置
集群
内容
学习
实用
更深
上代
兴趣
实用性
实际
操作简单
文件
更多
朋友
网站
频道
查询
数据库的安全要保护哪些东西
数据库安全各自的含义是什么
生产安全数据库录入
数据库的安全性及管理
数据库安全策略包含哪些
海淀数据库安全审计系统
建立农村房屋安全信息数据库
易用的数据库客户端支持安全管理
连接数据库失败ssl安全错误
数据库的锁怎样保障安全
滦州品牌软件开发
死亡空间2没有连接ea服务器
云自研服务器云上应用规模
北京网络安全郭庆
智能家居中的网络安全问题研究
手帐软件开发
用vb删除数据库中的数据
语音软件开发创始人
怀旧服普通服务器和pvp区别
计算机网络安全涉及哪些方面
软件开发转行可以干什么
金华比奇网络技术有限公司游戏
服务器租赁公司哪家好
战场里面不同服务器可以交易吗
税务 网络安全 规定
服务器能当家用机箱上网快吗
广州交友软件开发多少钱
宝塔服务器管理
可意网络技术有限公司
建邺区的app软件开发
navicat更新数据到数据库
计算机网络技术应用考试试题
互联网科技公司的技术优势
软件开发税率多少 小规模
关于网络安全1500字
有哪些做兼职的软件开发
前端如何调用数据库
郑州的网络安全公司
数据库按序号分组
赣州银行 软件开发