1. ActiveMQ 持久化方案介绍
- ActiveMQ 的消息持久化机制有 JDBC、AMQ、KahaDB 和 LevelDB，无论使用哪种持久化方式，消息的存储逻辑都是一致的。
Queue 类型的持久化机制
Topic 类型的持久化机制
- 会记录每个 Customer 的处理进度。
- 定时清除策略。
- 当发现 topic 长时间没有使用，就会清除。
2. JDBC 方式
- http://activemq.apache.org/jdbc-support
- 将消息存储在数据库中，例如：Mysql、SQL Server、Oracle、DB2 等。
优点 | 缺点 |
|---|---|
方便管理 | 性能低 |
可以支持强一致性 | / |
3. AMQ 方式
- http://activemq.apache.org/amq-message-store
- 基于文件的存储方式，它具有写入速度快和容易恢复的特点，但是由于其重建索引时间过长，而且索引文件占用磁盘空间过大，所以已经不推荐使用。
优点 | 缺点 |
|---|---|
性能高于 JDBC | 索引占用磁盘空间量大 |
/ | 重建索引速度非常慢 |
4. KahaDB 方式
- http://activemq.apache.org/kahadb
- 从 ActiveMQ 5.4 开始默认的持久化方式，KahaDB 恢复时间远远小于其前身 AMQ 并且使用更少的数据文件，所以可以完全代替 AMQ。
5. LevelDB 方式
- LevelDB 是 Google 开发的一套用于持久化数据的高性能类库。LevelDB 并不是一种服务，用户需要自行实现 Server。是单线程的服务，能够处理十亿级别规模 Key-Value 型数据，占用内存小。
LevelDB 的特点
- 基于 KV 存储
- Key 值有序存储
- 操作接口简单
- 支持数据快照
- 支持数据压缩
LevelDB 的结构
ActiveMQ 配置 LevelDB
- 修改配置文件 ${ACTIVEMQ_HOME}/conf/activemq.xml
<persistenceAdapter>
<levelDB directory="${activemq.data}/activemq-data"/>
</persistenceAdapter>6. 事务机制
1. ActiveMQ 事务实现机制
2. ActiveMQ 开启事务
代码语言：javascript复制// ......
// 第一个参数为事务开关，为 true 则会忽略第二个参数，被 jms 服务器设置为 SESSION_TRANSACTED
conn.createSession(true, Session.SESSION_TRANSACTED)
// ......
// 提交事务
session.commit();
// 回滚事务
// session.rollback();
