理论部分在https://www.jianshu.com/p/453c6e7ff81c中的 “三、事务消息”。下面从代码层面看一下rockemq的事务消息 一、事务消费端。 　　从代码中看到跟其他 ...

参考： https://blog.csdn.net/zhaoming19870124/article/details/90900808 https://blog.csdn.net/hosaos/a ...

　　看了https://www.jianshu.com/p/453c6e7ff81c这篇博客，得出顺序消费的结论。“要实现严格的顺序消息，简单且可行的办法就是：保证生产者 - MQServer - 消费者是一对一的关系”。 我们下面通过几个实例来学习RocketMQ的顺序消费。 一、单节点 ...

一、准备环境 1.系统：Centos7.3（无硬性要求） 2. jdk：1.8 3.maven：3.5（无硬性要求） 4.git 5.rocketmq 4.2 二、环境部署 1.jdk1.8以及maven可以在另一篇文章查看【http://www.cnblogs.com ...

参考： https://blog.csdn.net/u010277958/article/details/88647281 https://blog.csdn.net/u010634288/art ...

Rocketmq 消费者默认是集群的方式消费的，消费者还可以用广播的模式进行消费。广播模式消费就是所有订阅同一个主题的消费者都会收到消息。代码实现上其实很简单，就是在消费端添加 就可以了。我们看实验步骤： 一、启动ConsumerBroadCastMember1 二、启动 ...

了解RocketMQ的都知道，它会保存所有的消息到本地文件。这个文件就是 MappedFile,每一个文件对应一个MappedFile.默认情况下大小位1g。 在MessageStoreConfig中的mapedFileSizeCommitLog设置，当然一半情况下是通过配置文件来设置的。文件路 ...

GitHub地址：https://github.com/apache/rocketmq/tree/master/docs/cn Gitee(速度更快)：https://gitee.com/apache/rocketmq/tree/master/docs/cn#apache-rocketmq ...