1. ActiveMQ 持久化方案介绍

  • ActiveMQ 的消息持久化机制有 JDBC、AMQ、KahaDB 和 LevelDB，无论使用哪种持久化方式，消息的存储逻辑都是一致的。

Queue 类型的持久化机制

image.png

Topic 类型的持久化机制

image.png

  • 会记录每个 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 的结构

image.png

ActiveMQ 配置 LevelDB

  • 修改配置文件 ${ACTIVEMQ_HOME}/conf/activemq.xml
    1. <persistenceAdapter>
    2.   <levelDB directory="${activemq.data}/activemq-data"/>
    3. </persistenceAdapter>

6. 事务机制

1. ActiveMQ 事务实现机制

image.png

2. ActiveMQ 开启事务

// ......
// 第一个参数为事务开关，为 true 则会忽略第二个参数，被 jms 服务器设置为 SESSION_TRANSACTED
conn.createSession(true, Session.SESSION_TRANSACTED)
// ......
// 提交事务
session.commit();
// 回滚事务
// session.rollback();