Producer

生產(chǎn)者，發(fā)送消息

發(fā)送步驟

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

代碼

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

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。