AMQ高可用叢集-jdbc方式搭建叢集
阿新 • • 發佈:2019-01-28
解壓AMQ後進行配置
1.配置
修改 conf/activemq.xml
增加:
<bean id="**oracle-ds**" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>
<property name="url" value="jdbc:oracle:thin:@localhost:1521:ORCL" />
<property name="username" value="oracle_username"/>
<property name="password" value="oracle_password"/>
<property name="poolPreparedStatements" value="true"/>
</bean>
修改:
<persistenceAdapter>
<!--<kahaDB directory="${activemq.data}/kahadb"/>-->
<jdbcPersistenceAdapter dataDirectory="${activemq.data}" dataSource="#**oracle-ds**" createTablesOnStartup="true"/>
</persistenceAdapter>
注意:oracle-ds要保持一致
其他兩個修改配置一樣【偽叢集記得修改埠conf/activemq.xml,conf/jetty.xml】
2.新增jar包
jar包放置lib/目錄下
[http://www-eu.apache.org/dist/commons/](http://www-eu.apache.org/dist/commons/) 可下載commonsjar ojdbc在oracle11g\product\11.2.0\dbhome_1\jdbc\lib下 2.啟動AMQ 啟動命令,`bin/win64/activemq.bat` 或者【`linux bin/activemq start`啟動】
【linux bin/activemq start啟動】
訪問http://ip1:port1/admin/queues.jsp,http://ip2:port2/admin/queues.jsp,http://ip3:port3/admin/queues.jsp
只有一個ip,port能成功訪問,該節點為主節點,其他為從節點
開啟資料庫:多了3張表
3.測試
建立佇列,並建立持久化訊息【持久化訊息才會快取至資料庫】
檢視資料庫
關閉主節點,檢視主從切換,切換成功並有快取的訊息即配置成功