理論部分在https://www.jianshu.com/p/453c6e7ff81c中的 “三、事務消息”。下面從代碼層面看一下rockemq的事務消息 一、事務消費端。 　　從代碼中看到跟其他模式的消費端沒有什么兩樣。 二、本地事務的執行器，實現 ...

broker過期文件刪除機制 RocketMQ會每隔10秒執行文件清理任務 主要是刪除commitlog和consumequeue文件 commitlog文件刪除 觸發過期文件刪除的條件： 1）達到配置的時間點 2）磁盤用了超過85% 3）手動執行 ...

　　RocketMQ作為消息中間件，經常會被用來和其他消息中間件做比較，比對rabbitmq, kafka... 但個人覺得它一直對標的，都是kafka。因為它們面對的場景往往都是超高並發，超高性能要求的場景。 　　所以，有必要深挖下其實現高性能，高並發的原因。實際上，這是非常大的話題 ...

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

RocketMQ日志 RocketMQ提供了一個日志模塊，實現自定義的Appender，目的是為了將日志發送到MQ中。 可以參考文章https://blog.csdn.net/wanbf123/article/details/77988801 在RocketMQ的client模塊中中 ...

　　看了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 ...