理論部分在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 ...