activemq分布式部署

1、分布式部署ActiveMQ服務(wù)器針對(duì)海量消息所要求的橫向擴(kuò)展性和系統(tǒng)的高可用性，ActiveMQ提供了網(wǎng)絡(luò)連接模式的集群功能。簡(jiǎn)單的說，就是通過把多個(gè)不同的broker實(shí)例連接在一起，作為一個(gè)整體對(duì)外提供服務(wù)，從而提高整體對(duì)外的消息服務(wù)能力。通過這種方式連接在一起的broker實(shí)例之間，可以共享隊(duì)列和消費(fèi)者列表，從而達(dá)到分布式隊(duì)列的目的。ActiveMq支持的網(wǎng)絡(luò)協(xié)議名詞解釋l transport connector傳輸連接器，實(shí)現(xiàn)客戶端與代理(client-to-broker)之間的通信l network connector網(wǎng)絡(luò)連接器，實(shí)現(xiàn)代理與代理之間的通信拓?fù)浣Y(jié)構(gòu)幾種不同的ActiveM

2、Q部署拓?fù)浣Y(jié)構(gòu)（嵌入、主從復(fù)制、集群）：配置示例l 嵌入式在activemq.xml的broker節(jié)點(diǎn)內(nèi)添加：<networkConnectors> <networkConnector uri="static:(tcp:/localhost:62001)"/></networkConnectors>l 主從復(fù)制<networkConnectors> <networkConnector uri="multicast:/default"/></networkConnectors><

3、transportConnectors> <transportConnector uri="tcp:/localhost:0" discoveryUri="multicast:/default"/></transportConnectors>第一個(gè)是master，其他是slavel 集群使用靜態(tài)URI方式可以指定多個(gè)URL，networkConnector將連接到每一個(gè)broker。<networkConnectors> <networkConnector uri="static:(tcp:/ho

4、st1:61616,tcp:/host2:61616,tcp:/.)"/></networkConnectors>當(dāng)然，一個(gè)broker的實(shí)例內(nèi)可以配置多個(gè)networkConnector，如果有兩個(gè)以上的networkConnector指向同一個(gè)broker，則需要顯式的指定name。參數(shù)詳解URI屬性示例：networkConnector配置參數(shù)管道訂閱(conduit subscription)conduitSubscriptions選擇決定網(wǎng)絡(luò)消費(fèi)者在所有消費(fèi)者中的比重。假如有2個(gè)同一個(gè)遠(yuǎn)程的broker1上的網(wǎng)絡(luò)消費(fèi)者和一個(gè)broker2的本地消費(fèi)者。1.

5、 conduitSubscriptions為true，則2個(gè)網(wǎng)絡(luò)消費(fèi)者只相當(dāng)于一個(gè)消費(fèi)者，broker1僅僅在broker2上注冊(cè)了一個(gè)消費(fèi)者。這時(shí)往broker2上發(fā)送300個(gè)消息，2個(gè)網(wǎng)絡(luò)消費(fèi)者各接收到75個(gè)消息，一個(gè)本地消費(fèi)者接收到150 消息。2. conduitSubscriptions為false，則3個(gè)消費(fèi)者平分所有消息，broker1在broker2上將注冊(cè)了兩個(gè)消費(fèi)者。這時(shí)往broker2上發(fā)送300個(gè)消息，2個(gè)網(wǎng)絡(luò)消費(fèi)者和本地消費(fèi)者一樣，各接收到100個(gè)消息。雙向網(wǎng)絡(luò)連接(duplex networkConnector) 默認(rèn)NetworkConnector在需要轉(zhuǎn)發(fā)消息時(shí)

6、是單向連接的。當(dāng)duplex=true時(shí)，就變成了雙向連接，這時(shí)配置在broker2端的指向broker1的duplex networkConnector，相當(dāng)于即配置了broker2到broker1的網(wǎng)絡(luò)連接，也配置了broker1到broker2的網(wǎng)絡(luò)連接。（就是說不管broker1同意與否，都被綁架了。）當(dāng)然，僅僅在broker1上配置也有同樣的效果。注意：可以在兩個(gè)broker間建立兩個(gè)以上的雙向網(wǎng)絡(luò)連接來增加吞吐量或?qū)χ黝}隊(duì)列分區(qū)，只需要指定他們使用不同的name即可。指定和限制Destination通過NetworkConnector共享的destination太多，傳輸?shù)腁dvi

7、sory Message就會(huì)變的非常多，系統(tǒng)的拓?fù)浣Y(jié)構(gòu)將變得非常復(fù)雜，所有才有多種方式來限制這些destination配置：dynamicallyIncludedDestinations這里匹配到的destination，在需要時(shí)將被轉(zhuǎn)發(fā)2. excludedDestinations這里匹配到的destination，將不會(huì)被轉(zhuǎn)發(fā)3. staticallyIncludedDestinations如果指定了staticBridge為true，則只有這里匹配的destination可以被轉(zhuǎn)發(fā)。此時(shí)本地broker完全被其他broker代理。并且本broker不會(huì)訂閱其他broker上的AdvisoryMessage，也不會(huì)獲取任何遠(yuǎn)程consumer信息。參考文