ActiveMQ入门到精通4-消息持久化到Mysql
2018-03-30 12:24
597 查看
ActiveMQ入门到精通4-消息持久化到Mysql
原创 2017年10月23日 17:22:53标签:redis /
MQ /
spring /
互联网 /
java
79
四、ActiveMQ消息持久化到Mysql
ActiveMQ提供多种数据持久化方式:可以持久化到文件,也可以持久化到数据库,其中数据库可以支持MySQL、Oracle,在生产环境中最好是持久化到levelDB等内存型的数据库中。默认提供的是持久化到文件的方式,即activemq.xml文件中的:<persistenceAdapter>
<kahaDB directory="${activemq.base}/data/kahadb"/>
</persistenceAdapter>关于KahaDB的资料,请自行查阅网络。
1 添加MySQL驱动
首先需要把MySql的驱动放到ActiveMQ的Lib目录下,我用的文件名字是:mysql-connector-java-5.1.30-bin.jar2 修改配置文件activemq.xml
将其中的这段配置:<persistenceAdapter><kahaDB directory="${activemq.base}/data/kahadb"/>
</persistenceAdapter>修改为下面这段内容:<persistenceAdapter>
<jdbcPersistenceAdapter dataSource="#derby-ds"/>
</persistenceAdapter>另外需要在broker节点的上面定义id为derby-ds的bean,如下:<beanid="derby-ds"class="org.apache.commons.dbcp.BasicDataSource"destroy-method="close">
<propertyname="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url"value="jdbc:mysql://localhost:3306/active_mq?relaxAutoCommit=true"/>
<propertyname="username" value="root"/>
<propertyname="password" value="root"/>
<propertyname="maxActive" value="200"/>
<propertyname="poolPreparedStatements" value="true"/>
</bean>
3 新建数据库
从配置中可以看出数据库的名称是active_mq,需要手动在MySql中新建一个test_mq的空数据库。此时,重新启动MQ,就会发现test_mq库中多了三张表:activemq_acks,activemq_lock,activemq_msgs,OK,说明已经持久化成功啦!
相关文章推荐
- ActiveMQ入门到精通4-消息持久化到Mysql
- [jms那点事儿] JMS ( java message service )入门 + activemq消息持久化
- [jms那点事儿] JMS ( java message service )入门 + activemq消息持久化
- ActiveMQ使用MySQL进行消息持久化
- JMS消息持久化,将ActiveMQ消息持久化到mySql数据库中
- activemq中利用mysql做消息的持久化
- 消息队列(MQ)入门-activemq,rocketmq代码级别
- 消息中间件-activemq入门(二)
- 消息中间件(3)-ActiveMQ消息持久化
- NHibernate从入门到精通系列(5)——持久对象的生命周期(下)
- java web入门到精通java调用mysql存储过程实例
- 将ActiveMQ的消息保存到MySQL中
- storm从入门到精通 第三节 storm消息机制
- Java网络编程从入门到精通:HTTP消息头字段
- java消息机制 ActiveMQ入门实例
- Mysql入门到精通之数据表的操作
- MYSQL从入门到精通
- NHibernate生命周期:临时态、持久态、游离态-NHibernate入门到精通系列4
- Android从入门到精通第12章:线程与消息处理
- MySQL从入门到精通_7数据的操作