Connector:ActiveMQ提供的,用來實現連接通訊的功能。包括:client-tobroker、broker-to-broker。 ActiveMQ允許客戶端使用多種協議來連接
配置Transport Connector的文件在activeMQ安裝目錄的conf/activemq.xml中的<transportConnectors>標簽之內。
<transportConnectors>
<!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="amqp" uri="amqp://0.0.0.0:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="stomp" uri="stomp://0.0.0.0:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="mqtt" uri="mqtt://0.0.0.0:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
<transportConnector name="ws" uri="ws://0.0.0.0:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
ActiveMQ支持的client-broker通訊協議有:TCP、NIO、UDP、SSL、Http(s)、VM。
Transmission Control Protocol (TCP)
1:這是默認的Broker配置,TCP的Client監聽端口是61616。
2:在網絡傳輸數據前,必須要序列化數據,消息是通過一個叫wire protocol的來序列化成字節流。默認情況下,ActiveMQ把wire protocol叫做OpenWire,它的目的是促使網絡上的效率和數據快速交互。
3:TCP連接的URI形式:tcp://hostname:port?key=value&key=value,加粗部分是必須的
4:TCP傳輸的優點:
(1)TCP協議傳輸可靠性高,穩定性強
(2)高效性:字節流方式傳遞,效率很高
(3)有效性、可用性:應用廣泛,支持任何平台
5:所有關於Transport協議的可配置參數,可以參見:
http://activemq.apache.org/configuring-version-5-transports.html
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
New I/O API Protocol(NIO)
1:NIO協議和TCP協議類似,但NIO更側重於底層的訪問操作。它允許開發人員對同一資源可有更多的client調用和服務端有更多的負載。
2:適合使用NIO協議的場景:
(1)可能有大量的Client去鏈接到Broker上一般情況下,大量的Client去鏈接Broker是被操作系統的線程數所限制的。因此,NIO的實現比TCP需要更少的線程去運行,所以建議使用NIO協議
(2)可能對於Broker有一個很遲鈍的網絡傳輸NIO比TCP提供更好的性能
3:NIO連接的URI形式:nio://hostname:port?key=value
4:Transport Connector配置示例:
<transportConnectors>
<transportConnector name="tcp" uri="tcp://localhost:61616?trace=true" />
<transportConnector name="nio" uri="nio://localhost:61618?trace=true" />
</transportConnectors>
上面的配置,示范了一個TCP協議監聽61616端口,一個NIO協議監聽61618端口
User Datagram Protocol(UDP)
1:UDP和TCP的區別
(1)TCP是一個原始流的傳遞協議,意味着數據包是有保證的,換句話說,數據包是不會被復制和丟失的。UDP,另一方面,它是不會保證數據包的傳遞的
(2)TCP也是一個穩定可靠的數據包傳遞協議,意味着數據在傳遞的過程中不會被丟失。這樣確保了在發送和接收之間能夠可靠的傳遞。相反,UDP僅僅是一個鏈接協議,所以它沒有可靠性之說
2:從上面可以得出:TCP是被用在穩定可靠的場景中使用的;UDP通常用在快速數據傳遞和不怕數據丟失的場景中,還有ActiveMQ通過防火牆時,只能用UDP
3:UDP連接的URI形式:udp://hostname:port?key=value
4:Transport Connector配置示例:
<transportConnectors>
<transportConnector name="udp" uri="udp://localhost:61618?trace=true" />
</transportConnectors>
Secure Sockets Layer Protocol (SSL)
1:連接的URI形式:ssl://hostname:port?key=value
2:Transport Connector配置示例:
<transportConnectors>
<transportConnector name="ssl" uri="ssl://localhost:61617?trace=true"/>
</transportConnectors>
Hypertext Transfer Protocol (HTTP/HTTPS)
1:像web和email等服務需要通過防火牆來訪問的,Http可以使用這種場合
2:連接的URI形式:http://hostname:port?key=value或者https://hostname:port?key=value
3:Transport Connector配置示例:
<transportConnectors>
<transportConnector name="http" uri="http://localhost:8080?trace=true" />
</transportConnectors>
VM Protocol(VM)
1、VM transport允許在VM內部通信,從而避免了網絡傳輸的開銷。這時候采用的連 接不是socket連接,而是直接的方法調用。
2、第一個創建VM連接的客戶會啟動一個embed VM broker,接下來所有使用相同的 broker name的VM連接都會使用這個broker。當這個broker上所有的連接都關閉 的時候,這個broker也會自動關閉。
3、連接的URI形式:vm://brokerName?key=value
4、Java中嵌入的方式: vm:broker:(tcp://localhost:6000)?brokerName=embeddedbroker&persistent=fal se , 定義了一個嵌入的broker名稱為embededbroker以及配置了一個 tcptransprotconnector在監聽端口6000上
5、使用一個加載一個配置文件來啟動broker vm://localhost?brokerConfig=xbean:activemq.xml