activeMQ 持久化配置
Mac 中安装activeMQjava
brew install activemqmysql
启动sql
activemq start数据库
控制台：在浏览器中输入url: http://localhost:8161/apache
A：持久化为文件浏览器
这个你装ActiveMQ时默认就是这种，只要你设置消息为持久化就能够了。涉及到的配置和代码有异步
<persistenceAdapter>
<kahaDB directory="${activemq.base}/data/kahadb"/>
</persistenceAdapter>
producer.Send(request, MsgDeliveryMode.Persistent, level, TimeSpan.MinValue);
<kahaDB directory="${activemq.base}/data/kahadb"/>
</persistenceAdapter>
producer.Send(request, MsgDeliveryMode.Persistent, level, TimeSpan.MinValue);
B：持久化为MySqltcp
你首先须要把MySql的驱动放到ActiveMQ的Lib目录下，我用的文件名字是：mysql-connector-java-5.0.4-bin.jarurl
接下来你修改配置文件spa
<persistenceAdapter>
<jdbcPersistenceAdapter dataDirectory="${activemq.base}/data" dataSource="#derby-ds"/>
</persistenceAdapter>
<jdbcPersistenceAdapter dataDirectory="${activemq.base}/data" dataSource="#derby-ds"/>
</persistenceAdapter>
在配置文件中的broker节点外增长
<bean id="derby-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="maxActive" value="200"/>
<property name="poolPreparedStatements" value="true"/>
</bean>
<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="maxActive" value="200"/>
<property name="poolPreparedStatements" value="true"/>
</bean>
从配置中能够看出数据库的名称是activemq，你须要手动在MySql中增长这个库。
而后从新启动消息队列，你会发现多了3张表
1：activemq_acks
2：activemq_lock
3：activemq_msgs
C：持久化为Oracle
和持久化为MySql同样。
异步访问：
tcp://localhost:61616?jms.useAsyncSend=true&jms.producerWindowSize=1024000