A股上市公司传智教育(股票代码 003032)旗下技术交流社区北京昌平校区

 找回密码
 加入黑马

QQ登录

只需一步,快速开始

© liuchengwei1 中级黑马   /  2018-12-17 20:30  /  1832 人查看  /  10 人回复  /   0 人收藏 转载请遵从CC协议 禁止商业使用本文

ActiveMQ持久化
1.   说明
使用springactivemq环境
2.   ActiveMq topic持久化2.1. AMQ方式 (了解一下)
AMQ是一种文件存储形式,它具有写入速度快和容易恢复的特点。消息存储在一个个文件中,文件的默认大小为32M,如果一条消息的大小超过了32M,那么这个值必须设置大一点。当一个存储文件中的消息已经全部被消费,那么这个文件将被标识为可删除,在下一个清除阶段,这个文件被删除。AMQ适用于ActiveMQ5.3之前的版本
2.2. kafadb持久到文件
KahaDB   ActiveMQ 5.4默认持久化插件
2.2.1.   KahaDB主要特性
A、日志形式存储消息;
B、消息索引以B-Tree结构存储,可以快速更新;
B-Tree存储结构参考:https://www.cnblogs.com/gym333/p/6877023.html
C、完全支持JMS事务;
D、支持多种恢复机制;
2.2.2.    修改activemq.xml文件
a)     位置:
b)     修改broker
c)      修改persistenceAdapter

2.2.3.    生产者配置文件
2.2.4.    消费者配置文件
消息者设置需要设置标识符clientId即接收者ID

2.3. jdbc持久化2.3.1.    上传jar包到activemq/lib

2.3.2.    修改activemq.xml
其中数据库对应的地址请修改。


2.3.3.    启动生产者,自动创建三个表

activemq_acks:ActiveMQ的签收信息。
用于存储订阅关系。如果是持久化Topic,订阅者和服务器的订阅关系在这个表保存。
activemq_lock:ActiveMQ的锁信息。
这张表只有在集群环境中才会用到
activemq_msgs:ActiveMQ的消息的信息
用于存储消息,Topic和Queue消息都会保存在这张表中

2.4. LevelDB方式
从ActiveMQ 5.6版本之后,又推出了LevelDB的持久化引擎。
目前默认的持久化方式仍然是KahaDB,不过LevelDB持久化性能高于KahaDB,可能是以后的趋势。
在ActiveMQ 5.9版本提供了基于LevelDB和Zookeeper的数据复制方式,用于Master-slave方式的首选数据复制方案。
2.5. 测试:
在发布/订阅模下,启动两个生产者,再启动消费者,可实现持久化。

更多图片 小图 大图
组图打开中,请稍候......

10 个回复

倒序浏览
张志辉 来自手机 中级黑马 2018-12-19 07:35:18
沙发
占个沙发
回复 使用道具 举报
学到了
回复 使用道具 举报
回复 使用道具 举报
优秀
回复 使用道具 举报
Vicky韦 来自手机 黑马粉丝团 2018-12-19 13:48:42
地板
专业
回复 使用道具 举报
回复 使用道具 举报
消息中间件更多知识见: http://www.uml.org.cn/zjjs/201802111.asp
回复 使用道具 举报
一个人一座城0.0 来自手机 中级黑马 2018-12-20 12:34:14
9#
看看不说话
回复 使用道具 举报
顶顶顶顶顶起来
回复 使用道具 举报
回复 使用道具 举报
您需要登录后才可以回帖 登录 | 加入黑马