ActiveMQ (三)—持久化消息

ActiveMQ的另一个问题就是只要是软件就有可能挂掉，挂掉不可怕，怕的是挂掉之后把信息给丢了，所以本节分析一下几种持久化方式：

一、持久化为文件

ActiveMQ默认就支持这种方式，只要在发消息时设置消息为持久化就可以了。

打开安装目录下的配置文件：

D:ActiveMQapache-activemqconfactivemq.xml在越80行会发现默认的配置项：

        <persistenceAdapter>

            <kahaDB directory="${activemq.data}/kahadb"/>

        </persistenceAdapter>

注意这里使用的是kahaDB，是一个基于文件支持事务的消息存储器，是一个可靠，高性能，可扩展的消息存储器。

     他的设计初衷就是使用简单并尽可能的快。KahaDB的索引使用一个transaction log，并且所有的destination只使用一个index，有人测试表明：如果用于生产环境，支持1万个active connection，每个connection有一个独立的queue。该表现已经足矣应付大部分的需求。

然后再发送消息的时候改变第二个参数为：

MsgDeliveryMode.Persistent

Message保存方式有2种
PERSISTENT：保存到磁盘，consumer消费之后，message被删除。
NON_PERSISTENT：保存到内存，消费之后message被清除。
注意：堆积的消息太多可能导致内存溢出。

然后打开生产者端发送一个消息：

不启动消费者端，同时在管理界面查看：

发现有一个消息正在等待，这时如果没有持久化，ActiveMQ宕机后重启这个消息就是丢失，而我们现在修改为文件持久化，重启ActiveMQ后消费者仍然能够收到这个消息。

二、持久化为数据库

ActiveMQ具体就不介绍了，直接介绍如何讲ActiveMQ持久化到本地数据库，以SQL Server 2008 R2为例
1.下载ActiveMQ后直接解压，我下载的是apache-activemq-5.14.5-bin.zip。

2.打开conf下的activemq.xml,我要配置的是将消息持久化到SQL Server 2008 R2

3.增加配置：

Mysql持久化bean：

<bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  <property name="url" value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/>
  <property name="username" value="activemq"/>
  <property name="password" value="activemq"/>
  <property name="poolPreparedStatements" value="true"/>
</bean>

SQL Server持久化bean：

<bean id="mssql-ds" class="net.sourceforge.jtds.jdbcx.JtdsDataSource" destroy-method="close">
  <property name="driverClassName" value="com.microsoft.sqlserver.jdbc.SQLServerDriver"/>
  <property name="url" value="jdbc:sqlserver://xx.xxx.x.xxx:1433;databaseName=DATANAME;user=USER;password=PASSWORD"/>
  <property name="user" value="USER"/>
  <property name="password" value="PASSWORD"/>
</bean>

Oracle持久化bean：

<bean id="oracle-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
   <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>
   <property name="url" value="jdbc:oracle:thin:@10.53.132.47:1521:activemq"/>
   <propertyname="username" value="activemq"/>
   <property name="password" value="activemq"/>
   <property name="maxActive" value="200"/>
   <property name="poolPreparedStatements" value="true"/>
</bean>

DB2持久化bean：

<bean id="db2-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
   <property name="driverClassName" value="com.ibm.db2.jcc.DB2Driver"/>
   <property name="url" value="jdbc:db2://hndb02.bf.ctc.com:50002/activemq"/>
   <property name="username" value="activemq"/>
   <property name="password" value="activemq"/>
   <property name="maxActive" value="200"/>
   <property name="poolPreparedStatements" value="true"/>
</bean>

如图所示：配置MSSQL数据库

 

根据自己的服务器设定相关的信息。

4.修改持久化设置：

<persistenceAdapter> 
 　<jdbcPersistenceAdapter dataSource="#mssql-ds" createTablesOnStartup="true"/>
</persistenceAdapter>

如图所示：配置jdbcPersistenceAdpater

 

5.最后，别忘了将MSSQL Server JDBC驱动sqljdbc4-4.0.jar(可以到微软官网下载https://msdn.microsoft.com/zh-cn/library/mt683464.aspx)拷贝到lib目录下，
好了，运行bin下的activemq.bat。
在数据库中已建立好ActiveMQ持久化需要的数据表。如图所示：如果配置成功，默认会创建三张表：

activemq_acks：ActiveMQ的签收信息。
activemq_lock:ActiveMQ的锁信息。
activemq_msgs:ActiveMQ的消息的信息

6.当表已成功创建，再次修改持久化设置中的创建表设置(只要第一次创建表成功就行了)：
createTablesOnStartup="false"

7.管理登录：
http://localhost:8161默认用户和密码均为admin

OK配置完成！

PS：如果你发现ActiveMQ添加了持久化后，发了消息，为什么activemq_msgs表中没有记录任何数据，其实这个是需要我们自己在代码里控制的，需要设置MsgDeliveMode为Persistent，具体代码如下：

1 //PERSISTENT：保存到磁盘，consumer消费之后，message被删除。
2 //NON_PERSISTENT：保存到内存，消费之后message被清除。
3 //注意：堆积的消息太多可能导致内存溢出。
4 producer.Send(msg,MsgDeliveryMode.Persistent,level,TimeSpan.MinValue);