1. 程式人生 > >AMQ高可用叢集-jdbc方式搭建叢集

AMQ高可用叢集-jdbc方式搭建叢集

解壓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包
jdbc連線所需的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張表
AMQ資料庫表

3.測試

建立佇列,並建立持久化訊息【持久化訊息才會快取至資料庫】

建立佇列及持久化訊息

檢視資料庫
檢視資料庫儲存的持久化訊息

關閉主節點,檢視主從切換,切換成功並有快取的訊息即配置成功