Lianxun_Java.git

old mode 100644 new mode 100755

			@@ -1,7 +1,8 @@
			package com.java110.core.cache;

			import org.springframework.beans.factory.annotation.Autowired;
			import org.springframework.boot.autoconfigure.condition.ConditionalOnBean;
			import org.springframework.beans.factory.annotation.Qualifier;
			import org.springframework.beans.factory.annotation.Value;
			import org.springframework.cache.CacheManager;
			import org.springframework.cache.annotation.CachingConfigurerSupport;
			import org.springframework.cache.annotation.EnableCaching;
			@@ -11,14 +12,23 @@
			import org.springframework.data.redis.cache.RedisCacheManager;
			import org.springframework.data.redis.connection.RedisConnectionFactory;
			import org.springframework.data.redis.core.RedisTemplate;
			import org.springframework.data.redis.serializer.GenericJackson2JsonRedisSerializer;
			import org.springframework.data.redis.serializer.RedisSerializationContext;
			import org.springframework.data.redis.serializer.*;

			import org.springframework.util.StringUtils;
			import redis.clients.jedis.HostAndPort;
			import redis.clients.jedis.JedisCluster;
			import redis.clients.jedis.JedisPool;
			import redis.clients.jedis.JedisPoolConfig;

			import java.time.Duration;
			import java.util.HashSet;
			import java.util.Set;

			/**
			* Created by wuxw on 2017/7/23.
			*/
			@Configuration
			@EnableCaching //开启缓存，默认是rendis缓存，继承CachingConfigurerSupport ，直接重写里面的方法
			@ConditionalOnBean(Java110RedisCacheWriter.class)
			@EnableCaching
			public class Java110RedisConfig extends CachingConfigurerSupport {

			public final static String REDIS_EXPIRE_TIME_KEY = "#key_expire_time";
			@@ -30,12 +40,84 @@
			@Autowired
			private RedisTemplate redisTemplate;

			@Bean
			public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory factory){
			RedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();
			redisTemplate.setConnectionFactory(factory);
			redisTemplate.setKeySerializer(new StringRedisSerializer()); // key的序列化类型
			redisTemplate.setHashKeySerializer(new StringRedisSerializer());
			redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer()); // value的序列化类型
			redisTemplate.setHashValueSerializer(new JdkSerializationRedisSerializer());
			redisTemplate.afterPropertiesSet();
			return redisTemplate;
			}

			//@Bean(name = "jedisPool")
			//@Autowired
			public JedisPool jedisPool(@Qualifier("jedis.pool.config") JedisPoolConfig config,
			@Value("${jedis.pool.host}") String host,
			@Value("${jedis.pool.port}") int port,
			@Value("${jedis.pool.timeout}") int timeout,
			@Value("${jedis.pool.password}") String password) {
			//没有配置改为默认值
			if (timeout == 0) {
			timeout = 2000;
			}

			if (StringUtils.isEmpty(password)) {
			return new JedisPool(config, host, port, timeout);
			} else {
			return new JedisPool(config, host, port, timeout, password);
			}
			}


			// @Bean(name = "jedisCluster")
			// @Autowired
			public JedisCluster jedisCluster(@Qualifier("jedis.pool.config") JedisPoolConfig config,
			@Value("${jedis.pool.host}") String host,
			@Value("${jedis.pool.port}") int port,
			@Value("${jedis.pool.timeout}") int timeout,
			@Value("${jedis.pool.password}") String password) {
			//没有配置改为默认值
			if (timeout == 0) {
			timeout = 2000;
			}
			String[] hosts = host.split(",");
			Set<HostAndPort> nodes = new HashSet<>();
			String[] tmpHosts = null;
			for (String tmpHost : hosts) {
			tmpHosts = tmpHost.split(":");
			nodes.add(new HostAndPort(tmpHosts[0], Integer.parseInt(tmpHosts[1])));
			}
			JedisCluster cluster = new JedisCluster(nodes);
			return cluster;
			}

			//@Bean(name = "jedis.pool.config")
			public JedisPoolConfig jedisPoolConfig(@Value("${jedis.pool.config.maxTotal}") int maxTotal,
			@Value("${jedis.pool.config.maxIdle}") int maxIdle,
			@Value("${jedis.pool.config.maxWaitMillis}") int maxWaitMillis) {
			JedisPoolConfig config = new JedisPoolConfig();
			config.setMaxTotal(maxTotal);
			config.setMaxIdle(maxIdle);
			config.setMaxWaitMillis(maxWaitMillis);


			return config;
			}

			@Bean
			public RedisSerializer<String> redisKeySerializer(){
			return new StringRedisSerializer();
			}


			@Override
			@Bean
			public CacheManager cacheManager() {

			RedisConnectionFactory connectionFactory = redisTemplate.getConnectionFactory();
			System.out.printf("123123");
			//上面实现的缓存读写
			Java110RedisCacheWriter java110RedisCacheWriter
			= new Java110RedisCacheWriter(connectionFactory);
			@@ -46,13 +128,21 @@
			return cm;
			}

			/**
			* @return
			* @Cacheable和通过RedisTemplate之间去相互获取数据
			* @Cacheable注解存储redis缓存数据和通过RedisTemplate去获取存储的数据，由于@Cacheable默认的序列化编码存储到数据为byte类型，而RedisTemplate的默认编码为JdkSerializationRedisSerializer，所以要通过设置同一个序列化方式去解决问题；通过继承CachingConfigurerSupport并且开启@EnableCaching去设置cache的配置通过RedisCacheConfiguration.defaultCacheConfig()去设置序列化的方式RedisTemplate<String, Object>设置RedisTemplate的序列化方式
			* 设置序列化方式Jackson2JsonRedisSerializer
			*/
			@Bean
			public RedisCacheConfiguration redisCacheConfiguration() {

			RedisCacheConfiguration configuration = RedisCacheConfiguration.defaultCacheConfig();

			configuration = configuration.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer())).entryTtl(Duration.ofSeconds(30));

			configuration = configuration.serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new JdkSerializationRedisSerializer())).entryTtl(Duration.ofSeconds(30));
			return configuration;


			}


			}