Producer
生產者，生產消息，發送端

發送步驟

第一步：創建ConnectionFactory對象，需要指定服務端ip及端口號
第二步：使用ConnectionFactory對象創建一個Connection對象
第三步：開啟連接，調用Connection對象的start方法
第四步：使用Connection對象創建一個Session對象
第五步：使用Session對象創建一個Destination對象（topic、queue），此處創建一個Queue對象
第六步：使用Session對象創建一個Producer對象
第七步：創建一個Message對象，創建一個TextMessage對象
第八步：使用Producer對象發送消息
第九步：關閉資源

代碼

@Test public void testQueueProducer() throws Exception {//1.創建一個連接工廠對象ConnectionFactory對象。需要指定mq服務的ip及端口ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");//2.使用ConnectionFactory創建一個連接Connection對象Connection connection = connectionFactory.createConnection();//3.開啟連接。調用Connection對象的start方法connection.start();//4.使用Connection對象創建一個Session對象//第一個參數是是否開啟事務，一般不使用事務。保證數據的最終一致，可以使用消息隊列實現。//如果第一個參數為true，第二個參數自動忽略。如果不開啟事務false，第二個參數為消息的應答模式。一般自動應答就可以。 Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//5.使用Session對象創建一個Destination對象，兩種形式queue、topic?，F在應該使用queue//參數就是消息隊列的名稱Queue queue = session.createQueue("test-queue");//6.使用Session對象創建一個Producer對象MessageProducer producer = session.createProducer(queue);//7.創建一個TextMessage對象/*TextMessage textMessage = new ActiveMQTextMessage();textMessage.setText("hello activemq");*/TextMessage textMessage = session.createTextMessage("hello activemq1111");//8.發送消息producer.send(textMessage);//9.關閉資源producer.close();session.close();connection.close(); } 《新程序員》：云原生和全面數字化實踐50位技術專家共同創作，文字、視頻、音頻交互閱讀

總結

以上是生活随笔為你收集整理的ActiveMQ中Queue生产者的全部內容，希望文章能夠幫你解決所遇到的問題。

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