修改配置文件持久化到Mysql數據庫

文件路徑：\conf\activemq.xml

<persistenceAdapter><!--<kahaDB directory="${activemq.data}/kahadb"/>--><jdbcPersistenceAdapter dataSource="#mysql-ds"/> </persistenceAdapter> <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://localhost:3306/test?relaxAutoCommit=true"/><property name="username" value="root"/><property name="password" value="123456"/><property name="poolPreparedStatements" value="true"/> </bean>

?apache-dbcp包下載地址

http://commons.apache.org/proper/commons-dbcp/download_dbcp.cgi

apache-commons-pool下載地址:

http://commons.apache.org/proper/commons-pool/download_pool.cgi

?

數據庫需要字符集設置為latin1.

可以參考這個博客:

https://www.cnblogs.com/grey-wolf/p/6530998.html CREATE DATABASE IF NOT EXISTS test default charset utf8; //這個是錯誤的寫法 要么不寫要么寫latin1DROP DATABASE test;CREATE DATABASE IF NOT EXISTS test;

Enabling Message Priority

配置優先級生效：

<policyEntry queue='first' prioritizedMessages='true' />

循序漸進ActiveMQ（3）----MessageConsumer的消息選擇器及mysql消息持久化

?

?

?

?

?

總結

以上是生活随笔為你收集整理的ActiveMQ 消息持久化到Mysql数据库的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。