本章介紹使用 Java 實現RocketMQ 的客戶端、 以及各種消息的方式的實現。
本章實現了以下幾種消息的實現方式:
一:普通消息
普通的消息分為三種:
1> 可靠的同步消息
可靠的同步傳輸用於廣泛的場景,如重要通知信息,短信通知,短信營銷系統等。
2> 可靠的異步消息
異步傳輸通常用於響應時間敏感的業務場景。
3> 單向傳輸消息
單向傳輸用於要求中等可靠性的情況,如日志收集。
二:順序消費
RocketMQ使用FIFO順序提供有序消息
三:廣播消息
廣播正在向主題的所有訂閱者發送消息。 如果您希望所有訂閱者接收有關主題的消息,廣播是一個不錯的選擇。
四:定時消息
定時的消息與正常消息不同,因為它們將在以后提供的時間內不會被傳送。
五:事務消息
事務消息為了解決分布式事務最終一致性。
應為以上五中消息類型的實現代碼比較多、不方便在此處貼出。如有感興趣的同學可以到如下地址查看。
git: https://github.com/yuelicn/rocketmq-example