Spring Redis Cache使用中的ClassCastException

    //springcache for redis

    @Bean

    public JedisConnectionFactory redisConnectionFactory(Environment env) {

        String redisHost = env.getProperty("cache.redis.host");

        int redisPort = Commons.stringToInteger(()->env.getProperty("cache.redis.port"), 6379);

        String redisPassword = env.getProperty("cache.redis.password");

        int redisDatabase = Commons.stringToInteger(()->env.getProperty("cache.redis.database"), 0);

        long redisTimeout = Commons.stringToLong(()->env.getProperty("cache.redis.timeout"), 60L);

        RedisStandaloneConfiguration redisConfig = new RedisStandaloneConfiguration(redisHost, redisPort);

        redisConfig.setPassword(redisPassword);

        redisConfig.setDatabase(redisDatabase);

        //pool

        JedisPoolConfig jedisPoolConfig=new JedisPoolConfig();

        jedisPoolConfig.setMaxIdle(100);

        jedisPoolConfig.setMinIdle(10);

        jedisPoolConfig.setMaxTotal(1000);

        jedisPoolConfig.setMaxWaitMillis(1000L);

        

        JedisClientConfiguration clientConfig = JedisClientConfiguration.builder()

                .connectTimeout(Duration.ofSeconds(redisTimeout))

                .readTimeout(Duration.ofSeconds(redisTimeout))

                .usePooling()

                .poolConfig(jedisPoolConfig)

                .build();

        return new JedisConnectionFactory(redisConfig, clientConfig);

    }

    

    @Bean

    public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory cf, GenericJackson2JsonRedisSerializer valuesRedisSerializer) {

        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();

        redisTemplate.setConnectionFactory(cf);

        redisTemplate.setKeySerializer(new StringRedisSerializer());

        redisTemplate.setValueSerializer(valuesRedisSerializer);//new GenericJackson2JsonRedisSerializer());

        redisTemplate.setHashKeySerializer(new StringRedisSerializer());

        redisTemplate.setHashValueSerializer(valuesRedisSerializer); //new GenericJackson2JsonRedisSerializer());

        return redisTemplate;

    }

    @Bean

    public RedisCacheManager cacheManager(RedisConnectionFactory connectionFactory, GenericJackson2JsonRedisSerializer valuesRedisSerializer) {

        RedisCacheConfiguration config = RedisCacheConfiguration

                .defaultCacheConfig()

                .entryTtl(Duration.ofDays(1))

                .disableCachingNullValues()

                .serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(valuesRedisSerializer));

        return RedisCacheManager.builder(connectionFactory).cacheDefaults(config).build();

    }

    

    @Bean("valuesRedisSerializer")

    public GenericJackson2JsonRedisSerializer redisSerializer(){

        JavaTimeModule jtm = new JavaTimeModule();

        jtm.addSerializer(LocalDateTime.class, new LocalDateTimeSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));

        jtm.addSerializer(LocalDate.class, new LocalDateSerializer(DateTimeFormatter.ofPattern("yyyy-MM-dd")));

        jtm.addSerializer(LocalTime.class, new LocalTimeSerializer(DateTimeFormatter.ofPattern("HH:mm:ss")));

        jtm.addDeserializer(LocalDateTime.class, new LocalDateTimeDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));

        jtm.addDeserializer(LocalDate.class, new LocalDateDeserializer(DateTimeFormatter.ofPattern("yyyy-MM-dd")));

        jtm.addDeserializer(LocalTime.class, new LocalTimeDeserializer(DateTimeFormatter.ofPattern("HH:mm:ss")));

        ObjectMapper mapper = new ObjectMapper()

                .setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY)

                .registerModule(jtm)

                .registerModule(new Jdk8Module())

                .findAndRegisterModules()

                .disable(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS);

        GenericJackson2JsonRedisSerializer j2jrs = new GenericJackson2JsonRedisSerializer(mapper);

        return j2jrs;

    }

    @Cacheable(key = "#id", unless="#result==null")

    @Override

    public Optional<BoardGroup> get(int id) {

        if (id > 0) {

            return boardGroupDao.findOne(id);

        }

        return Optional.empty();

    }

標籤：Web 開發

上一篇：大神們，幫幫我，看看這道題目吧

下一篇：如何同時使用兩個資料源？