Consumer

消費(fèi)者，接收消息

接收步驟

第一步：創(chuàng)建一個(gè)ConnectionFactory對(duì)象
第二步：從ConnectionFactory對(duì)象中獲得一個(gè)Connection對(duì)象
第三步：開(kāi)啟連接。調(diào)用Connection對(duì)象的start方法
第四步：使用Connection對(duì)象創(chuàng)建一個(gè)Session對(duì)象
第五步：使用Session對(duì)象創(chuàng)建一個(gè)Destination對(duì)象，和發(fā)送端保持一致topic，并且話題的名稱一致
第六步：使用Session對(duì)象創(chuàng)建一個(gè)Consumer對(duì)象
第七步：接收消息
第八步：打印消息
第九步：關(guān)閉資源

代碼

@Test public void testTopicConsumser() throws Exception {//創(chuàng)建一個(gè)連接工廠對(duì)象ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");//使用連接工廠對(duì)象創(chuàng)建一個(gè)連接Connection connection = connectionFactory.createConnection();//開(kāi)啟連接connection.start();//使用連接對(duì)象創(chuàng)建一個(gè)Session對(duì)象Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);//使用Session創(chuàng)建一個(gè)Destination，Destination應(yīng)該和消息的發(fā)送端一致。Topic topic = session.createTopic("test-topic");//使用Session創(chuàng)建一個(gè)Consumer對(duì)象MessageConsumer consumer = session.createConsumer(topic);//向Consumer對(duì)象中設(shè)置一個(gè)MessageListener對(duì)象，用來(lái)接收消息consumer.setMessageListener(new MessageListener() {@Overridepublic void onMessage(Message message) {//取消息的內(nèi)容if (message instanceof TextMessage) {TextMessage textMessage = (TextMessage) message;try {String text = textMessage.getText();//打印消息內(nèi)容System.out.println(text);} catch (JMSException e) {e.printStackTrace();}}}});//系統(tǒng)等待接收消息/*while(true) {Thread.sleep(100);}*/System.out.println("topic消費(fèi)者3.。。。");System.in.read();//關(guān)閉資源consumer.close();session.close();connection.close(); }

總結(jié)

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

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