Producer

生產者，發送消息

發送步驟

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

代碼

@Test public void testTopicProducer() throws Exception {//創建一個連接工廠對象ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");//創建連接Connection connection = connectionFactory.createConnection();//開啟連接connection.start();//創建SessionSession session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//創建Destination，應該使用topicTopic topic = session.createTopic("test-topic");//創建一個Producer對象MessageProducer producer = session.createProducer(topic);//創建一個TextMessage對象TextMessage textMessage = session.createTextMessage("hello activemq topic");//發送消息producer.send(textMessage);//關閉資源producer.close();session.close();connection.close(); }

總結

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

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