ActiveMQ消息持久化

时间：2019-09-27 17:43:37 阅读：75 评论：0 收藏：0 [点我收藏+]

标签：asi ring basic ble table jar包代码出现 startup

　　和前面我们说的持久，事物，签收不同的，前面的都是局限在同一台机器上，如果本机器坏了，那全部的消息也都丢失了

和Redis的持久化其实是一个概念，当我的主机宕机了也能将消息持久到硬盘或者其他上面（物理备份），方便恢复

官网详情：http://activemq.apache.org/persistence

ActiveMQ的消息持久化机制：

　　JDBC，AMQ，KahaDB，LevelDB，几种的存储逻辑都是一致的，将消息发出后，消息中心首先将消息存储到本地数据文件，内存数据库或者远程数据库，再试图将消息发送给接收者，成功则将消息从存储中删除，失败则继续尝试发送

　　消息中心启动后首先要检查指定的存储位置，若发现没有成功发送的消息，则需要把消息发送出去

　　AMQ：AMQ是一种以文件形式存储的机制，现在淘汰了，是5.3以前的

　　KahaDB:以日志形式记录消息，5.4以后默认就是KahaDB

技术图片

　　　　配置文件activemq.xml里默认KahaDB

　　　　官网详情：http://activemq.apache.org/persistence.html

技术图片

　　　　kahaDB存储在data目录

技术图片

　　kahadb目录：

技术图片

　　KahaDB消息存储使用一个事物日志(db.log)和一个索引文件(db.data)来存储它的所有地址，日志相当于书的文章，索引相当于目录

　　db-<number>.log用来存储消息，当此文件存储满了，又会产生一个新的文件，如第一个是db-1.log，当存储满了，又会产生一个db-2.log，类推，当不再有引用到数据库文件中的任何消息时，文件会被删除或者归档

　　db.data包含了持久化的BTree索引，索引了消息数据记录中的消息，它是消息的索引文件，本质时B树

　　db.rebo：用来进行消息恢复，如果KahaDB消息存储在强制退出后启动，用于恢复B树索引

　　lock:文件锁，就像mysql中的悲观锁，表示获得当前KahaDB读写操作的broker

　　LevelDB:基于文件的存储，没有使用B树作为索引（了解），5.8后才出现

 <persistenceAdapter>
      <levelDB directory="activemq-data"/>
 </persistenceAdapter>

　　JDBC消息存储：同步消息到mysql

　　　　步骤：1.添加mysql驱动包到/activemq/lib下

　　　　　　　2.jdbcPersistenceAdapter配置，将其取代KahaDB

<persistenceAdapter> 
  <jdbcPersistenceAdapter dataSource="#my-ds"/> 
</persistenceAdapter>

技术图片

　　　　　　3.数据库连接池配置

 <bean id="mysql-ds" class="org.apache.commons.dbcp2.BasicDataSource" destroy-method="close"> 
    <property name="driverClassName" value="com.mysql.jdbc.Driver"/> 
    <property name="url" value="jdbc:mysql://自己数据库/activemq?relaxAutoCommit=true"/> 
    <property name="username" value="用户名"/> 
    <property name="password" value="密码"/> 
    <property name="poolPreparedStatements" value="true"/> 
  </bean> 

注：上面使用的时dbcp2连接池，所以不用引入其他jar包，因为时默认的，如果c3p0,或在druid等连接池，需要引入除了mysql驱动以外的jar包到lib下

技术图片