解压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.测试创建队列,并创建持久化消息【持久化消息才会缓存至数据库】
查看数据库
关闭主节点,查看主从切换,切换成功并有缓存的消息即配置成功