dubbo視頻教程高可用架構(gòu)篇第03節(jié)activemq集群安裝、配置測(cè)試

高可用集群安裝、配置、高可（ZooKeeper+B）從ActiveMQ5.9開(kāi)始，ActiveMQ的集群實(shí)現(xiàn)方式取消了傳統(tǒng)的Master-SlaveZooKeeper+LevelDB的Master-Slave實(shí)現(xiàn)方式，其他兩種方 共享和數(shù)據(jù)庫(kù)共享依然存在<kahaDB<beanid="mysql-ds" mons.dbcp.BasicDataSource"destroy-<propertyname="driverClassName"<propertyname="url" <propertyname="username"<propertyname="password"<propertyname="maxActive"<propertyname="poolPreparedStatements"<jdbcPersistenceAdapterdataDirectory="${activemq.data}"dataSource="#mysql-ds"行實(shí)現(xiàn)Server。是單進(jìn)程的服務(wù)，能夠處理十億級(jí)別規(guī)模Key-Value型數(shù)據(jù)，占用內(nèi)存小。高可用的原理：使用ZooKeeper（集群）所有的ActiveMQBroker。只有其中的一個(gè)Broker可以提供服務(wù)，被視Master，其他的Broker狀態(tài)SlaveMaster障而不能提供服務(wù)，ZooKeeper會(huì)從Slave中出一個(gè)Broker充當(dāng)Master。Slave連接Master并同步他們的狀態(tài)，Slave不接受客戶端連接。所有的操作都將被到連接至Master的Slaves。如果Master宕了，得到了更新的Slave會(huì)成為Master。故障節(jié)點(diǎn)在恢復(fù)后會(huì)重新加入到集群中并連接Master進(jìn)入Slave模式。如果你配置了replicas=3，那么法定大小是(3/2)+1=2。Master將會(huì)并更新然后等待(2-1)=1個(gè)Slavesuccess。至于為什么是2-1，熟悉Zookeepernode要作為觀擦者存在。當(dāng)一個(gè)新的Master被選中，你需要至少保障一個(gè)法定node以能夠找到擁有狀態(tài)的node。這個(gè)node可以成為新的Master。因此，推薦運(yùn)行至少3個(gè)replicanodes，以防止一個(gè)node失敗了，服務(wù)中斷。（原理與ZooKeeper集群的高可用實(shí)現(xiàn)方式類(lèi)似）環(huán)境：CentOS6.6x64版本：ActiveMQ2、打開(kāi)對(duì)應(yīng)的端$mkdir到$cd$tar-xvfapache-activemq-5.11.1-$mvapache-activemq-5.11.1node- 5、修改管理控制臺(tái)端口（8161）可在conf/jetty.xml<beanid="jettyPort"class="org.apache.activemq.web.WebConsolePort"init-<!--thedefaultportnumberforthewebconsole--<propertyname="host"<propertyname="port"<beanid="jettyPort"class="org.apache.activemq.web.WebConsolePort"init-<!--thedefaultportnumberforthewebconsole--<propertyname="host"<propertyname="port"<beanid="jettyPort"class="org.apache.activemq.web.WebConsolePort"init-<!--thedefaultportnumberforthewebconsole--<propertyname="host"<propertyname="port"hostname和zkPath。注意：每個(gè)ActiveMQBrokerName必須相同，否則不能加入集群。<brokerxmlns=""brokerName="DubboEdu"<brokerxmlns=""brokerName="DubboEdu"<brokerxmlns=""brokerName="DubboEdu"<!--DOSprotection,limitconcurrentconnectionsto1000andframesizeto100MB-- uri="tcp://0.0.0.0:51511?umConnections=1000 <transportConnectorname="amqp" umConnections=1000 <transportConnectorname="stomp" umConnections=1000 <transportConnectorname="mqtt" umConnections=1000 <transportConnectorname="ws" umConnections=1000 <!--DOSprotection,limitconcurrentconnectionsto1000andframesizeto100MB-- uri="tcp://0.0.0.0:51512?umConnections=1000 <transportConnectorname="amqp" umConnections=1000 <transportConnectorname="stomp"uri="stomp://0.0.0.0:61613?umConnections=1000 <transportConnectorname="mqtt"uri="mqtt://0.0.0.0:1883?umConnections=1000 <transportConnectorname="ws"uri="ws://0.0.0.0:61614?umConnections=1000 <!--DOSprotection,limitconcurrentconnectionsto1000andframesizeto100MB-- uri="tcp://0.0.0.0:51513?umConnections=1000 <transportConnectorname="amqp"uri="amqp://0.0.0.0:5672?umConnections=1000 <transportConnectorname="stomp"uri="stomp://0.0.0.0:61613?umConnections=1000 <transportConnectorname="mqtt"uri="mqtt://0.0.0.0:1883?umConnections=1000 <transportConnectorname="ws"uri="ws://0.0.0.0:61614?umConnections=1000 $/home/wusc/activemq/node-01/bin/activemq$/home/wusc/activemq/node-02/bin/activemq$/home/wusc/activemq/node-03/bin/activemq$tail-f/home/wusc/activemq/node-$tail-f/home/wusc/activemq/node-$tail-f/home/wusc/activemq/node-ZooKeeperActiveMQ300000000000，其他兩個(gè)節(jié)點(diǎn)是Slave。9、集群可用性測(cè)試（配置和測(cè)試代碼，請(qǐng)看接Broker應(yīng)該使用failover協(xié)議。10、集群高可用測(cè)試(請(qǐng)看當(dāng)一個(gè)ActiveMQ節(jié)點(diǎn)掛掉，或者一個(gè)ZooKeeper節(jié)點(diǎn)掛掉，ActiveMQ服務(wù)依然正常運(yùn)轉(zhuǎn)。如果僅剩一個(gè)ActiveMQ節(jié)點(diǎn)，因?yàn)椴荒躆aster，ActiveMQ不能正常運(yùn)轉(zhuǎn)；同樣的，如果ZooKeeper僅剩一個(gè)節(jié)點(diǎn)活動(dòng)，不管ActiveMQ各節(jié)點(diǎn)是否存活，ActiveMQ也不能正常提供服務(wù)。#visu-wusc-c'/home/wusc/activemq/node-01/bin/activemqstart'su-wusc-c'/home/wusc/activemq/node-02/bin/activemqstart'su-wusc-c'/home/wusc/activemq/node-03/bin/act