activemq网络桥接_ActiveMQ –经纪人网络解释–第4部分
activemq網(wǎng)絡(luò)橋接
在前面的第3部分中 ，我們已經(jīng)看到ActiveMQ如何幫助將遠(yuǎn)程使用者與本地使用者區(qū)分開來(lái)，這有助于確定從消息生產(chǎn)者到使用者的較短路徑。
在第4部分中，我們將研究如何在遠(yuǎn)程代理上負(fù)載均衡并發(fā)使用者。
讓我們考慮一些高級(jí)配置，以平衡遠(yuǎn)程代理中隊(duì)列上的并發(fā)消息使用者，如下所示。
| 第四部分–經(jīng)紀(jì)人網(wǎng)絡(luò) |
在以上配置中，我們有一個(gè)消息生成器，將消息發(fā)送到Broker-1上的隊(duì)列moo.bar中。 Broker-1建立到Broker-2和Broker-3的網(wǎng)絡(luò)連接器。 消費(fèi)者C1使用來(lái)自代理2上隊(duì)列moo.bar的消息，而消費(fèi)者C2和C3是代理3上隊(duì)列moo.bar上的并發(fā)消費(fèi)者。
讓我們看看這個(gè)動(dòng)作
讓我們創(chuàng)建三個(gè)經(jīng)紀(jì)人實(shí)例…
| 經(jīng)紀(jì)人1 | 61616 | 8161 | 5672 |
| 經(jīng)紀(jì)人2 | 61626 | 9161 | 5682 |
| 經(jīng)紀(jì)人3 | 61636 | 10161 | 5692 |
消費(fèi)者訂閱由代理2和代理3轉(zhuǎn)發(fā)到其相鄰的代理1，代理1具有通過(guò)使用咨詢消息為代理2和代理3建立的網(wǎng)絡(luò)連接器。
| http：// localhost：8161 / admin / queues.jsp |
這是因?yàn)槟J(rèn)情況下，從broker-1到broker-2以及到broker-3的網(wǎng)絡(luò)連接器都具有“ conduitSubscriptions”屬性。
由于使用了來(lái)自同一隊(duì)列“ moo.bar”的消息的代理3的C2和C3被視為代理1中的一個(gè)使用方。
| 顯示消息如何從生產(chǎn)者傳播到消費(fèi)者C1，C2，C3 |
如上所示，即使有3個(gè)使用者和30條消息，但由于C2，C3訂閱被合并到Broker-1的一個(gè)使用者中，因此他們每條消息都無(wú)法處理10條消息。
如果我們要在主題上創(chuàng)建訂閱者，則該管道將是有用的設(shè)置，因?yàn)檫@樣可以防止出現(xiàn)重復(fù)消息。 在第5部分中對(duì)此有更多的了解。
因此，為了使隊(duì)列moo.bar上的C2和C3訂閱傳播到broker-1，讓我們?cè)赽roker-1的網(wǎng)絡(luò)連接器配置中將conductorSubscriptions =“ false”設(shè)置為6之后重新執(zhí)行相同的步驟6、7、8、9和10。 conf / activemq.xml。
這是Broker-1的新網(wǎng)絡(luò)連接器配置代碼段：
<networkConnectors><networkConnectorname="Q:broker1->broker2"uri="static:(tcp://localhost:61626)"duplex="false"decreaseNetworkConsumerPriority="true"networkTTL="2"conduitSubscriptions="false"dynamicOnly="true"><excludedDestinations><topic physicalName=">" /></excludedDestinations></networkConnector><networkConnectorname="Q:broker1->broker3"uri="static:(tcp://localhost:61636)"duplex="false"decreaseNetworkConsumerPriority="true"networkTTL="2"conduitSubscriptions="false"dynamicOnly="true"><excludedDestinations><topic physicalName=">" /></excludedDestinations></networkConnector> </networkConnectors>重新啟動(dòng)代理和使用者C1，C2和C3并在Broker-1的moo.bar隊(duì)列中產(chǎn)生30條消息后，我們發(fā)現(xiàn)所有三個(gè)使用者訂閱都在Broker-1上可見(jiàn)。 結(jié)果，broker-1以循環(huán)方式向每個(gè)使用者分發(fā)了10條消息，以實(shí)現(xiàn)負(fù)載平衡。 如下圖所示。
| 顯示消息如何從生產(chǎn)者傳播到消費(fèi)者C1，C2，C3 |
Broker-1的Web控制臺(tái)@http：// localhost：8161 / admin / queueConsumers.jsp？JMSDestination = moo.bar顯示，Broker-1現(xiàn)在可以看到3個(gè)使用者，并向每個(gè)使用者發(fā)送10條消息。
因此，在博客系列的第4部分中，我們已經(jīng)了解了如何平衡正在使用隊(duì)列中消息的遠(yuǎn)程并發(fā)使用者。
一如既往地感謝您的意見(jiàn)和反饋！
在第5部分中，我們將探討如果使用主題而不是隊(duì)列來(lái)播放同一場(chǎng)景。 敬請(qǐng)關(guān)注…
資源資源
- http://fusesource.com/docs/esb/4.3/amq_clustering/Networks-Connectors.html
- 此博客中使用的所有代理的配置文件（activemq.xml和jetty.xml）在此處可用。
翻譯自: https://www.javacodegeeks.com/2014/06/activemq-network-of-brokers-explained-part-4.html
activemq網(wǎng)絡(luò)橋接
總結(jié)
以上是生活随笔為你收集整理的activemq网络桥接_ActiveMQ –经纪人网络解释–第4部分的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： 手机wps文档清除格式(在手机版WPS中
- 下一篇： 入深户网上已审批同意（深户首次备案）