首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
您找到你想要的搜索结果了吗?
是的
没有找到

RocketMQ源码详解:事务消息、批量消息、延迟消息

◆ 概述 在上文中,我们讨论了消费者对于消息拉取的实现,对于 这个黑盒的心脏部分,我们顺着消息的发送流程已经将其剖析了大半部分。本章我们不妨乘胜追击,接着讨论各种不同的消息的原理与实现。...◆ 事务消息 ◆ 概念 RocketMQ 中的事务消息功能,实际上是 分布式事务中的本地事务表 的实现,只不过,在这里用消息中间件来代替了数据库,同时也帮我们做好了回查的操作。...◆ 事务流程 客户端发送 half 消息 吐槽一下为什么要叫半消息(half message),叫 prepare 消息不是更直观吗 Broker 将 half 消息持久化 客户端根据事务执行结果,发送...,来标记可以被移除的 half 消息(op 消息的存在代表对应事务的结束) /** * 读取op消息,解析op消息,填充removeMap * * @param removeMap 要删除的半消息,key...◆ 批量消息 ◆ 概念 在消息队列中,批量消息也是一个重要的部分,将消息压缩在一起发送不仅可以减少带宽的消耗,还能节省头部占用的空间。

1.2K20
领券