核心代碼段

提供一個(gè)JedisConnectionFactory 根據(jù)配置來判斷 單點(diǎn) 集群 還是哨兵

@Bean @ConditionalOnMissingBean public JedisConnectionFactory jedisConnectionFactory() {JedisConnectionFactory factory = null; String[] split = node.split(',');Set<HostAndPort> nodes = new LinkedHashSet<>();for (int i = 0; i < split.length; i++) { try {String[] split1 = split[i].split(':');nodes.add(new HostAndPort(split1[0], Integer.parseInt(split1[1]))); } catch (Exception e) {throw new RuntimeException(String.format('出現(xiàn)配置錯(cuò)誤!請確認(rèn)node=[%s]是否正確', node)); }}//獲得默認(rèn)的連接池構(gòu)造器(怎么設(shè)計(jì)的，為什么不抽象出單獨(dú)類，供用戶使用呢) 有毒JedisClientConfiguration.JedisPoolingClientConfigurationBuilder jpcb =(JedisClientConfiguration.JedisPoolingClientConfigurationBuilder) JedisClientConfiguration.builder();//指定jedisPoolConifig來修改默認(rèn)的連接池構(gòu)造器（真麻煩，濫用設(shè)計(jì)模式！） ！！！！jpcb.poolConfig(jedisPoolConfig);//通過構(gòu)造器來構(gòu)造jedis客戶端配置JedisClientConfiguration jedisClientConfiguration = jpcb.build(); //如果是哨兵的模式if (!StringUtils.isEmpty(sentinel)) { logger.info('Redis use SentinelConfiguration'); RedisSentinelConfiguration redisSentinelConfiguration = new RedisSentinelConfiguration(); String[] sentinelArray = sentinel.split(','); for (String s : sentinelArray) {try { String[] split1 = s.split(':'); redisSentinelConfiguration.addSentinel(new RedisNode(split1[0], Integer.parseInt(split1[1])));} catch (Exception e) { throw new RuntimeException(String.format('出現(xiàn)配置錯(cuò)誤!請確認(rèn)node=[%s]是否正確', node));} } factory = new JedisConnectionFactory(redisSentinelConfiguration, jedisClientConfiguration); }//如果是單個(gè)節(jié)點(diǎn) 用Standalone模式else if (nodes.size() == 1) { logger.info('Redis use RedisStandaloneConfiguration'); for (HostAndPort n : nodes) {RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();if (!StringUtils.isEmpty(password)) { redisStandaloneConfiguration.setPassword(RedisPassword.of(password));}redisStandaloneConfiguration.setPort(n.getPort());redisStandaloneConfiguration.setHostName(n.getHost());factory = new JedisConnectionFactory(redisStandaloneConfiguration, jedisClientConfiguration); }}//集群配置信息實(shí)現(xiàn)else { logger.info('Redis use RedisStandaloneConfiguration'); RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration(); nodes.forEach(n -> {redisClusterConfiguration.addClusterNode(new RedisNode(n.getHost(), n.getPort())); }); if (!StringUtils.isEmpty(password)) {redisClusterConfiguration.setPassword(RedisPassword.of(password)); } redisClusterConfiguration.setMaxRedirects(maxRedirect); factory = new JedisConnectionFactory(redisClusterConfiguration, jedisClientConfiguration);}return factory; }Configration

import com.fasterxml.jackson.annotation.JsonAutoDetect;import com.fasterxml.jackson.annotation.PropertyAccessor;import com.fasterxml.jackson.databind.ObjectMapper;import org.slf4j.Logger;import org.slf4j.LoggerFactory;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Value;import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;import org.springframework.cache.Cache;import org.springframework.cache.CacheManager;import org.springframework.cache.annotation.CachingConfigurerSupport;import org.springframework.cache.annotation.EnableCaching;import org.springframework.cache.interceptor.CacheErrorHandler;import org.springframework.context.annotation.Bean;import org.springframework.context.annotation.Configuration;import org.springframework.data.redis.cache.RedisCacheManager;import org.springframework.data.redis.connection.*;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.GenericJackson2JsonRedisSerializer;import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;import org.springframework.data.redis.serializer.RedisSerializer;import org.springframework.data.redis.serializer.StringRedisSerializer;import org.springframework.util.StringUtils;import redis.clients.jedis.HostAndPort;import redis.clients.jedis.JedisPoolConfig; import java.util.LinkedHashSet;import java.util.Set; /** * @Author foxzzz * @Class SelfAdaptionRedisConfig * @Description 自適應(yīng)redis配置 * 適用于 單點(diǎn)[主從] 哨兵模式 集群模式 * @Date 2020/7/6 14:34 */ @Configuration@EnableCachingpublic class SelfAdaptionRedisConfig<K, V> extends CachingConfigurerSupport { private final static Logger logger = LoggerFactory.getLogger(SelfAdaptionRedisConfig.class); @Value('${spring.redis.node}') private String node; @Value('${spring.redis.timeout:0}') private int timeout; @Value('${spring.redis.password:}') private String password; @Value('${spring.redis.sentinel:}') private String sentinel; @Value('${spring.redis.jedis.pool.max-total:8}') private int maxTotal; @Value('${spring.redis.jedis.pool.max-idle:8}') private int maxIdle; @Value('${spring.redis.jedis.pool.min-idle:0}') private int minIdle; @Value('${spring.redis.jedis.pool.max-wait:-1}') private long maxWaitMillis; @Value('${spring.redis.jedis.pool.test-on-borrow:true}') private boolean testOnBorrow; @Value('${spring.redis.jedis.factory.max-redirects:5}') private int maxRedirect; @Autowired private JedisPoolConfig jedisPoolConfig; @Autowired private JedisConnectionFactory jedisConnectionFactory; @Bean @ConditionalOnMissingBean @Override public CacheManager cacheManager() {// 初始化緩存管理器，在這里我們可以緩存的整體過期時(shí)間什么的，我這里默認(rèn)沒有配置logger.info('初始化 -> [{}]', 'CacheManager RedisCacheManager Start');RedisCacheManager.RedisCacheManagerBuilder builder = RedisCacheManager.RedisCacheManagerBuilder.fromConnectionFactory(jedisConnectionFactory);return builder.build(); } @Bean @ConditionalOnMissingBean @Override public CacheErrorHandler errorHandler() {// 異常處理，當(dāng)Redis發(fā)生異常時(shí)，打印日志，但是程序正常走logger.info('初始化 -> [{}]', 'Redis CacheErrorHandler');CacheErrorHandler cacheErrorHandler = new CacheErrorHandler() { @Override public void handleCacheGetError(RuntimeException e, Cache cache, Object key) {logger.error('Redis occur handleCacheGetError：key -> [{}]', key, e); } @Override public void handleCachePutError(RuntimeException e, Cache cache, Object key, Object value) {logger.error('Redis occur handleCachePutError：key -> [{}]；value -> [{}]', key, value, e); } @Override public void handleCacheEvictError(RuntimeException e, Cache cache, Object key) {logger.error('Redis occur handleCacheEvictError：key -> [{}]', key, e); } @Override public void handleCacheClearError(RuntimeException e, Cache cache) {logger.error('Redis occur handleCacheClearError：', e); }};return cacheErrorHandler; } @Bean @ConditionalOnMissingBean public JedisPoolConfig jedisPoolConfig() {JedisPoolConfig config = new JedisPoolConfig();// 獲取連接時(shí)的最大等待毫秒數(shù)(如果設(shè)置為阻塞時(shí)BlockWhenExhausted),如果超時(shí)就拋異常, 小于零:阻塞不確定的時(shí)間, 默認(rèn)-1config.setMaxWaitMillis(maxWaitMillis);//最小空閑連接數(shù), 默認(rèn)0config.setMinIdle(minIdle);// 最大空閑連接數(shù), 默認(rèn)8個(gè)config.setMaxIdle(maxIdle);// 最大連接數(shù), 默認(rèn)值8個(gè)config.setMaxTotal(maxTotal);//對拿到的connection進(jìn)行validateObject校驗(yàn)config.setTestOnBorrow(testOnBorrow);return config; } // private JedisCluster getJedisCluster() {//String[] split = node.split(',');//Set<HostAndPort> nodes = new LinkedHashSet<>();//for (int i = 0; i < split.length; i++) {// try {//String[] split1 = split[i].split(':');//nodes.add(new HostAndPort(split1[0], Integer.parseInt(split1[1]))));// } catch (Exception e) {// }//}//JedisCluster jedisCluster = null;//if (StringUtils.isEmpty(password)) {// jedisCluster = new JedisCluster(nodes, 5000, 3000, 10, jedisPoolConfig);//} else {// jedisCluster = new JedisCluster(nodes, 5000, 3000, 10, password, jedisPoolConfig);//}// } @Bean @ConditionalOnMissingBean public JedisConnectionFactory jedisConnectionFactory() {JedisConnectionFactory factory = null; String[] split = node.split(',');Set<HostAndPort> nodes = new LinkedHashSet<>();for (int i = 0; i < split.length; i++) { try {String[] split1 = split[i].split(':');nodes.add(new HostAndPort(split1[0], Integer.parseInt(split1[1]))); } catch (Exception e) {throw new RuntimeException(String.format('出現(xiàn)配置錯(cuò)誤!請確認(rèn)node=[%s]是否正確', node)); }}//獲得默認(rèn)的連接池構(gòu)造器(怎么設(shè)計(jì)的，為什么不抽象出單獨(dú)類，供用戶使用呢) 有毒JedisClientConfiguration.JedisPoolingClientConfigurationBuilder jpcb =(JedisClientConfiguration.JedisPoolingClientConfigurationBuilder) JedisClientConfiguration.builder();//指定jedisPoolConifig來修改默認(rèn)的連接池構(gòu)造器（真麻煩，濫用設(shè)計(jì)模式！） ！！！！jpcb.poolConfig(jedisPoolConfig);//通過構(gòu)造器來構(gòu)造jedis客戶端配置JedisClientConfiguration jedisClientConfiguration = jpcb.build(); //如果是哨兵的模式if (!StringUtils.isEmpty(sentinel)) { logger.info('Redis use SentinelConfiguration'); RedisSentinelConfiguration redisSentinelConfiguration = new RedisSentinelConfiguration(); String[] sentinelArray = sentinel.split(','); for (String s : sentinelArray) {try { String[] split1 = s.split(':'); redisSentinelConfiguration.addSentinel(new RedisNode(split1[0], Integer.parseInt(split1[1])));} catch (Exception e) { throw new RuntimeException(String.format('出現(xiàn)配置錯(cuò)誤!請確認(rèn)node=[%s]是否正確', node));} } factory = new JedisConnectionFactory(redisSentinelConfiguration, jedisClientConfiguration); }//如果是單個(gè)節(jié)點(diǎn) 用Standalone模式else if (nodes.size() == 1) { logger.info('Redis use RedisStandaloneConfiguration'); for (HostAndPort n : nodes) {RedisStandaloneConfiguration redisStandaloneConfiguration = new RedisStandaloneConfiguration();if (!StringUtils.isEmpty(password)) { redisStandaloneConfiguration.setPassword(RedisPassword.of(password));}redisStandaloneConfiguration.setPort(n.getPort());redisStandaloneConfiguration.setHostName(n.getHost());factory = new JedisConnectionFactory(redisStandaloneConfiguration, jedisClientConfiguration); }}//集群配置信息實(shí)現(xiàn)else { logger.info('Redis use RedisStandaloneConfiguration'); RedisClusterConfiguration redisClusterConfiguration = new RedisClusterConfiguration(); nodes.forEach(n -> {redisClusterConfiguration.addClusterNode(new RedisNode(n.getHost(), n.getPort())); }); if (!StringUtils.isEmpty(password)) {redisClusterConfiguration.setPassword(RedisPassword.of(password)); } redisClusterConfiguration.setMaxRedirects(maxRedirect); factory = new JedisConnectionFactory(redisClusterConfiguration, jedisClientConfiguration);}return factory; } @Bean @ConditionalOnMissingBean public RedisTemplate<String, Object> redisTemplate(JedisConnectionFactory jedisConnectionFactory) {//設(shè)置序列化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);// 配置redisTemplateRedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();redisTemplate.setConnectionFactory(jedisConnectionFactory);RedisSerializer stringSerializer = new StringRedisSerializer();// key序列化redisTemplate.setKeySerializer(stringSerializer);// value序列化redisTemplate.setValueSerializer(new GenericJackson2JsonRedisSerializer());//redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);// Hash key序列化redisTemplate.setHashKeySerializer(stringSerializer);// Hash value序列化redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);redisTemplate.afterPropertiesSet();return redisTemplate; }}pom依賴

<dependencies><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId> <version>${springboot.version}</version></dependency><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> <scope>provided</scope></dependency><dependency> <groupId>redis.clients</groupId> <artifactId>jedis</artifactId> <version>${redis.version}</version></dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-annotations</artifactId> <scope>provided</scope></dependency><dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> <scope>provided</scope></dependency><dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-core</artifactId> <scope>provided</scope></dependency> </dependencies>配置文件

1.yml配置

1.1支持 Cluster模式 集群

node有多個(gè)redis的地址,以逗號分隔 如果redis沒有密碼直接去掉配置就可以了 yml配置

spring: redis: node: 127.0.0.1:1001,127.0.0.1:1002,127.0.0.1:1003 password: 123456

properties配置

spring.redis.node=127.0.0.1:1001,127.0.0.1:1002,127.0.0.1:1003 spring.redis.password=123456

1.2支持 Standalone模式 單點(diǎn)

node里只有一個(gè)redis地址的時(shí)候,會自動變成單點(diǎn)模式 yml配置

spring: redis: node: 127.0.0.1:1001 password: 123456

properties配置

spring.redis.node=127.0.0.1:1001spring.redis.password=123456

1.3支持 Sentinel模式 哨兵

當(dāng)配置上sentinel以后就變成了哨兵模式 多個(gè)哨兵可以以逗號分割 yml配置

spring: redis: node: 127.0.0.1:1001 sentinel:127.0.0.1:1002,127.0.0.1:1003 password: 123456

properties配置

spring.redis.node=127.0.0.1:1001spring.redis.sentinel:127.0.0.1:1002,127.0.0.1:1003spring.redis.password=123456

1.4覆蓋默認(rèn)配置

如果沒有配置這些信息,就會走默認(rèn)配置 也可以在properties或者yml覆蓋默認(rèn)配置

#最大連接數(shù), 默認(rèn)值8個(gè)spring.redis.jedis.pool.max-total=8#最大空閑連接數(shù), 默認(rèn)8個(gè)spring.redis.jedis.pool.max-idle=8#最小空閑連接數(shù), 默認(rèn)0spring.redis.jedis.pool.min-idle=0#獲取連接時(shí)的最大等待毫秒數(shù),如果超時(shí)就拋異常, 小于零:阻塞不確定的時(shí)間, 默認(rèn)-1spring.redis.jedis.pool.max-wait=-1#對拿到的connection進(jìn)行validateObject校驗(yàn)spring.redis.jedis.pool.test-on-borrow=true#集群時(shí)最大重定向個(gè)數(shù)默認(rèn)5spring.redis.jedis.factory.max-redirects=5使用

代碼使用

@Autowired private RedisTemplate<String, Object> redisTemplate;

到此這篇關(guān)于SpringBoot Redis自適應(yīng)配置的實(shí)現(xiàn)(Cluster Standalone Sentinel)的文章就介紹到這了,更多相關(guān)SpringBoot Redis自適應(yīng)配置內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)！