Java消息服務JMS詳解
Java消息服務(JMS Java Message Services)提供了點對點模式(Point-to-Point Queue)和發布-訂閱模式(Publish-Subscribe Topics).
Queue僅允許一個消息傳送給一個客戶（一對一）:
Java消息服務JMS的接收者和發送者之間不存在時間上的依賴關系。不論發送者發送消息時接收者是否在運行，接收者都可以提取信息。接收者對于成功處理的消息給出回執。
Topics可以有多個客戶端（一對多，多對多）:
向某個話題訂閱的客戶程序只能收到那些在它訂閱之后發布的消息。為了接收到消息，訂閱者必須保持活動狀態。因此，發布者和訂閱者之間存在時間上的依賴關系。
點對點消息模式通過一個消息隊列(Queue)實現，消息的生產者向隊列寫入消息，消息的訂閱者從隊列提取消息。發布-訂閱消息模式通過一個話題（Topic）節點構成的層次結構實現，消息的生產者向這個層次結構發布消息，消息的訂閱者向這個結構訂閱消息。
消息驅動的Bean只有一個Bean類。從某些方面看，JMS消息驅動的Bean類似于無狀態會話Bean：消息驅動的Bean不為特定的客戶保留數據或對話狀態。
- @MessageDriven(activationConfig={
- @ActivationConfigProperty(propertyName="destinationType",propertyValue="javax.jms.Queue"),
- @ActivationConfigProperty(propertyName="destination",propertyValue="queue/jms")
- })
@MessageDriven注釋指明這是一個消息驅動Bean，并使用@ActivationConfigProperty注釋配置消息的各種屬性，其 中destinationType屬性指定消息的類型，消息有兩種類型topics 和queues，下面是這兩種消息類型的介紹：
Topics 可以有多個客戶端。用topic發布允許一對多，或多對多通訊通道。消息的產生者被叫做publisher, Java消息服務接受者叫做subscriber。destinationType屬性對應值：javax.jms.Topic
Queue 僅僅允許一個消息傳送給一個客戶。一個發送者將消息放入消息隊列，接受者從隊列中抽取并得到消息，消息就會在隊列中消失。第一個接受者抽取并得到消息后，其他人就不能再得到它。destinationType屬性對應值：javax.jms.Queue destination屬性用作指定消息路徑，消息驅動Bean在發布時，如果路徑不存在，容器會自動創建該路徑，當容器關閉時該路徑會自動被刪除
當一個消息到達queue/jms隊列時，就會觸發onMessage方法，消息作為一個參數傳入.
- package com.julycn.jms;
- import javax.ejb.ActivationConfigProperty;
- import javax.ejb.MessageDriven;
- import javax.jms.JMSException;
- import javax.jms.Message;
- import javax.jms.MessageListener;
- import javax.jms.TextMessage;
- @MessageDriven(activationConfig = {
- @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
- @ActivationConfigProperty(propertyName = "destination", propertyValue = "queue/jms") })
- public class MessageQueue implements MessageListener {
- public MessageQueue() {
- }
- public void onMessage(Message message) {
- TextMessage tmsg = (TextMessage) message;
- try {
- System.out.println(tmsg.getText());
- } catch (JMSException e) {
- e.printStackTrace();
- }
- }
- }
- package com.julycn.client;
- import javax.jms.JMSException;
- import javax.jms.Queue;
- import javax.jms.QueueConnection;
- import javax.jms.QueueConnectionFactory;
- import javax.jms.QueueSender;
- import javax.jms.QueueSession;
- import javax.jms.TextMessage;
- import javax.naming.InitialContext;
- import javax.naming.NamingException;
- public class MessageQueueClient {
- public static void main(String[] args) {
- QueueConnection conn;
- QueueSession session;
- Queue queue;
- QueueSender sender;
- TextMessage msg;
- try {
- InitialContext ctx = new InitialContext();
- QueueConnectionFactory qcf = (QueueConnectionFactory) ctx
- .lookup("ConnectionFactory");
- conn = qcf.createQueueConnection();
- session = conn.createQueueSession(false,
- QueueSession.AUTO_ACKNOWLEDGE);
- queue = (Queue) ctx.lookup("queue/jms");
- msg = session.createTextMessage("你好，好久不見！");
- sender = session.createSender(queue);
- sender.send(msg);
- sender.close();
- } catch (NamingException e) {
- e.printStackTrace();
- } catch (JMSException e) {
- e.printStackTrace();
- }
- }
- }
(1) 得到一個JNDI初始化上下文(Context)；
例子對應代碼：
Properties props = new Properties();
props.setProperty("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
props.setProperty("java.naming.provider.url", "localhost:1099");
props.setProperty("java.naming.factory.url.pkgs", "org.jboss.naming");
InitialContext ctx = new InitialContext(props);
注意：可以寫在代碼中，也可以寫在jndi.properties文件中.
(2) 根據上下文來查找一個連接工廠TopicConnectFactory/ QueueConnectionFactory (有兩種連接工廠，根據是topic/queue來使用相應的類型)；
例子對應代碼：
QueueConnectionFactory qcf =(QueueConnectionFactory) ctx.lookup("ConnectionFactory");
(3) 從連接工廠得到一個連接(Connect 有兩種[TopicConnection/ QueueConnection]);
例子對應代碼：conn = qcf.createQueueConnection();
(4) 通過連接來建立一個會話(Session);
例子對應代碼：session= conn.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE);
這句代碼意思是：建立不需要事務的并且能自動接收Java消息服務收條的會話，在非事務Session 中，JMS消息傳遞的方式有三種：
Session.AUTO_ACKNOWLEDGE ：當客戶機調用的receive方法成功返回，或當MessageListenser 成功處理了消息，session將會自動接收消息的收條。
Session.CLIENT_ACKNOWLEDGE ：客戶機通過調用消息的acknowledge方法來接收消息。接收發生在session層。接收到一個被消費的消息時，將自動接收該session已經 消費的所有消息。例如：如果消息的消費者消費了10條消息，然后接收15 個被傳遞的消息，則前面的10 個消息的收據都會在這15 個消息中被接收。
Session.DUPS_ACKNOWLEDGE ：指示session緩慢接收消息。
(5) 查找目的地(Topic/ Queue);
例子對應代碼：queue =(Queue) ctx.lookup("queue/jms");
(6) 根據會話以及目的地來建立消息制造者(TopicPublisher/QueueSender)和消費者(TopicSubscriber/QueueReceiver).
例子對應代碼：
msg = session.createTextMessage("你好，好久不見！");
sender = session.createSender(queue);
sender.send(msg);
備注：如果運行時出現javax.naming.NameNotFoundException: jms not bound ， 是因為JBoss不會自已建立一個Queue對象，因此，需要手工來配置Queue對象。可以<JBoss5.x安裝目錄>\server\default\deploy目錄中建立一個xxx-service.xml文件，其中xxx可以任意取值，但必須跟“-service”后綴，例如，abc-service.xml。該文件可以放在deploy或其子目錄（可以是多層子目錄）中。該文件的內容如下：
- <?xml version="1.0" encoding="UTF-8"?>
- <server>
- <mbean code="org.jboss.mq.server.jmx.Queue" name="jboss.mq.destination:service=Queue,name=jms">
- <depends optional-attribute-name="DestinationManager">
- jboss.mq:service=DestinationManager</depends>
- </mbean>
- </server>
<mbean>元素的name屬性值中的name必須是jms，要與queue/jms中的/后面的部分一致.
【編輯推薦】
