RocketMQ Java 客戶端實現


  本章介紹使用 Java 實現RocketMQ 的客戶端、 以及各種消息的方式的實現。

本章實現了以下幾種消息的實現方式:

一:普通消息

  普通的消息分為三種:

  1> 可靠的同步消息

    可靠的同步傳輸用於廣泛的場景,如重要通知信息,短信通知,短信營銷系統等。

  2> 可靠的異步消息

    異步傳輸通常用於響應時間敏感的業務場景。

  3> 單向傳輸消息

    單向傳輸用於要求中等可靠性的情況,如日志收集。

二:順序消費

  RocketMQ使用FIFO順序提供有序消息

三:廣播消息

  廣播正在向主題的所有訂閱者發送消息。 如果您希望所有訂閱者接收有關主題的消息,廣播是一個不錯的選擇。

四:定時消息

  定時的消息與正常消息不同,因為它們將在以后提供的時間內不會被傳送。

五:事務消息

  事務消息為了解決分布式事務最終一致性。

應為以上五中消息類型的實現代碼比較多、不方便在此處貼出。如有感興趣的同學可以到如下地址查看。

git: https://github.com/yuelicn/rocketmq-example

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM