ActiveMQ中的消息持久性

ActiveMQ很好的支持了消息的持久性(Persistence)。消息持久性对于可靠消息传递来说应该是一种比较好的方法，有了消息持久化，即使发送者和接受者不是同时在线或者消息中心在发送者发送消息后宕机了，在消息中心重新启动后仍然可以将消息发送出去，如果把这种持久化和ReliableMessaging结合起来应该是很好的保证了消息的可靠传送。

 

    消息持久性的原理很简单，就是在发送者将消息发送出去后，消息中心首先将消息存储到本地数据文件、内存数据库或者远程数据库等，然后试图将消息发送给接收者，发送成功则将消息从存储中删除，失败则继续尝试。消息中心启动以后首先要检查制定的存储位置，如果有未发送成功的消息，则需要把消息发送出去。

 

    对于ActiveMQ，消息的持久化同样是很简单的，仅仅通过配置信息就可以实现。这里主要介绍两种不同的持久化方法。

 

1。High performance journal

    这是ActiveMQ基于开源的HOWL(High-speed ObjectWeb Logger)，将HOWL扩展为可以存储任意大小的消息(HOWL只能存储固定大小的记录)，实现的一种消息持久化方法。它可以快速的将消息存储在本地文件中，且这种文件是以一种类似数据库的方式管理的。这样，如果你发送了10,000个消息，可能只有很少数的消息没有发送成功，当达到一个checkpoint的时候，journal将一批未成功消息通过JDBC存储到数据库，这样避免了多次的数据库操作，很大程度上提高了性能并且保证了可靠性。

    配置方法非常简单，就是无需配置，呵呵。ActiveMQ默认支持Journal，在activemq.xml配置文件中，可以找到如下信息：

<persistenceAdapter>
    <journaledJDBC journalLogFiles="5" journalLogFileSize="1024" dataDirectory="${activemq.home}/activemq-data"/>
</persistenceAdapter>

 这里可以改动的就是journalLogFiles，这个属性是制定默认创建几个数据文件来存储消息。journalLogFileSize为数据文件大小，默认为20MB。dataDirectory指向了存储数据文件的位置。

 

2。使用MySQL进行消息持久化

    ActiveMQ持久几乎所有数据库(因为是通过JDBC把消息存储到数据库的)。方法同样简单，就是配置信息稍微有点变化。

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

 其中dataSource指定了所用数据源的名字为mysql-ds。需要在activemq.xml文件中的<broker>标签之外配置数据源。下面是MySql的配置信息。

<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="root"/>
    <property name="password" value="root"/>
    <property name="poolPreparedStatements" value="true"/>
</bean>

    大多数信息的含义是很清楚的，需要注意的是relaxAutoCommit需要设置为true，不知道什么含义。不同数据库的配置信息可能有些不一样，还需要自己再查一下。

    配置文件修改好之后，将所选数据库的JDBC驱动包下载之后放到%ACTIVEMQ_HOME%\lib\下，然后启动%ACTIVEMQ_HOME%\bin\activemq.bat。

！！！需要注意的一个地方是：ActiveMQ使用MySQL持久化消息是，需要首先创建数据库，上面配制信息中可以看到，数据库的名字是activemq。启动activemq.bat之后，会在数据库中创建表。我使用MySQL4.1，出现了max key lengh...错误，原因就是ActiveMQ创建的表使用三个字段的组合作为主键，每个字段时varchar(250)，加起来是750个varchar，如果按一个varchar 2个字节(据说如果采用utf-8编码，可能会是3个字节？？)，超出了MySQL允许的1024字节。我曾试图更改MySQL的设置，没有成功，最后手动的那控制台打印出来的SQL语句中的250都换成了100，创建了这个表，然后把其他创建的表删掉。然后重新启动activemq.bat，成功！！！:)

 

    这样，消息中心具有了消息持久化功能，还需要做的就是消息发送者在发送消息的时候要采用JMS中的PERSISTENT模式发送消息。示例代码如下：

MessageProducer producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.PERSISTENT);
// 如果不想持久化可用下面语句
//producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

  这样，你的消息无论怎么发，都可以成功了。

转至http://zhaiyl.spaces.live.com/blog/cns!939A197D2798715B!125.entry