redis spring redisTemplate 管道 批量修改数据后,读取数据 反序列化失败

图片说明

redis 配置 Jackson2JsonRedisSerializer序列化

public RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        // 配置连接工厂
        template.setConnectionFactory(factory);
        //使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值(默认使用JDK的序列化方式)
        Jackson2JsonRedisSerializer jacksonSeial = new Jackson2JsonRedisSerializer(Object.class);
        ObjectMapper om = new ObjectMapper();
        // 指定要序列化的域,field,get和set,以及修饰符范围,ANY是都有包括private和public
        om.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        // 指定序列化输入的类型,类必须是非final修饰的,final修饰的类,比如String,Integer等会跑出异常
        om.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);
        jacksonSeial.setObjectMapper(om);
        // 值采用json序列化
        template.setValueSerializer(jacksonSeial);
        //使用StringRedisSerializer来序列化和反序列化redis的key值
        template.setKeySerializer(new StringRedisSerializer());
        // 设置hash key 和value序列化模式
        template.setHashKeySerializer(new StringRedisSerializer());
        template.setHashValueSerializer(jacksonSeial);
        template.afterPropertiesSet();
        return template;
    }

redis Pipelined批量修改数据

redisTemplate.executePipelined(new RedisCallback<Object>() {
            @Override
            public Object doInRedis(RedisConnection redisConnection) throws DataAccessException {

                try {
                    for (Cart cart : cartList){
                        cart.setSelected(selected);
                        redisConnection.hSet(Key.getBytes(), (""+cart.getCommodityId()).getBytes(), objectMapper.writeValueAsString(cart).getBytes());
                    }
                }catch (Exception e){
                    e.printStackTrace();
                }

                return null;
            }
        },redisTemplate.getValueSerializer());

读取数据的时候报错

HashOperations<String,String,Cart> hashOperations = redisTemplate.opsForHash();
        return hashOperations.values(KEY_PREFIX + userId);

https://blog.csdn.net/shuangyueliao/article/details/95120342