RocketMQ系列

一分耕耘一分收获 前言 今天又到了最幸福的时刻，下了班躺床上就是玩。这个时候下铺老黑接了一个电话说：“行行行，那你先给我发几个设计图看一下吧。” 我：“老黑，啥设计图啊，你现在弄啥…

可以播放背景音乐哦~~~~ 搭建RocketMQ集群 根据之前的了解，我们已经知道了RocketMQ可以单机部署，支持集群部署。 RocketMQ 支持以下集中部署方式 1.单Ma…

批量发送消息能显著提高传递小消息的性能。限制是这些批量消息应该有相同的topic，相同的waitStoreMsgOK，而且不能是延时消息。此外，这一批消息的总大小不应超过4MB。 …

在大多数情况下，TAG是一个简单而有用的设计，其可以来选择您想要的消息。例如： DefaultMQPushConsumer consumer = ne…

事务消息共有三种状态，提交状态、回滚状态、中间状态： TransactionStatus.CommitTransaction: 提交事务，它允许消费者消费此消息。 Transact…

之前我们已经学习了RocketMQ是由四个部分组成的。这篇文章更加深入的来看看这个四个部分。 NameServer 接下来，我们来看 NameServer 的相关内容，我们都知道 …

上一篇文章RocketMQ架构设计之启动过程解析 分析了 NameServer, Broker, Producer, Consumer 四个部分的启动过程, 这边文章我们分析 消息…

最近有点浮躁，玩了一个周, 没有写文章了。今天继续搞RocketMQ的事务实现。 往期文章 RocketMQ搭建 RocketMQ架构设计之启动 RocketMQ架构设计之消息 分…

本文大约需要三分钟的时间，点开上面的歌曲，边听边看。 正文开始： 常用的绝大多数消息队列,如 RocketMQ、RabbitMQ 等在消息传输上都只能保证至少传输成功一次(At l…

在 RocketMQ架构设计之消息 这篇文章中, 我们学习了 消息发送到消费 的整体流程。这篇文章，我们一起来看看 MappedFile 的实现细节. 引言 我们都知道的是 Roc…