Spring Boot Redis多实例配置

uyfrjk

package com.demo.common.config;　　import com.fasterxml.jackson.annotation.JsonAutoDetect;
　　import com.fasterxml.jackson.annotation.PropertyAccessor;
　　import com.fasterxml.jackson.databind.ObjectMapper;
　　import org.springframework.beans.factory.annotation.Value;
　　import org.springframework.cache.CacheManager;
　　import org.springframework.cache.annotation.EnableCaching;
　　import org.springframework.cache.interceptor.KeyGenerator;
　　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.jedis.JedisConnectionFactory;
　　import org.springframework.data.redis.core.RedisTemplate;
　　import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
　　import redis.clients.jedis.JedisPoolConfig;
　　import java.lang.reflect.Method;
　　/**
　　* Redis多实例配置
　　*/
　　@Configuration
　　@EnableCaching

　　public>　　@Value("${spring.redis.pool.max-active}")
　　private int redisPoolMaxActive;
　　@Value("${spring.redis.pool.max-idle}")
　　private int redisPoolMaxIdle;
　　@Value("${spring.redis.pool.min-idle}")
　　private int redisPoolMinIdle;
　　@Value("${spring.redis.pool.max-wait}")
　　private int redisPoolMaxWait;
　　@Bean
　　public KeyGenerator keyGenerator(){
　　return new KeyGenerator() {
　　@Override
　　public Object generate(Object target, Method method, Object... params) {
　　StringBuilder sb = new StringBuilder();
　　sb.append(target.getClass().getName());
　　sb.append(method.getName());
　　for (Object obj : params) {
　　sb.append(obj.toString());
　　}
　　return sb.toString();
　　}
　　};
　　}
　　/**
　　* 创建连接
　　* @param host
　　* @param port
　　* @param timeout
　　* @return
　　*/
　　public JedisConnectionFactory newJedisConnectionFactory(int index,String host,int port,int timeout){
　　JedisConnectionFactory factory = new JedisConnectionFactory();
　　factory.setDatabase(index);
　　factory.setHostName(host);
　　factory.setPort(port);
　　factory.setTimeout(timeout); //设置连接超时时间
　　//testOnBorrow为true时，返回的连接是经过测试可用的
　　factory.setPoolConfig(poolCofig(redisPoolMaxIdle,redisPoolMinIdle,redisPoolMaxActive,redisPoolMaxWait,true));
　　System.out.println("redis config========="+host);
　　return factory;
　　}
　　@Bean
　　public CacheManager cacheManager(RedisTemplate redisTemplate) {
　　RedisCacheManager cacheManager = new RedisCacheManager(redisTemplate);
　　// Number of seconds before expiration. Defaults to unlimited (0)
　　//cacheManager.setDefaultExpiration(10); //设置key-value超时时间
　　return cacheManager;
　　}
　　public JedisPoolConfig poolCofig(int maxIdle, int minIdle,int maxTotal,long maxWaitMillis,boolean testOnBorrow) {
　　JedisPoolConfig poolCofig = new JedisPoolConfig();
　　poolCofig.setMaxIdle(maxIdle);
　　poolCofig.setMinIdle(minIdle);
　　poolCofig.setMaxTotal(maxTotal);
　　poolCofig.setMaxWaitMillis(maxWaitMillis);
　　poolCofig.setTestOnBorrow(testOnBorrow);
　　return poolCofig;
　　}
　　public void setSerializer(RedisTemplate template) {
　　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);
　　template.setValueSerializer(jackson2JsonRedisSerializer);
　　template.setKeySerializer(new StringRedisSerializer());