溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點(diǎn)擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

ActiveMQ(五)——ActiveMQ的Transport

發(fā)布時(shí)間:2020-07-20 10:51:24 來源:網(wǎng)絡(luò) 閱讀:543 作者:mazongfei 欄目:編程語言

一、支持的傳輸協(xié)議

  • Connector:ActiveMQ提供的,用來實(shí)現(xiàn)連接通訊的功能。包括:client-to-broker、broker-to-broker。ActiveMQ允許客戶端使用多種協(xié)議來連接
  • 配置Transport Connector,在conf/activemq.xml中,配置如下:

    <transportConnectors>
    <transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/>
    <transportConnector name="ssl" uri="ssl://localhost:61617"/>
    <transportConnector name="stomp" uri="stomp://localhost:61613"/>
    <transportConnector name="xmpp" uri="xmpp://localhost:61222"/>
    </transportConnectors>
  • ActiveMQ支持的client-broker通訊協(xié)議如下:
    1:TCP:這個(gè)也是缺省使用的協(xié)議
    2:NIO
    3:UDP
    4:SSL
    5:Http(s)
    6:VM:如果客戶端和broker在一個(gè)虛擬機(jī)內(nèi)的話,通過VM協(xié)議通訊在VM內(nèi)通訊,從而減少網(wǎng)絡(luò)傳輸?shù)拈_銷。

    二、Transmission Control Protocol(TCP)
    1:這是默認(rèn)的Broker配置,TCP的Client監(jiān)聽端口是61616。
    2:在網(wǎng)絡(luò)傳輸數(shù)據(jù)前,必須要序列化數(shù)據(jù),消息是通過一個(gè)叫wire protocol的來序列化成字節(jié)流。默認(rèn)情況下,ActiveMQ把wire protocol叫做0penWire,它的目的是促使網(wǎng)絡(luò)上的效率和數(shù)據(jù)快速交互。
    3.TCP連接的URI形式:tcp://hostname:port?key=value&key=value,加粗部分是必須的
    4:TCP傳輸?shù)膬?yōu)點(diǎn):
    (1)TCP協(xié)議傳輸可靠性高,穩(wěn)定性強(qiáng)
    (2)高效性:字節(jié)流方式傳遞,效率很高
    (3)有效性、可用性:應(yīng)用廣泛,支持任何平臺
    5:所有關(guān)于Transport協(xié)議的可配置參數(shù),可以參見:
    http://activemq.apache.org/configuring-version-5-transports.html

    三、New I/O API Protocol(NIO)
    1:NIO協(xié)議和TCP協(xié)議類似,但NIO更側(cè)重于底層的訪問操作。它允許開發(fā)人員對同一資源可有更多的client調(diào)用和服務(wù)端有更多的負(fù)載。
    2:適合使用NI0協(xié)議的場景:
    (1)可能有大量的Client去鏈接到Broker上
    一般情況下,大量的Client去鏈接Brokerr是被操作系統(tǒng)的線程所限制的。因此,NIO的實(shí)現(xiàn)比TCP需要更少的線程去運(yùn)行,所以建議使用NIO協(xié)議。
    (2)可能對于Broker有一個(gè)很遲鈍的網(wǎng)絡(luò)傳輸,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:61617?Trace=true"/>
    </transportConnectors>

    上面的配置,示范了一個(gè)TCP協(xié)議監(jiān)聽61616端口,一個(gè)NI0協(xié)議監(jiān)聽61617端口

    四、User Datasgram Protocol(UDP)
    1:UDP和TCP的區(qū)別
    (1)TCP是一個(gè)原始流的傳遞協(xié)義,意味著數(shù)據(jù)包是有保證的,換句話說,數(shù)據(jù)包是不會被復(fù)制和丟夫的。UDP,另一方面,它是不會保證數(shù)據(jù)包的傳遞的。
    (2)TCP也是一個(gè)穩(wěn)定可靠的數(shù)據(jù)包傳遞協(xié)議,意味著數(shù)據(jù)在傳遞的過程中不會被丟夫。這樣確保了在發(fā)送和接收之間能夠可靠的傳遞。相反,UDP僅僅是一個(gè)鏈接協(xié)議,所以它沒有可靠性之說。
    2:從上面可以得出:TCP是被用在穩(wěn)定可靠的場景中使用的;UDP通常用在快速數(shù)據(jù)傳遞和不怕數(shù)據(jù)丟夫的場景中,還有ActiveMQ通過防火墻時(shí),只能用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:61619?Trace=true"/>
    </transportConnectors>

    六、Hypertext Transfer Protocol(HTTP/HTTPS)
    1:像web和email等服務(wù)需要通過防火墻來訪問的,Http可以使用這種場合
    2:連接的URI形式:http(s)://hostname:port?Key=value
    3:Transport Connector配置示例:

    <transportConnectors>
    <transportConnector name="http" uri="http://localhost:61620?Trace=true"/>
    </transportConnectors>

    七、VM Protocol(VM)
    1:VM transport允許在內(nèi)部通訊,從而避免了網(wǎng)絡(luò)傳輸?shù)拈_銷。這時(shí)候采用的連接不是socket連接,而是直接的方法調(diào)用。
    2:第一個(gè)創(chuàng)建連接的客戶會啟動一個(gè)embed broker,接下來所有使用相同的
    Broker name的VM連接都會使用這個(gè)broker。當(dāng)這個(gè)broker上所有的連接都關(guān)閉的時(shí)候,這個(gè)broker也會自動關(guān)閉。
    3:連接的URI形式:vm://brokerName?key=va1ue
    4:Java內(nèi)嵌入的方式:
    vm:broke:(tcp://localhost:6000)?brokerName=embeddedbbroker&persistent=false,定義了一個(gè)嵌入的broker名稱為embededbroker以及配置了一個(gè)tcptransprotconnector在監(jiān)聽端口6000上
    5:使用一個(gè)加載個(gè)配置文件來啟動broker
    Vm://localhost?brokerConfig=xbean:activemq.xml

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI