activemq網(wǎng)絡(luò)橋接

在此博客中，我們將看到雙工網(wǎng)絡(luò)連接器如何工作。

在上一部分中，我們從broker-1和broker-2創(chuàng)建了一個(gè)網(wǎng)絡(luò)連接器。 我們能夠看到，當(dāng)代理2上有一個(gè)使用者使用隊(duì)列“ foo.bar”時(shí)，代理1上的隊(duì)列“ foo.bar”的消息如何轉(zhuǎn)發(fā)到代理2上的隊(duì)列“ foo.bar”。

讓我們嘗試通過(guò)將消息生成到broker-2的隊(duì)列foo.bar中并從broker-1的隊(duì)列“ foo.bar”中消費(fèi)來(lái)進(jìn)行相反的操作

Ashwinis-MacBook-Pro:example akuntamukkala$?ant producer -Durl=tcp://localhost:61626 -Dtopic=false -Ddurable=true -Dsubject=foo.bar -Dmax=100Ashwinis-MacBook-Pro:example akuntamukkala$?ant consumer -Durl=tcp://localhost:61616 -Dtopic=false -Dsubject=foo.bar

在上一篇博客文章中，我們使100條消息入隊(duì)/出隊(duì)。 因此，現(xiàn)在排隊(duì)的#messages顯示為200。

如上所示，在Broker-2的foo.bar隊(duì)列中有100條新消息入隊(duì)，但是沒(méi)有用戶，盡管從Broker-1到Broker-2的所有隊(duì)列都有網(wǎng)絡(luò)連接器。

原因是，除非指定為“雙工”，否則網(wǎng)絡(luò)連接器是從源到目標(biāo)代理的單向連接。

讓我們更改以下以黃色突出顯示的屬性

/Users/akuntamukkala/apache-activemq- 5.8.0/bridge-demo/broker-1/conf/activemq.xml

broker-1的配置文件。

<networkConnectors><networkConnector name="T:broker1->broker2" uri="static:(tcp://localhost:61626)" duplex="false" decreaseNetworkConsumerPriority="true" networkTTL="2" dynamicOnly="true"><excludedDestinations><queue physicalName=">" /></excludedDestinations></networkConnector><networkConnector name="Q:broker1->broker2" uri="static:(tcp://localhost:61626)" duplex="true" decreaseNetworkConsumerPriority="true" networkTTL="2" dynamicOnly="true"><excludedDestinations><topic physicalName=">" /></excludedDestinations></networkConnector></networkConnectors>

讓我們重新啟動(dòng)代理，并使用jConsole連接到代理。

這是broker-1 jConsole MBean選項(xiàng)卡的屏幕截圖，顯示以下內(nèi)容：

Q：broker1-> broker2網(wǎng)絡(luò)連接器是雙工的。

現(xiàn)在有一個(gè)動(dòng)態(tài)的生產(chǎn)者從broker-2進(jìn)入broker-1，因?yàn)?
問(wèn)：broker1-> broker2網(wǎng)絡(luò)連接器是“雙工”。

這是broker-2的jConsole MBean選項(xiàng)卡屏幕快照，顯示以下內(nèi)容：

從broker-2到broker-1的雙工網(wǎng)絡(luò)連接器

從broker-1到broker-2的兩個(gè)動(dòng)態(tài)消息生產(chǎn)者

請(qǐng)注意，“ Q：broker1-> broker2”網(wǎng)絡(luò)連接器顯示為activemq.xml中配置的雙工

讓我們看看這個(gè)動(dòng)作

生產(chǎn)者100消息進(jìn)入broker-2

Ashwinis-MacBook-Pro:example akuntamukkala$?ant producer -Durl=tcp://localhost:61626 -Dtopic=false -Ddurable=true -Dsubject=foo.bar -Dmax=100

broker-2中隊(duì)列的屏幕截圖：http：// localhost：9161 / admin / queues.jsp

在broker-1的foo.bar上創(chuàng)建使用者

Ashwinis-MacBook-Pro:example akuntamukkala$?ant consumer -Durl=tcp://localhost:61616 -Dtopic=false -Dsubject=foo.bar

下面來(lái)自broker-2的屏幕快照顯示，所有100條消息已由使用者出隊(duì)（動(dòng)態(tài)轉(zhuǎn)發(fā)到broker-1）。

http：// localhost：9161 / admin / queues.jsp

以下屏幕快照顯示了broker-2的foo.bar隊(duì)列上此動(dòng)態(tài)使用者的詳細(xì)信息。

http：// localhost：9161 / admin / queueConsumers.jsp？JMSDestination = foo.bar

以下屏幕快照顯示了我們?cè)诓襟E2中創(chuàng)建的使用者已成功使用了從Broker-2的foo.bar隊(duì)列動(dòng)態(tài)移動(dòng)到Broker-1的foo.bar隊(duì)列的100條消息。

到此系列的第2部分結(jié)束，我們了解了雙工網(wǎng)絡(luò)連接器的工作方式。

一如既往地歡迎您提出意見(jiàn)。

請(qǐng)繼續(xù)關(guān)注第3部分，我們將討論本地/遠(yuǎn)程代理上的負(fù)載均衡消費(fèi)者...

翻譯自: https://www.javacodegeeks.com/2014/04/activemq-network-of-brokers-explained-part-2.html

activemq網(wǎng)絡(luò)橋接

總結(jié)

以上是生活随笔為你收集整理的activemq网络桥接_ActiveMQ –经纪人网络解释–第2部分的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。