使用管道的方式存储数据时,会直接保存字节数组,不需要用到序列化的功能
redisTemplate.executePipelined(new RedisCallback() {
@Override
public Object doInRedis(RedisConnection connection) {
keys.forEach(key -> {
connection.sAdd(key.getBytes(), "str".getBytes());
});
return null;
}
});
使用管道的方式读取数据时,如果只传入一个参数,会默认使用定义好的序列化类对结果进行反序列化操作,从而报
org.springframework.data.redis.serializer.SerializationException: Cannot deserialize; 异常。这时候只要调用管道的两个参数的重载方法,第二个参数传入空就不会再反序列化了
List> list = redisTemplate.executePipelined(new RedisCallback>>() {
@Override
public List> doInRedis(RedisConnection connection) throws DataAccessException {
connection.openPipeline();
keys.forEach(key -> {
connection.sMembers(key.getBytes());
});
return null;
}
}, null);