ActiveMQ in Action(3) - Persistence

时间：2023-03-09 17:42:41
ActiveMQ in Action(3) - Persistence

关键字: activemq

2．3 Persistence
2．3．1 AMQ Message Store
    AMQ Message Store是ActiveMQ5.0缺省的持久化存储。Message commands被保存到transactional journal（由rolling data logs组成）。Messages被保存到data logs中，同时被reference store进行索引以提高存取速度。Date logs由一些单独的data log文件组成，缺省的文件大小是32M，如果某个消息的大小超过了data log文件的大小，那么可以修改配置以增加data log文件的大小。如果某个data log文件中所有的消息都被成功消费了，那么这个data log文件将会被标记，以便在下一轮的清理中被删除或者归档。以下是其配置的一个例子：

  1. <broker brokerName="broker" persistent="true" useShutdownHook="false">
  2. <persistenceAdapter>
  3. <amqPersistenceAdapter directory="${activemq.base}/data" maxFileLength="32mb"/>
  4. </persistenceAdapter>
  5. </broker>

2．3．2 Kaha Persistence
    Kaha Persistence 是一个专门针对消息持久化的解决方案。它对典型的消息使用模式进行了优化。在Kaha中，数据被追加到data logs中。当不再需要log文件中的数据的时候，log文件会被丢弃。以下是其配置的一个例子：

  1. <broker brokerName="broker" persistent="true" useShutdownHook="false">
  2. <persistenceAdapter>
  3. <kahaPersistenceAdapter directory="activemq-data" maxDataFileLength="33554432"/>
  4. </persistenceAdapter>
  5. </broker>

2．3．3 JDBC Persistence
    目前支持的数据库有Apache Derby, Axion, DB2, HSQL, Informix, MaxDB, MySQL, Oracle, Postgresql, SQLServer, Sybase。
    如果你使用的数据库不被支持，那么可以调整StatementProvider 来保证使用正确的SQL方言（flavour of SQL）。通常绝大多数数据库支持以下adaptor：

  • org.activemq.store.jdbc.adapter.BlobJDBCAdapter
  • org.activemq.store.jdbc.adapter.BytesJDBCAdapter
  • org.activemq.store.jdbc.adapter.DefaultJDBCAdapter
  • org.activemq.store.jdbc.adapter.ImageJDBCAdapter

也可以在配置文件中直接指定JDBC adaptor，例如：

  1. <jdbcPersistenceAdapter  adapterClass="org.apache.activemq.store.jdbc.adapter.ImageBasedJDBCAdaptor"/>
  1. <persistence>
  2. <jdbcPersistence dataSourceRef=" mysql-ds"/>
  3. </persistence>
  4. <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
  5. <property name="driverClassName" value="com.mysql.jdbc.Driver"/>
  6. <property name="url" value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/>
  7. <property name="username" value="activemq"/>
  8. <property name="password" value="activemq"/>
  9. <property name="poolPreparedStatements" value="true"/>
  10. </bean>

2．3．4 Disable Persistence
    以下是其配置的一个例子：

  1. <broker persistent="false">
  2. </broker>

相关文章