如何在Redis发布订阅中传递结构化JSON消息并高效反序列化

胖磊酱_7952

胖磊酱_7952

2026-10-04

248人浏览

原创

应使用message.getbody()配合utf-8解码获取json字符串,而非message.tostring();必须统一发送端与监听端的redisserializer.json(),并确保userdto含public无参构造器和getter/setter。

如何在redis发布订阅中传递结构化json消息并高效反序列化

直接用 RedisSerializer.json() 配合 MessageListener 就能传 JSON,但反序列化失败、类型丢失、空指针或乱码,基本都是序列化器没对齐或消息体没正确解包导致的。

为什么 message.toString() 会丢数据或报错

Redis 的 Message 对象里,真实内容在 message.getBody() 字节数组中;toString() 是调用字节数组的默认实现(类似 [B@1a2b3c),不是 JSON 字符串。硬转会导致解析失败或空对象。

  • 错误写法:new String(message.toString()) 或 JSONObject.parseObject(message.toString(), UserDTO.class)
  • 正确做法:先用 new String(message.getBody(), StandardCharsets.UTF_8) 提取原始 JSON 字符串
  • 如果用了 RedisSerializer.json(),且发送端是 redisTemplate.convertAndSend(),那 getBody() 就是标准 UTF-8 JSON 字节流,无需额外解码

RedisSerializer.json() 和 RedisSerializer.java() 怎么选

传 JSON 就必须用 RedisSerializer.json(),否则接收端拿到的是 JDK 序列化二进制,根本不是可读 JSON,JSON.parseObject() 会直接抛 JSONException 或乱码。

Feishu calendar sync, local ics to json data for AI agent
Feishu calendar sync, local ics to json data for AI agent

将ICS日历文件转为JSON格式,用于飞书日历导入导出及数据集成。

下载
  • RedisSerializer.json():依赖 Fastjson2 / Jackson,序列化后是紧凑可读字符串,跨语言友好,推荐用于结构化消息
  • RedisSerializer.java():JDK 原生序列化,要求类实现 Serializable,体积大、不兼容其他语言、有安全风险,仅适合纯 Java 内部临时通信
  • 发送端和监听端的 serializer 必须一致——container.addMessageListener(...) 里设的 setSerializer() 要和 redisTemplate 的序列化器匹配

反序列化时如何避免 ClassCastException 或 null 字段

Spring Data Redis 的 MessageListenerAdapter 在启用 RedisSerializer.json() 后,其实已能自动把 JSON 反序列化为指定类型(前提是配置了泛型信息)。手动解析反而容易出错。

  • 推荐方式:让 MessageListenerAdapter 直接注入目标类型参数,例如 onMessage(UserDTO userDTO)(方法签名带具体类型)
  • 不推荐方式:在 onMessage(Message, byte[]) 里手动 JSON.parseObject(...) ——容易漏处理空值、时区、枚举等细节
  • 若必须手动解析,用 JSON.parseObject(new String(msg.getBody()), UserDTO.class),别用 message.toString()
  • 注意:Fastjson2 默认不支持无参构造器缺失或字段非 public 的类,反序列化前确认 UserDTO 有 public 无参构造 + getter/setter

多个监听器混用不同序列化器会怎样

可以,但每个 MessageListenerAdapter 必须单独设置 setSerializer(),且不能共享同一个 adapter 实例。否则后注册的会覆盖前者的序列化行为。

  • 错误示范:两个 listener 共用一个 MessageListenerAdapter 实例,只调一次 setSerializer()
  • 正确做法:像知识库示例那样,为 listenerAdapter 和 listenerAdapter2 分别 new 并各自 setSerializer()
  • 后果:混用时,某监听器收到非预期格式(比如 JSON 字节被当 JDK 二进制解析),大概率抛 StreamCorruptedException 或返回 null 对象

最易忽略的一点:RedisSerializer.json() 默认使用 Fastjson2,但 Spring Boot 3+ 默认可能用 Jackson;如果项目里没显式声明 Fastjson2 依赖,又没配 Jackson 的 ObjectMapper,convertAndSend() 可能静默失败或序列化成空对象——务必检查实际序列化输出是否为合法 JSON 字符串。

相关文章

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

redis js json

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
js正则表达式
js正则表达式

php中文网为大家提供各种js正则表达式语法大全以及各种js正则表达式使用的方法,还有更多js正则表达式的相关文章、相关下载、相关课程,供大家免费下载体验。

2023.06.20

3976

8

js获取当前时间
js获取当前时间

JS全称JavaScript,是一种具有函数优先的轻量级,解释型或即时编译型的编程语言;它是一种属于网络的高级脚本语言,主要用于Web,常用来为网页添加各式各样的动态功能。js怎么获取当前时间呢?php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

2023.07.28

1255

5

js 字符串转数组
js 字符串转数组

js字符串转数组的方法:1、使用“split()”方法;2、使用“Array.from()”方法;3、使用for循环遍历;4、使用“Array.split()”方法。本专题为大家提供js字符串转数组的相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.03

1618

5

js是什么意思
js是什么意思

JS是JavaScript的缩写,它是一种广泛应用于网页开发的脚本语言。JavaScript是一种解释性的、基于对象和事件驱动的编程语言,通常用于为网页增加交互性和动态性。它可以在网页上实现复杂的功能和效果,如表单验证、页面元素操作、动画效果、数据交互等。

2023.08.17

9483

11

js删除节点的方法
js删除节点的方法

js删除节点的方法有:1、removeChild()方法,用于从父节点中移除指定的子节点,它需要两个参数,第一个参数是要删除的子节点,第二个参数是父节点;2、parentNode.removeChild()方法,可以直接通过父节点调用来删除子节点;3、remove()方法,可以直接删除节点,而无需指定父节点;4、innerHTML属性,用于删除节点的内容。

2023.09.01

880

4

js截取字符串的方法
js截取字符串的方法

js截取字符串的方法有substring()方法、substr()方法、slice()方法、split()方法和slice()方法。本专题为大家提供字符串相关的文章、下载、课程内容,供大家免费下载体验。

2023.09.04

2404

5

Js中concat和push的区别
Js中concat和push的区别

Js中concat和push的区别:1、concat用于将两个或多个数组合并成一个新数组,并返回这个新数组,而push用于向数组的末尾添加一个或多个元素,并返回修改后的数组的新长度;2、concat不会修改原始数组,是创建新的数组,而push会修改原数组,将新元素添加到原数组的末尾等等。本专题为大家提供concat和push相关的文章、下载、课程内容,供大家免费下载体验。

2023.09.14

1469

5

js截取字符串的方法介绍
js截取字符串的方法介绍

JavaScript字符串截取方法,包括substring、slice、substr、charAt和split方法。这些方法可以根据具体需求,灵活地截取字符串的不同部分。在实际开发中,根据具体情况选择合适的方法进行字符串截取,能够提高代码的效率和可读性 。

2023.09.21

4049

3

js生成随机数方法
js生成随机数方法

JavaScript生成随机数的方法,包括使用Math.random()方法生成指定范围内的随机整数、生成随机字符串和生成随机颜色。根据具体需求,可以选择适合的方法来生成随机数,以实现各种功能 。

2023.09.25

2295

5

热门下载

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

精品课程

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

共0课时 | 0人学习

进程与SOCKET
进程与SOCKET

共6课时 | 0.5万人学习