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

    xiaoxiao2021-03-25  79

    解压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.测试

    创建队列,并创建持久化消息【持久化消息才会缓存至数据库】

    查看数据库

    关闭主节点,查看主从切换,切换成功并有缓存的消息即配置成功

    转载请注明原文地址: https://ju.6miu.com/read-34104.html

    最新回复(0)