使用RedisTemplate和Pipeline批量查询时返回值为空的原因是什么？如何解决这一问题？

feifei123 发布于 2025-03-16 阅读（18）

使用redistemplate和pipeline批量查询时返回值为空的原因是什么？如何解决这一问题？

Spring Data Redis:  RedisTemplate与Pipeline批量查询返回值为空的解决方法

使用Spring Data Redis的RedisTemplate进行批量查询时，尤其采用pipeline模式，经常会遇到返回值为空的情况。即使确认Redis中存在对应数据，问题依旧存在。本文将分析原因并提供解决方案。

问题根源：Pipeline操作结果处理时机错误

pipeline模式下，Redis命令并非立即执行并返回结果，而是批量发送，批量接收。  错误的处理方式通常在pipeline执行过程中尝试获取结果，而此时结果尚未返回。

错误示例：在pipeline内部处理结果

以下代码片段演示了错误的处理方式：尝试在RedisCallback或SessionCallback内部直接反序列化结果。

// 错误示例：在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(keySerializer.serialize(key)); // 获取字节数组
                T value = (T) valueSerializer.deserialize(bytes); // 立即反序列化，错误！
                list.add(value); 
            }
            return null; // 返回null，pipeline结果被忽略
        }
    });
    return list; // 返回空列表
}
正确方法：在pipeline执行完毕后处理结果
executePipelined方法返回一个List，包含每个命令的执行结果。正确的做法是在executePipelined之后处理这些结果。
解决方案：正确处理Pipeline结果
以下代码展示了正确的处理方式：
public  List batchGetList(Collection keys) {
    if (CollectionUtil.isEmpty(keys)) {
        return new ArrayList<>();
    }

    RedisSerializer keySerializer = redisTemplate.getStringSerializer();
    RedisSerializer valueSerializer = redisTemplate.getValueSerializer();

    List results = redisTemplate.executePipelined((RedisConnection connection) -> {
        for (String key : keys) {
            connection.get(keySerializer.serialize(key));
        }
        return null; // 返回null，pipeline结果在results中
    });

    return results.stream()
                  .map(bytes -> valueSerializer.deserialize(bytes))
                  .collect(Collectors.toList());
}
这段代码首先执行pipeline操作，将所有get命令发送到Redis。然后，在executePipelined返回后，遍历结果列表，使用valueSerializer反序列化每个byte[]数组，最终得到正确的结果列表。
关键点总结:
  • Pipeline的本质:  批量发送命令，批量接收结果，不是逐个命令执行和返回。
  • 结果处理时机:  在executePipelined方法返回后处理结果，而不是在pipeline操作内部。
  • 序列化/反序列化: 使用RedisTemplate的序列化器进行正确的序列化和反序列化操作。
通过以上方法，可以有效解决RedisTemplate和pipeline批量查询时返回值为空的问题，确保获取到正确的数据。  请根据实际数据类型选择合适的序列化器。
以上就是使用RedisTemplate和Pipeline批量查询时返回值为空的原因是什么？如何解决这一问题？的详细内容，更多请关注资源网其它相关文章！
                
                
标签:  redis access 解决方法 red spring 数据类型 
                
                

                                

                    
相关阅读

                    
                

                            
            



















	
发表评论:

	

	
	
	
 

	
 

	
 

	
	

	

	

	

	
◎欢迎参与讨论，请在这里发表您的看法、交流您的观点。


        
        


	    	



	
最近发表
	





	
热评文章

	





	
标签列表
	






	
网站分类
	



    
    
    

        

                        
本站内容来源于互联网搬运，仅限用于小范围内传播学习，

请在下载后24小时内删除， 如果有侵权内容、

不妥之处，请第一时间联系我们删除。敬请谅解!

 E-mail：dpw1001@163.com

陕ICP备2023000927号             
Powered By Z-BlogPHP Theme By 老白编程