JMS 之 Active MQ 的訊息傳輸

本文使用Active MQ5.6 

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

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

 

#（2一）、傳輸連接器（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協定：

#　　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 的訊息傳輸的詳細內容。更多資訊請關注PHP中文網其他相關文章！