ActiveMQ消息持久化到mysql数据库
- 将mysql驱动导入到activeMQ的lib文件夹
-
修改ActiveMQ的conf目录下的active.xml文件，修改数据持久化的方式
- <persistenceAdapter>
-
<!-- <kahaDB directory="${activemq.data}/kahadb"/> -->
-
<jdbcPersistenceAdapter dataSource="#mysql-ds"/>
- </persistenceAdapter>
- 在conf目录下的active.xml文件添加数据库配置,注意代码位置,在<broker>标签外面(</broker>标签外即可)
- <!-- 用于持久化数据到Mysql数据库 -->
-
<bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
-
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
-
<property name="url" value="jdbc:mysql://localhost:3306/activemq?relaxAutoCommit=true"/>
-
<property name="username" value="root"/>
-
<property name="password" value="1234"/>
-
<property name="maxActive" value="200"/>
-
<property name="poolPreparedStatements" value="true"/>
-
-
</bean>
- 保存文件,然后运行activemq,发送消息后数据库中将添加三张表
- 使用Activemq图形化管理添加消息即可严重数据库是否可用