Redis发布订阅模式如何实现跨语言的消息传递?

秋杰小哥_3428

秋杰小哥_3428

2026-07-30

1117人浏览

原创

跨语言使用 redis pub/sub 可行但需手动对齐编码、序列化等细节;python 消息 java 收不到主因是 payload 解码失败或频道名不匹配;json 序列化是唯一靠谱方案;连接断开后需手动重订阅并加延时;频道命名应统一小写加下划线,慎用通配符。

redis发布订阅模式如何实现跨语言的消息传递?

跨语言使用 Redis Pub/Sub 是可行的,但必须手动对齐编码、序列化、频道命名和重订阅逻辑——Redis 本身不提供跨语言适配层,所有“兼容”都靠开发者约定。

为什么 Python 发的消息 Java 收不到?

常见错误不是连接失败,而是 payload 解码失败或频道名不匹配。Redis 只管转发原始字节流,不做任何转换。

  • SUBSCRIBE 和 PUBLISH 传输的是 raw bytes,客户端库默认行为差异极大:Python 的 redis-py 默认 decode 响应为 str(UTF-8),Go 的 go-redis 默认返回 []byte,Java 的 Lettuce 在 StringRedisTemplate 中尝试 UTF-8 解码,失败则静默丢弃
  • 中文乱码往往源于发送端用了系统默认编码(如 GBK),而接收端强制用 UTF-8 解码;或发送端 json.dumps(..., ensure_ascii=True) 把中文转成 \u4f60\u597d,接收端又没做 json.loads()
  • 频道名大小写敏感:Order.Created 和 order.created 是两个频道;Java 客户端订阅 order.created,Python 发到 Order.Created,消息就丢了

JSON 序列化是唯一靠谱的跨语言方案

Protobuf、Avro 等二进制格式要求 schema 同步,实践中极易因版本错位导致解析崩溃;而 JSON 被所有主流语言原生支持,容错性强,调试直观。

redis-tools
redis-tools

按类别查找Redis命令、检测服务器连接、监控键数量和内存占用,支持离线速查表。

下载
  • 发送前统一调用:json.dumps(obj, ensure_ascii=False)(Python)、new ObjectMapper().writeValueAsString(obj)(Java)、json.Marshal()(Go)
  • 接收后必须用对应语言的 JSON 解析器反序列化,不能直接当字符串用;例如 Java 收到字节数组,要先 new String(bytes, StandardCharsets.UTF_8) 再 ObjectMapper.readTree()
  • 避免在 JSON 中塞 base64 图片或二进制 blob——体积膨胀、解析慢、易出错;改用传递 {"image_url": "https://..."} 或 Redis key 引用

连接断开后订阅自动恢复?别信

Redis 服务器从不保存客户端订阅状态。TCP 连接断开即丢失全部 SUBSCRIBE,哪怕客户端库标着 “auto-reconnect”,也只是重建连接,不会自动 SUBSCRIBE 回去。

  • Java Lettuce 需监听 ConnectionEvents.CONNECTED 事件,手动调用 pubSubCommands.subscribe("order.created")
  • Go go-redis 的 PubSub.Listen() 返回 error 时,必须显式重连 + 重新 psubscribe 或 subscribe
  • Python redis-py 的 pubsub.listen() 在连接中断后会 raise ConnectionError,需捕获并重建 pubsub 实例、重新 subscribe()
  • 务必在重订阅前加短延时(如 100ms),避免反复断连引发雪崩式重试

频道命名和模式订阅的实际约束

通配符 PSUBSCRIBE 看似灵活,但在跨语言场景下容易埋坑——不同客户端对 pattern 匹配行为不完全一致,且 Redis 不保证 pattern 订阅的顺序和可靠性。

  • 坚持小写 + 下划线命名:用 user.registered,不用 UserRegistered 或 userRegistered
  • 避免嵌套层级过深:com.example.order.payment.confirmed 比 order.payment.confirmed 更难维护,也无实际收益
  • 慎用 PSUBSCRIBE *:全匹配会收到所有频道消息,包括运维频道(如 __sentinel__:hello),增加解析负担和误处理风险
  • 如果必须用 pattern,确保所有语言客户端都测试过相同 pattern 的匹配结果(例如 order.* 是否匹配 order.created 和 order.updated)

真正麻烦的从来不是发消息,而是让所有服务在断网、重启、部署更新后,还能同步地重新找到彼此——这需要每个客户端都把订阅当作有状态的生命周期来管理,而不是当成一次性的 setup 步骤。

相关文章

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

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

下载

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

相关专题

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

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

2023.11.02

4589

19

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

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

2023.11.14

4155

11

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

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

2024.04.02

7752

6

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

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

2024.04.07

643

6

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

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

2024.04.07

756

6

mysql和redis怎么保证双写一致性
mysql和redis怎么保证双写一致性

确保 mysql 和 redis 双写一致性的技术包括:1、事务性更新:同时更新 mysql 和 redis,保证一致性;2、主从复制:mysql 主服务器更改同步到 redis 从服务器;3、基于事件的更新:mysql 记录更改并发送到 redis等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

7742

6

redis缓存一般存些什么数据
redis缓存一般存些什么数据

redis缓存中存储的数据类型包括:字符串、哈希、列表、集合、有序集合、位图、地理空间数据和hyperloglog。这些数据类型适用于存储各种数据,从简单信息到复杂对象和地理位置。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

1160

6

redis的8种数据类型有哪些
redis的8种数据类型有哪些

redis 提供 8 种数据类型:字符串(文本、数字、二进制)、哈希(键值对)、列表(有序集合)、集合(无序唯一元素)、有序集合(按分数排序)、地理空间(地理位置)、hyperloglog(估计大数据基数)和位图(位序列存储)。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

1156

6

redis主要作用有哪些
redis主要作用有哪些

redis 的主要作用包括:1. 缓存数据,提高访问速度;2. 充当消息队列,实现消息传递;3. 存储各种数据类型,如字符串、散列和集合;4. 管理会话信息,确保可靠性和可用性;5. 限制请求速率,防止服务器超载等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

2024.04.07

6738

6

热门下载

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

精品课程

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

共0课时 | 0人学习