第一步找到activemq的配置文件activemq.xml中关于数据库的配置,该文件位置位于activemq安装位置的conf文件夹下,默认数据库是kahadb
1 <persistenceAdapter> 2 <kahaDB directory="${activemq.data}/kahadb"/> 3 </persistenceAdapter>
将其改为
1 <persistenceAdapter> 2 <jdbcPersistenceAdapter dataSource="#mysql-ds"/> 3 </persistenceAdapter>
第二步 在activemq.xml文件的beans标签下,配置activemq数据源
1 <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> 2 <property name="driverClassName" value="com.mysql.cj.jdbc.Driver"/> 3 <property name="url" value="jdbc:mysql://localhost:3306/activemq"/> 4 <property name="username" value="root"/> 5 <property name="password" value="123456"/> 6 <property name="maxActive" value="200"/> 7 <property name="poolPreparedStatements" value="true"/> 8 </bean>
第三步 引入依赖的jar包,将jar包放在安装位置下的lib文件夹下
commons-dbcp-1.4.jar
commons-pool-1.6.jar
mysql-connector-java-8.0.11.jar
第四步,启动服务 进入到bin目录下 执行 ./activemq restart 或者./activemq start。执行完毕后可以进入到data目录下查看activemq.log日志,也可以查看该mysql数据库。该mysql数据库会生成三张表