1、將連接Mysql數據庫的jar文件，放到ActiveMQ的lib目錄下

2、修改ActiveMQ的conf目錄下的active.xml文件，修改數據持久化的方式

2.1 ?修改原來的kshadb的持久化數據的方式

2.2 ?連接Mysql的配置(注意配置文件放置的位置)

3、將數據持久化Mysql的運行截圖

3.1 ?重新啟動ActiveMQ，并運行程序，放入持久化數據，查看Mysql的active數據庫

4、放入持久化數據的代碼

importjavax.jms.Connection;importjavax.jms.ConnectionFactory;importjavax.jms.DeliveryMode;importjavax.jms.Destination;importjavax.jms.MessageProducer;importjavax.jms.Session;importjavax.jms.TextMessage;importorg.apache.activemq.ActiveMQConnectionFactory;public classSender {public static void main(String[] args) throwsException {//1、建立ConnectionFactory工廠對象，需要填入用戶名，密碼，以及連接的地址//僅使用默認。端口號為"tcp://localhost:61616"

ConnectionFactory connectionFactory = newActiveMQConnectionFactory("zhangsan",//ActiveMQConnectionFactory.DEFAULT_USER,

"123",//ActiveMQConnectionFactory.DEFAULT_PASSWORD,

"tcp://localhost:61616");//2、通過ConnectionFactory工廠對象創建一個Connection連接//并且調用Connection的start方法開啟連接,Connection默認是不開啟的

Connection connection =connectionFactory.createConnection();

connection.start();//3、通過Connection對象創建Session會話(上下文環境對象)，//參數一，表示是否開啟事務//參數二，表示的是簽收模式，一般使用的有自動簽收和客戶端自己確認簽收//第一個參數設置為true，表示開啟事務//開啟事務后，記得要手動提交事務

Session session=connection.createSession(Boolean.TRUE,

Session.CLIENT_ACKNOWLEDGE);//4、通過Session創建Destination對象，指的是一個客戶端用來指定生產消息目標和消費消息來源的對象。//在PTP模式中,Destination指的是Queue//在發布訂閱模式中，Destination指的是Topic

Destination destination = session.createQueue("queue1");//5、使用Session來創建消息對象的生產者或者消費者

MessageProducer messageProducer =session.createProducer(destination);//6、如果是，生產者，使用MessageProducer的setDeliverMode方法設置，消息的持久化和非持久化

messageProducer.setDeliveryMode(DeliveryMode.PERSISTENT);//7、最后使用JMS規范的TextMessage形式創建數據(通過Session對象)//并利用MessageProducer的send方法發送數據

for (int i = 0; i < 5; i++) {

TextMessage textMessage=session.createTextMessage();

textMessage.setText("我是消息" +i);

messageProducer.send(textMessage);

}//手動提交開啟的事務

session.commit();//釋放連接

if (connection != null) {

connection.close();

}

}

}

總結

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

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