讲师中心 微信公众号
AI工具推荐 视频效率加速

如何在Spring Boot中使用Redis Pipeline批量读写数据?

冬宇君_6090

冬宇君_6090

发布时间:2026-11-05 07:25:30

|

620人浏览过

|

来源于php中文网

原创

executePipelined回调必须返回null,因框架强制校验非null即抛InvalidDataAccessApiUsageException;实际结果通过方法返回的List按序获取,不可在回调中返回业务值。

如何在spring boot中使用redis pipeline批量读写数据?

executePipelined 方法必须返回 null

调用 redisTemplate.executePipelined() 时,如果回调中返回非 null 值(比如 return "done"),会触发 ClassCastException 或空指针异常,因为框架内部期望该方法返回 null 来标识“仅执行、不取结果”。实际结果是通过 pipeline 的响应列表隐式返回的。

常见错误写法:
return operations.opsForValue().get(key);
这会导致类型不匹配——pipeline 返回的是 List<object></object>,不是单个值。

  • 正确做法:在 SessionCallback 或 RedisCallback 中只做命令注册,末尾写 return null;
  • 若需获取结果,必须从 executePipelined 的返回值(List<object></object>)中按顺序提取,注意 null 值可能代表命令失败或无返回(如 set)
  • 对 StringRedisTemplate,建议用 StringRedisConnection 类型转换后再操作,避免字节编码问题

SessionCallback vs RedisCallback:选哪个?

SessionCallback 封装了 RedisOperations,支持高阶 API(如 opsForHash().hGetAll()),写法更贴近业务逻辑;RedisCallback 暴露原生 RedisConnection,能调用底层字节数组命令(如 lPop(key.getBytes())),性能略高但需手动处理序列化。

  • 读写字符串、Hash、List 等结构化数据,优先用 SessionCallback,可直接复用 redisTemplate 配置的序列化器
  • 需要精确控制 key/value 编码(比如兼容老系统二进制协议),或操作非 String 类型键(如含中文或特殊字符的 key),用 RedisCallback + StringRedisConnection
  • 不要混用:在 SessionCallback 里调用 connection.xxx() 会绕过序列化,导致乱码或反序列化失败

批量读取 Hash 数据时的坑

用 pipeline 批量读 HASH 字段(如 hGetAll)时,不能直接传入多个 key——hGetAll 本身只接受一个 hash key。想一次读多个 hash,得用循环注册多个 hGetAll 命令,每个对应一个 key。

SEO Automated Content Pipeline
SEO Automated Content Pipeline

SEO自动化内容管线技能。从竞争对手研究、关键词挖掘到文章生成与发布,全程自动化工作流。

下载

错误认知:“hMget 能批量读 field,所以 hGetAll 也能批量读多个 hash”——不对,hMget 是针对单个 hash 的多个 field,而 hGetAll 是针对单个 hash 的全部 field。

  • 正确姿势:对每个目标 hash key,调用一次 operations.opsForHash().hGetAll(key)
  • 返回的 List<object></object> 中,每个元素是 Map<byte byte></byte>(未反序列化),需手动转成 Map<string string></string>
  • 若 key 不存在,对应位置返回 null,不是空 Map,需判空

Pipeline 不保证原子性,也不同步事务

executePipelined 只是打包发送命令,不等效于 MULTI/EXEC。哪怕所有命令都进了 pipeline,中间某条失败(如 key 过期、内存满),其余命令照常执行,也不会回滚。

  • 需要原子性保障?必须显式用 redisTemplate.execute(new SessionCallback<object>() { ... })</object> 包裹 multi() 和 exec()
  • Pipeline 失败时,异常不会立即抛出,而是体现在返回 List<object></object> 的某个位置为 Exception 实例(如 RedisSystemException),需遍历检查
  • 高并发下,pipeline + 连接池配置不当(如 max-active 过小)会导致线程阻塞在 getConnection(),比单条还慢
Pipeline 的真正价值不在“能不能用”,而在“什么时候值得用”:当批量操作 QPS > 500 且网络 RT > 1ms 时,收益才明显。本地开发环境测出的 10 倍性能提升,在生产跨机房链路下可能只剩 2–3 倍——别只看 demo 里的 for 循环耗时对比。

热门AI工具

更多
豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

PixPix
PixPix Hot

PixPix是一款面向电商视觉生产的AI商品图生成工具。

Atoms
Atoms Hot

Atoms是一款AI智能体工具,第一支自动构建真实业务的 AI 团队。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

UP简历
UP简历 Hot

一款AI办公效率工具,主要用于基于AI技术的免费在线简历制作工具,适合需要提升相关任务效率的用户。

PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

讯飞智作

讯飞智作是一款AI视频创作工具,AI文本配音工具,数字人课程、营销视频制作。

创客贴AI

创客贴AI是一款AI图像与设计工具,AI辅助的智能在线设计工具。

相关专题

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

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

2831

2025.08.06

Java Spring Security 与认证授权
Java Spring Security 与认证授权

本专题系统讲解 Java Spring Security 框架在认证与授权中的应用,涵盖用户身份验证、权限控制、JWT与OAuth2实现、跨站请求伪造(CSRF)防护、会话管理与安全漏洞防范。通过实际项目案例,帮助学习者掌握如何 使用 Spring Security 实现高安全性认证与授权机制,提升 Web 应用的安全性与用户数据保护。

517

2026.01.26

pip安装使用方法
pip安装使用方法

安装步骤:1、确保Python已经正确安装在您的计算机上;2、下载“get-pip.py”脚本;3、按下Win + R键,然后输入cmd并按下Enter键来打开命令行窗口;4、在命令行窗口中,使用cd命令切换到“get-pip.py”所在的目录;5、执行安装命令;6、验证安装结果即可。大家可以访问本专题下的文章,了解pip安装使用方法的更多内容。

3390

2023.10.09

更新pip版本
更新pip版本

更新pip版本方法有使用pip自身更新、使用操作系统自带的包管理工具、使用python包管理工具、手动安装最新版本。想了解更多相关的内容,请阅读专题下面的文章。

7723

2024.12.20

pip设置清华源
pip设置清华源

设置方法:1、打开终端或命令提示符窗口;2、运行“touch ~/.pip/pip.conf”命令创建一个名为pip的配置文件;3、打开pip.conf文件,然后添加“[global];index-url = https://pypi.tuna.tsinghua.edu.cn/simple”内容,这将把pip的镜像源设置为清华大学的镜像源;4、保存并关闭文件即可。

9402

2024.12.23

python升级pip
python升级pip

本专题整合了python升级pip相关教程,阅读下面的文章了解更多详细内容。

4907

2025.07.23

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

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

4809

2023.11.02

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

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

4375

2023.11.14

DBeaver安全防护教程大全
DBeaver安全防护教程大全

DBeaver安全防护专题,围绕数据库连接安全、账号密码保护和访问权限管理展开,整理SSL/TLS加密连接、SSH隧道、数据库凭据保存及证书验证等配置方法,同时介绍敏感信息保护、远程连接风险和高权限账号使用等注意事项,帮助用户提高数据库日常管理的安全性。

0

2026.11.05

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn