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

接收步驟

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

代碼

@Test public void testQueueConsumer() throws Exception {//創(chuàng)建一個(gè)連接工廠對(duì)象ConnectionFactory connectionFactory = new ActiveMQConnectionFactory("tcp://192.168.25.168:61616");//使用連接工廠對(duì)象創(chuàng)建一個(gè)連接Connection connection = connectionFactory.createConnection();//開啟連接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ā)送端一致。Queue queue = session.createQueue("test-queue");//使用Session創(chuàng)建一個(gè)Consumer對(duì)象MessageConsumer consumer = session.createConsumer(queue);//向Consumer對(duì)象中設(shè)置一個(gè)MessageListener對(duì)象，用來接收消息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.in.read();//關(guān)閉資源consumer.close();session.close();connection.close(); }

總結(jié)

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

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