?前一講簡單的介紹了一下JMS的基本概念, 這一講結合一個例子讓大家深入理解前一講的基本概念. 首先需要做的是選擇一個JMS提供者, 如果在JavaEE環境中可以不用考慮這些. 我們選擇ActiveMQ, 官方地址: http://activemq.apache.org/. 網上有很多介紹ActiveMQ的文檔, 所以在這里就不介紹了.

按照上一講的這個簡圖,

? ConnectionFactory---->Connection--->Session--->Message
? Destination + Session------------------------------------>Producer
? Destination + Session------------------------------------>MessageConsumer

首先需要得到ConnectionFactoy和Destination，這里創建一個一對一的Queue作為Destination。
? ConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");
? Queue queue = new ActiveMQQueue("testQueue");

然后又ConnectionFactory創建一個Connection, 再啟動這個Connection:
? Connection connection = factory.createConnection();
? connection.start();

接下來需要由Connection創建一個Session:
? Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE)
??? 現在暫且不用管參數的含義, 以后會詳細講到.

下面就可以創建Message了,這里創建一個TextMessage。
? Message message = session.createTextMessage("Hello JMS!");

要想把剛才創建的消息發送出去，需要由Session和Destination創建一個消息生產者：
? MessageProducer producer = session.createProducer(queue);

下面就可以發送剛才創建的消息了：
? producer.send(message);

消息發送完成之后，我們需要創建一個消息消費者來接收這個消息：
? MessageConsumer comsumer = session.createConsumer(queue);
? Message recvMessage = comsumer.receive();

消息消費者接收到這個消息之后，就可以得到它的內容：
? System.out.println(((TextMessage)recvMessage).getText());

至此，一個簡單的JMS例子就完成了。下面是全部源碼 ：

?

view plaincopy to clipboardprint?

import?javax.jms.Connection;??

import?javax.jms.Message;??

import?javax.jms.MessageConsumer;??

import?javax.jms.MessageProducer;??

import?javax.jms.Queue;??

import?javax.jms.Session;??

import?javax.jms.TextMessage;??

import?org.apache.activemq.ActiveMQConnectionFactory;??

import?org.apache.activemq.command.ActiveMQQueue;??

public?class?MessageSendAndReceive?{??

????public?static?void?main(String[]?args)?throws?Exception?{??

????????ConnectionFactory?factory?=?new?ActiveMQConnectionFactory("vm://localhost");??

?????

????????Connection?connection?=?factory.createConnection();??

????????connection.start();??

?????????

????????Queue?queue?=?new?ActiveMQQueue("testQueue");??

?????????

????????final?Session?session?=?connection.createSession(false,?Session.AUTO_ACKNOWLEDGE);??

????????Message?message?=?session.createTextMessage("Hello?JMS!");??

?????????

????????MessageProducer?producer?=?session.createProducer(queue);??

????????producer.send(message);??

?????

????????System.out.println("Send?Message?Completed!");??

?????????

????????MessageConsumer?comsumer?=?session.createConsumer(queue);??

????????Message?recvMessage?=?comsumer.receive();??

????????System.out.println(((TextMessage)recvMessage).getText());??

????}??

} ?

?

新人創作打卡挑戰賽發博客就能抽獎！定制產品紅包拿不停！

總結

以上是生活随笔為你收集整理的深入掌握JMS（二）：一个JMS例子的全部內容，希望文章能夠幫你解決所遇到的問題。

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