本篇内容主要讲解“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) { Map source = 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=true
spring.redis.cluster.connectionTimeout=60000 spring.redis.cluster.soTimeout=2000 spring.redis.cluster.maxAttempts=5 到此，相信大家对“springboot redis cluster集群的配置方法”有了更深的了解，不妨来实际操作一番吧！这里是创新互联网站，更多相关内容可以进入相关频道进行查询，关注我们，继续学习！
