欢迎来到雄杰鑫电商资讯网
技术教程

使用RedisTemplate进行批量查询时，为什么返回的结果会是空值？

心靈之曲 次阅读

RedisTemplate批量查询返回空值原因及解决方案

使用Java的RedisTemplate进行Redis管道(pipeline)批量查询时，经常会遇到一个棘手的问题：即使keys集合包含有效数据，Redis中也存在对应数据，但返回结果却全是null。这是因为RedisTemplate的管道操作的特性导致的。

问题根源：

RedisTemplate的管道操作会将多个Redis命令批量发送到服务器，但不会立即返回结果。所有命令的执行结果会被缓存，直到调用executePipelined方法后，才一次性从服务器接收响应，并返回一个包含每个命令响应的列表。 因此，在RedisCallback或SessionCallback内部直接处理结果是无效的，因为此时Redis的响应尚未返回。

错误代码示例 (类似原文中的错误代码)：

以下代码片段演示了错误的处理方式，它试图在管道操作内部处理结果：

// 错误示例：在pipeline内部尝试处理结果
public  List batchGetList(Collection keys) {
    List list = new ArrayList<>();
    // ... (省略部分代码) ...
    List results = redisTemplate.executePipelined(new RedisCallback() {
        @Override
        public Object doInRedis(RedisConnection connection) throws DataAccessException {
            for (String key : keys) {
                byte[] bytes = connection.get(redisTemplate.getKeySerializer().serialize(key));
                T obj = (T) redisTemplate.getValueSerializer().deserialize(bytes); // 错误：结果尚未返回
                list.add(obj);
            }
            return null;
        }
    });
    return list;
}

正确解决方案：


正确的做法是在executePipelined之后处理结果列表。  以下代码展示了正确的处理方式：


public  List batchGetList(Collection keys) {
    if (CollectionUtil.isEmpty(keys)) {
        return new ArrayList<>();
    }

    List results = redisTemplate.executePipelined((RedisConnection connection) -> {
        RedisSerializer keySerializer = redisTemplate.getKeySerializer();
        for (String key : keys) {
            connection.get(keySerializer.serialize(key));
        }
        return null; // executePipelined需要返回null
    });

    // 在管道执行之后处理结果
    List resultList = results.stream()
            .map(r
esult -> {
                if (result != null) {
                    return (T) redisTemplate.getValueSerializer().deserialize((byte[]) result);
                } else {
                    return null; // 处理null结果
                }
            })
            .collect(Collectors.toList());

    return resultList;
}

这段代码首先执行管道操作，然后遍历results列表，使用redisTemplate.getValueSerializer()对每个byte[]结果进行反序列化。  添加了对null结果的处理，以避免NullPointerException。  确保你的RedisTemplate配置了正确的序列化器。


关键点：


    

  • 
executePipelined的返回值:  executePipelined方法返回一个包含所有命令执行结果的列表。  在lambda表达式中返回null是必要的。
    • 

  • 
结果处理位置:  结果处理必须在executePipelined调用之后进行。
    • 

  • 
序列化器:  确保RedisTemplate配置了正确的键和值序列化器，以匹配你存储在Redis中的数据类型。
    • 

  • 
空值处理:  对results列表中的null值进行处理，防止出现异常。
    • 



通过以上改进，可以有效解决RedisTemplate管道批量查询返回空值的问题。  记住，管道操作的效率提升来自于批量执行，结果处理必须在批量操作完成之后进行。






            
 错误代码 为什么 是在 多个 这段 redis red NULL access 数据类型 发送到 会将 中也 Lambda 序列化 遍历 来自于  
 
          
        
      
      

        
           

            
          

                    

            
          

           

      

      

        

          

            
相关文章

          

                    

            
          

                    

            
          

                    

            
          

                    

            
          

                    

            
          

                    

            
          

           

      

    
    

  


 




  

  
  

    

      

        
           

            

              

                
              

              
            

                      

           

      

      
按ESC键退出。