0

0

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

霞舞

霞舞

发布时间:2025-03-16 08:16:01

|

625人浏览过

|

来源于php中文网

原创

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

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

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

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

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

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

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

// 错误示例:在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之后处理这些结果。

Clay AI
Clay AI

Clay AI 是一款可以将人物照片转换为粘土风格图像的AI工具,Clay AI:利用粘土动画让角色栩栩如生

下载

解决方案:正确处理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的序列化器进行正确的序列化和反序列化操作。

通过以上方法,可以有效解决RedisTemplatepipeline批量查询时返回值为空的问题,确保获取到正确的数据。 请根据实际数据类型选择合适的序列化器。

相关专题

更多
spring框架介绍
spring框架介绍

本专题整合了spring框架相关内容,想了解更多详细内容,请阅读专题下面的文章。

112

2025.08.06

数据类型有哪几种
数据类型有哪几种

数据类型有整型、浮点型、字符型、字符串型、布尔型、数组、结构体和枚举等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

307

2023.10.31

php数据类型
php数据类型

本专题整合了php数据类型相关内容,阅读专题下面的文章了解更多详细内容。

222

2025.10.31

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

978

2023.11.02

内存数据库有哪些
内存数据库有哪些

内存数据库有Redis、Memcached、Apache Ignite、VoltDB、TimesTen、H2 Database、Aerospike、Oracle TimesTen In-Memory Database、SAP HANA和ache Cassandra。更多关于内存数据库相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

634

2023.11.14

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

484

2024.04.02

redis怎么做缓存服务器
redis怎么做缓存服务器

redis 作为缓存服务器的答案:redis 是一款开源、高性能、分布式的键值存储,可作为缓存服务器使用。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

399

2024.04.07

redis怎么解决数据一致性
redis怎么解决数据一致性

redis 提供了两种一致性模型,以维护副本数据一致性:强一致性 (sync) 确保写操作仅在复制到所有从节点后才完成;最终一致性 (async) 则在主节点上写操作后认为已完成,牺牲一致性换取性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

392

2024.04.07

c++ 根号
c++ 根号

本专题整合了c++根号相关教程,阅读专题下面的文章了解更多详细内容。

58

2026.01.23

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
进程与SOCKET
进程与SOCKET

共6课时 | 0.4万人学习

Redis+MySQL数据库面试教程
Redis+MySQL数据库面试教程

共72课时 | 6.4万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号