Consumer

消費者，接收消息

接收步驟

第一步：創建一個ConnectionFactory對象
第二步：從ConnectionFactory對象中獲得一個Connection對象
第三步：開啟連接。調用Connection對象的start方法
第四步：使用Connection對象創建一個Session對象
第五步：使用Session對象創建一個Destination對象，和發送端保持一致topic，并且話題的名稱一致
第六步：使用Session對象創建一個Consumer對象
第七步：接收消息
第八步：打印消息
第九步：關閉資源

代碼

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

總結

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

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