在此博客中，我們將看到雙工網絡連接器如何工作。

在上一部分中，我們從broker-1和broker-2創建了一個網絡連接器。 我們能夠看到當代理2上有一個使用者使用隊列“ foo.bar”時，代理1上的隊列“ foo.bar”的消息如何轉發到代理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條消息入隊/出隊。 因此，現在排隊的#messages顯示為200。

如上所示，在Broker-2的foo.bar隊列中有100條新消息入隊，但是沒有消費者，盡管從Broker-1到Broker-2的所有隊列都有一個網絡連接器。

原因是，除非指定為“雙工”，否則網絡連接器是從源到目標代理的單向連接。

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

/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選項卡的屏幕截圖，顯示以下內容：

Q：broker1-> broker2網絡連接器是雙工的。

現在有一個動態的生產者從broker-2進入broker-1，因為
問：broker1-> broker2網絡連接器是“雙工”。

這是broker-2 jConsole MBean標簽的屏幕截圖，其中顯示以下內容：

從broker-2到broker-1的雙工網絡連接器

從broker-1到broker-2的兩個動態消息生產者

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

讓我們看看這個動作

生產者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上創建使用者

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

以下來自broker-2的屏幕截圖顯示，所有100條消息已由使用者出隊（動態轉發到broker-1）。

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

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

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

下面的屏幕快照顯示了我們在步驟2中創建的使用者已成功使用了從broker-2的foo.bar隊列動態移動到broker-1的foo.bar隊列的100條消息。

到此系列的第2部分結束，我們了解了雙工網絡連接器的工作方式。

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

請繼續關注第3部分，我們將介紹本地/遠程代理上的負載平衡消費者...

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

總結

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

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。