rocketmq源码分析2-broker的消息接收
broker消息接收，假设接收的是一个普通消息(即没有事务)，此处分析也只分析master上动作逻辑，不涉及ha。 1. 如何找到消息接收处理入口 可以通过broker的监听端口10911顺藤摸瓜式的找到 NettyClientConfig.setListenPort--> ...
原文：RocketMQ源码详解 | Broker篇 · 其四：事务消息、批量消息、延迟消息
概述 在上文中，我们讨论了消费者对于消息拉取的实现，对于 RocketMQ 这个黑盒的心脏部分，我们顺着消息的发送流程已经将其剖析了大半部分。本章我们不妨乘胜追击，接着讨论各种不同的消息的原理与实现。 事务消息 概念 RocketMQ 中的事务消息功能，实际上是 分布式事务中的本地事务表 的实现，只不过，在这里用消息中间件来代替了数据库，同时也帮我们做好了回查的操作。 在这点上，RocketMQ ...
2021-11-19 17:28 0 273 推荐指数：
相关推荐
RocketMQ源码 — 十一、 RocketMQ事务消息
分布式事务是一个复杂的问题，rmq实现了事务的最终一致性，rmq保证本地事务成功消息一定会发送成功并被成功消费，如果本地事务失败了，消息不会被发送。 rmq事务消息的实现过程为： producer发送half消息 broker确认half消息，并通知producer，表示消息已经成功 ...
RocketMQ定时（延迟）消息
RocketMQ 不支持任意时间自定义的延迟消息，仅支持内置预设值的延迟时间间隔的延迟消息。 预设值的延迟时间间隔为：1s、 5s、 10s、 30s、 1m、 2m、 3m、 4m、 5m、 6m、 7m、 8m、 9m、 10m、 20m、 30m、 1h、 2h 延时消息 ...
RocketMQ（二）事务消息&顺序消息
一、事务消息的由来 1、案例 引用官方的购物案例： 小明购买一个100元的东西，账户扣款100元的同时需要保证在下游的积分系统给小明这个账号增加100积分。账号系统和积分系统是两个独立是系统，一个要减少100元，一个要增加100积分。如下图： 2、问题 账号服务扣款成功 ...
RocketMQ源码详解 | Producer篇 · 其一：Start，然后 Send 一条消息
概述 Start DefaultMQProducer#start 首先进入 start 方法，可以看出主要的功能实现在于 defaultMQProducerIm ...
RocketMQ源码详解 | Consumer篇 · 其一：消息的 Pull 和 Push
才可见？ 消息如何到达消费者手里？ 是由 Broker push 过去吗？还是由消费者自己 pull？ ...
RocketMQ源码详解 | Producer篇 · 其二：消息组成、发送链路
概述 在上一节 RocketMQ源码详解 | Producer篇 · 其一：Start，然后 Send 一条消息 中，我们了解了 Producer 在发送消息的流程。这次我们再来具体下看消息的构成与其发送的链路 Message 在 RocketMQ 的使用中，Message 类是在发送 ...
RocketMQ中Broker的消息存储源码分析
Broker和前面分析过的NameServer类似，需要在Pipeline责任链上通过NettyServerHandler来处理消息 【RocketMQ中NameServer的启动源码分析】 实际上就通过前面提到的SendMessageProcessor ...