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

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

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

讓我們嘗試通過將消息生成到broker-2的隊列foo.bar中并從broker-1的隊列“ foo.bar”中消費來進行相反的操作

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條消息入隊/出隊。 因此，現(xiàn)在排隊的#messages顯示為200。

如上所示，在Broker-2的foo.bar隊列中有100條新消息入隊，但是沒有用戶，盡管從Broker-1到Broker-2的所有隊列都有網(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>

讓我們重新啟動代理，并使用jConsole連接到代理。

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

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

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

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

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

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

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

讓我們看看這個動作

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

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

broker-2中隊列的屏幕截圖：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

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

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

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

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

以下屏幕快照顯示了我們在步驟2中創(chuàng)建的使用者已成功使用了從Broker-2的foo.bar隊列動態(tài)移動到Broker-1的foo.bar隊列的100條消息。

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

一如既往地歡迎您提出意見。

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

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

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

總結(jié)

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

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