反序列化Spring Data Redis with Lettuce的问题

Question

@Bean
public RedisTemplate<String, Object> redisTemplate() {
    RedisTemplate<String, Object> redisTemplate = new RedisTemplate<String, Object>();
    redisTemplate.setConnectionFactory(redisConnectionFactory());
    redisTemplate.setEnableTransactionSupport(true);
    redisTemplate.setKeySerializer(new StringRedisSerializer());
    redisTemplate.sethashKeySerializer(new StringRedisSerializer);
    return redisTemplate;
}

public class ObservableRedisStateChecker implements Runnable {
    ...
    public void run() {
       try {
           Thread.sleep(3000);
           redisTemplate.opfForValue().get("validation");
           notifyObservers(true);
       } catch (Exception e) {
           noifyObservers(false);  // meaning that the Redis' state isn't fine.
       }
    ...
}

org.springframework.data.redis.serializer.SerializationException: 
Cannot deserialize; nested exception is org.springframework.core.serializer.support.SerializationFailedException: 
Failed to deserialize payload. Is the byte array a result of corresponding serialization for DefaultDeserializer?; 
nested exception is java.io.EOFException

奇怪的是，当我启动一个简单的测试应用程序，它在同一主机上运行与上述验证代码非常相同的代码时，错误发生了，而当错误发生时，测试应用程序却说没有错误。该错误只是发生在web应用程序上。
测试代码如下：

...
ExecutorService es = Executors.newCachedThreadPool()
RedisTemplate<String, Obejct> redisTemplate = ...

es.submit(new RedisValidationCheckTest(redisTemplate));
es.submit(new RedisValidationCheckTest(redisTemplate));
es.submit(new RedisValidationCheckTest(redisTemplate));
es.submit(new RedisValidationCheckTest(redisTemplate));
es.submit(new RedisValidationCheckTest(redisTemplate));
es.submit(new RedisValidationCheckTest(redisTemplate));
es.submit(new RedisValidationCheckTest(redisTemplate));
es.submit(new RedisValidationCheckTest(redisTemplate));
es.submit(new RedisValidationCheckTest(redisTemplate));
es.submit(new RedisValidationCheckTest(redisTemplate));
...

怎么了？

Answer 1

好像是连载问题。

您没有为值设置反序列化程序。所以redis使用了默认的Serializaer：JdkSerializationRedisSerializer，这一点也不好。我推荐使用Jackson或仅使用StringRedisserializer。

可能是由于网络问题，它收到一些不完整的响应，jdk反序列化器无法识别它并进行投诉。将此添加到您的配置中

Redistemplate.opfForValue（）.Get（“验证”）；

至

Redistemplate.GetConnectionFactory（）.GetConnection（）.Ping（）