1. 程式人生 > >ActiveMQ 3個broker配置

ActiveMQ 3個broker配置

第一個borker配置摘錄:

 <networkConnectors>
 </networkConnectors>

<transportConnectors>
            <transportConnector name="openwire" uri="tcp://0.0.0.0:61616"/>
</transportConnectors>

第二個broker配置摘錄:
        <networkConnectors>
            <networkConnector uri="static:(tcp://localhost:61616)" duplex="true"/>
        </networkConnectors>

        <transportConnectors>
            <transportConnector name="openwire" uri="tcp://0.0.0.0:61618"/>
        </transportConnectors>

第三個broker配置摘錄:
        <networkConnectors>
            <networkConnector uri="static:(tcp://localhost:61616)" duplex="true"/>
        </networkConnectors>

        <transportConnectors>
            <transportConnector name="openwire" uri="tcp://0.0.0.0:61620"/>
        </transportConnectors>

分別啟動1個生產者、3個消費者

生產者到61616生產、消費者分別到61616、61618、61620消費,可以看到生產者生產的訊息可以分別被3個消費者消費,但是不會出現一個訊息被多個消費者消費的情形。

第二種測試辦法

分別啟動1個生產者、3個消費者

生產者到61616生產、消費者到61620消費,等所有的訊息被處理之後,再啟動消費者到61618和61616進行訊息處理,發現在61616和61618上已經沒有可以處理的訊息了。