JMS 之 Active MQ 的訊息傳輸（圖文詳解）

下面小編就為大家帶來一篇JMS 之 Active MQ 的訊息傳輸(詳解)。小編覺得蠻不錯的，現在就分享給大家，也給大家做個參考。一起跟著小編過來看看吧

本文使用Active MQ5.6

#一、訊息協商器（Message Broker）

broke：訊息的交換器，就是對訊息進行管理的容器。 ActiveMQ 可以建立多個 Broker，客戶端與ActiveMQ交互，實際上都是與ActiveMQ中的Broker交互，Broker配置在${MQ_HOME}\conf\activemq.#xml。

二、連接器（Connectors）（一）、傳輸連接器（transportConnectors）

# transportConnectors 連接器：就是建立broker與訊息生產者、訊息消費者之間的互動。

傳輸連接器常用的協定：

在Active MQ中常用的連線協定：tcp、udp、nio、ssl、http、 https、vm。如果使用ssl協定需要設定證書，使用http或https需要使用httpclient來傳送接收訊息。

(1)TCP預設的協定

#tcp://hostname:port?key=value&key=value後面的參數選填

使用TCP協定的好處

有效率的：該協定連接使用了OpenWire協議，透過把訊息轉換成字節流，效能非常好

可用性：TCP是使用非常廣泛的網路協議，基本上所有的平台都支援

TCP設定範例conf/activemq.xml ：

    <transportConnectors>
      <!--activemq 的默认连接 tcp-->
      <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
    </transportConnectors>

（2） 、NIO

a、NIO協定和TCP協定類似，但NIO更著重於底層的存取操作。它允許開發人員對相同資源可有 更多的client呼叫和服務端有更多的負載。

b、適合使用NIO協定的場景：

可能有大量的Client去連結到Broker上一般情況下，大量的Client去連結Broker是被作業系統的執行緒數所限制的。因此， NIO的實作比TCP需要更少的執行緒去運行，所以建議使用NIO協定

可能對於Broker有一個很遲鈍的網路傳輸NIO比TCP提供更好的效能

c、NIO連線的URI形式：nio://hostname:port?key=value 後面的參數選填

#d、NIO設定實例conf/activemq.xml：

<transportConnectors>
      <!-- 设置一个NIO的连接-->
      <transportConnector name="nio" uri="nio://0.0.0.0:61617"/>
    </transportConnectors>

#（3）、UDP

a、UDP和TCP的區別

TCP是一個原始流的傳遞協議，意味著封包是有保證的，換句話說，資料包是不會被複製和遺失的。 UDP，另一方面，它是不會保證資料包的傳遞的

TCP也是一個穩定可靠的資料包傳遞協議，意味著資料在傳遞的過程中不會被遺失。這樣 確保了在發送和接收之間能夠可靠的傳遞。相反，UDP只是一個連結協議，所以它沒有可靠性之說

TCP是被用在穩定可靠的場景中使用的；UDP通常用在快速資料傳遞和不怕資料遺失的場景中，還有ActiveMQ通過防火牆時，只能用UDP

b、UDP連線的URI形式：udp://hostname:port?key=value

c、設定實例conf/activemq. xml

<transportConnectors>
  <transportConnector name="udp" uri="udp://localhost:61618"/>
</transportConnectors>

（4）、SSL

#底層是TCP協議，但對傳輸資料進行了加密

a、適用場景：MQ暴露在外網，要求客戶端與broker之間通訊

b、使用步驟：

b-1、建立SSL協定：

b-2、設定Broker SSL協定conf/activemq.xml：

 <sslContext>
  <sslContext keyStore="F:/beifeng/apache-activemq-5.6.0/conf/mybroker.ks"
   keyStorePassword="test123" />
</sslContext>

b-3、設定客戶端SSL協定：

c、SSL的連線的URI形式：ssl://hostname:port?key=value

d、設定實例conf/activemq.xml

<transportConnectors>
   <transportConnector name="ssl" uri="ssl://localhost:61619"/>
 </transportConnectors>

（5 ）HTTP、HTTPS

a、透過jetty容器來接收http協定的mq訊息

#b、用於只允許基本HTTP服務通過的網路環境

c、透過httpclient來傳送/接收訊息，需要增加額外的java套件Httpclient、Xstream、activemq-optional

d、URI：http://hostname:port?key=value

e、設定實例conf/activemq.xml：

<transportConnectors>
  <transportConnector name="http" uri="http://localhost:8080"/>
</transportConnectors>

#設定HTTPS則需要在jetty.xml中設定相關憑證HTTPS= HTTP+SSL

（二、）網路連接器（NetWorkConnectors）

NetWorkConnectors：用於Broke與Broke之間的交互，主要是ActiveMq叢集部署時。

以上這篇JMS 之 Active MQ 的訊息傳輸(詳解)就是小編分享給大家的全部內容了，希望能給大家一個參考，也希望大家多多支持腳本之家。

以上是JMS 之 Active MQ 的訊息傳輸（圖文詳解）的詳細內容。更多資訊請關注PHP中文網其他相關文章！