消息傳遞作為基本通信機制已經在全世界成功運用。無論是人與人、機器與人還是機器與機器之間,消息傳遞一直都是唯一常用的通信方式。在雙方(或更多)之間交換消息有兩種基本機制。
- 同步消息傳遞
- 異步消息傳遞
同步消息傳遞在這種情況下使用,當消息發送者希望在某個時間范圍內收到響應,然后再進行下一個任務。基本上就是他在收到響應前一直處於“阻塞”狀態。
異步消息意味着發送者並不要求立即收到響應,而且也不會阻塞整個流程。響應可有可無,發送者總會執行剩下的任務。
上面提到的技術,當兩台計算機上的程序相互通信的時候,就廣泛使用了異步消息傳遞。隨着微服務架構的興起,很明顯我們需要使用異步消息傳遞模型來構建服務。
這一直是軟件工程中的基本問題,而且不同的人和組織機構會提出不同的方法。我將介紹在企業IT系統中廣泛使用的三種最成功的異步消息傳遞技術。
Java消息傳遞服務(Java Messaging Service (JMS))
JMS是最成功的異步消息傳遞技術之一。隨着Java在許多大型企業應用中的使用,JMS就成為了企業系統的首選。它定義了構建消息傳遞系統的API。
下面是JMS的主要特性:
- 面向Java平台的標准消息傳遞API
- 在Java或JVM語言比如Scala、Groovy中具有互用性
- 無需擔心底層協議
- 有queues和topics兩種消息傳遞模型
- 支持事務
- 能夠定義消息格式(消息頭、屬性和內容)
高級消息隊列協議(Advanced Message Queueing Protocol (AMQP))
JMS非常棒而且人們也非常樂意使用它。微軟開發了NMS(.NET消息傳遞服務)來支持他們的平台和編程語言,它效果還不錯。但是碰到了互用性的問題。兩套使用兩種不同編程語言的程序如何通過它們的異步消息傳遞機制相互通信呢。此時就需要定義一個異步消息傳遞的通用標准。JMS或者NMS都沒有標准的底層協議。它們可以在任何底層協議上運行,但是API是與編程語言綁定的。AMQP解決了這個問題,它使用了一套標准的底層協議,加入了許多其他特征來支持互用性,為現代應用豐富了消息傳遞需求。
下面是AMQP的主要特性:
- 獨立於平台的底層消息傳遞協議
- 消費者驅動消息傳遞
- 跨語言和平台的互用性
- 它是底層協議的
- 有5種交換類型direct,fanout,topic,headers,system
- 面向緩存的
- 可實現高性能
- 支持長周期消息傳遞
- 支持經典的消息隊列,循環,存儲和轉發
- 支持事務(跨消息隊列)
- 支持分布式事務(XA,X/OPEN,MS DTC)
- 使用SASL和TLS確保安全性
- 支持代理安全服務器
- 元數據可以控制消息流
- 不支持LVQ
- 客戶端和服務端對等
- 可擴展
消息隊列遙測傳輸(Message Queueing Telemetry Transport (MQTT))
現在我們已經有了面向基於Java的企業應用的JMS和面向所有其他應用需求的AMQP。為什么我們還需要第三種技術?它是專門為小設備設計的。計算性能不高的設備不能適應AMQP上的復雜操作,它們需要一種簡單而且可互用的方式進行通信。這是MQTT的基本要求,而如今,MQTT是物聯網(IOT)生態系統中主要成分之一。
下面是MQTT的主要特性:
- 面向流,內存占用低
- 為小型無聲設備之間通過低帶寬發送短消息而設計
- 不支持長周期存儲和轉發
- 不允許分段消息(很難發送長消息)
- 支持主題發布-訂閱
- 不支持事務(僅基本確認)
- 消息實際上是短暫的(短周期)
- 簡單用戶名和密碼,基於沒有足夠信息熵的安全
- 不支持安全連接
- 消息不透明
- Topic是全局的(一個全局的命名空間)
- 支持最新值隊列(Last Value Queue (LVQ) )
- 客戶端和服務端不對稱
- 不能擴展
--------------------- 本文來自 dongfengkuayue 的CSDN 博客 ,全文地址請點擊:https://blog.csdn.net/dongfengkuayue/article/details/51329110?utm_source=copy