首页 > 技术文章 > 使用jdbc实现ActiveMQ持久化

wishsaber 2020-02-15 16:54 原文

步骤一:创建一个数据库
步骤二:配置activemq.xml配置文件
1.在persistenceAdapter加入如下配置

<!--createTablesOnStartup 启动是否创建表 第一次为true 后续为false-->
<jdbcPersistenceAdapter dataSource="#activemq-db" createTablesOnStartup="true" />

  


2.配置数据源
在beans节点中

<bean id="activemq-db" class="org.apache.commons.dbcp.BasicDataSource">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://127.0.0.1:3306/activemq"/>
<property name="username" value="root"/>
<property name="password" value="root"/>
<property name="maxActive" value="200"/> 
<property name="poolPreparedStatements" value="true"/>
</bean>

  


3.将数据库连接Jar放到activemq解压的lib文件夹下


步骤三:重新启动activemq

效果:

 

 

 

 

推荐阅读