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


@@ -1,5 +1,10 @@


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.beans.factory.annotation.Qualifier;


import org.springframework.beans.factory.annotation.Value;


@@ -12,8 +17,8 @@


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;


@@ -60,7 +65,7 @@


    }






//    @Bean(name = "jedisCluster")


    //    @Bean(name = "jedisCluster")


//    @Autowired


    public JedisCluster jedisCluster(@Qualifier("jedis.pool.config") JedisPoolConfig config,


                                     @Value("${jedis.pool.host}") String host,


@@ -95,6 +100,11 @@


        return config;


    }




    @Bean


    public RedisSerializer<String> redisKeySerializer(){


        return new StringRedisSerializer();


    }






    @Override


    @Bean


@@ -111,14 +121,20 @@


        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;






    }