联讯物业系统后台
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Your Name
2023-07-19 2b2a4cd535b047bed2fc182985a2895f3c8f7c76 
 java110-core/src/main/java/com/java110/core/cache/Java110RedisConfig.java

old mode 100644
new mode 100755

@@ -1,7 +1,13 @@


package com.java110.core.cache;




import com.fasterxml.jackson.annotation.JsonAutoDetect;


import com.fasterxml.jackson.annotation.PropertyAccessor;


import com.fasterxml.jackson.databind.ObjectMapper;


import com.fasterxml.jackson.databind.module.SimpleModule;


import com.fasterxml.jackson.databind.ser.std.ToStringSerializer;


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 +17,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.http.converter.json.Jackson2ObjectMapperBuilder;


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 +45,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 +133,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;






    }






}