基本概念

JMS(Java Message Service)即java訊息服務。它提供了標準的生產、傳送和接收資訊的藉口，簡化了企業開發的流程。它提供了兩種方式的訊息通訊模型：點對點的模型、釋出/點閱模型。

重要的幾個概念：

• Destination：訊息傳送的目的地
• Message：被髮送的訊息，它包括資料流、map和普通text等型別。
• Session：資訊生成者與訊息服務JMS建立的會話，只能通過session建立Message。
• Connection：資訊生產者與訊息服務JMS建立的連線，通過它建立Session。
• ConnectionFactory：連線工廠。
• Producer：訊息生產者。
• MessageConsumer：訊息的消費者。

下面是一個基於ActiveMQ訊息伺服器的例子

/** 
 * @author Administrator 
 * @desctiption 結合一個例子，深入理解JMS的基本概念 
 * 訊息的消費者接收訊息可以採用兩種方式： 
 * 1、consumer.receive() 或 consumer.receive(int timeout)； 
 * 2、註冊一個MessageListener。 
 * 採用第一種方式，訊息的接收者會一直等待下去，直到有訊息到達，或者超時。 
 * 後一種方式會註冊一個監聽器，當有訊息到達的時候，會回撥它的onMessage()方法。 
 */
 
  
package com.wl.jms;  

import javax.jms.Connection;  
import javax.jms.ConnectionFactory;  
import javax.jms.JMSException;  
import javax.jms.Message;  
import javax.jms.MessageConsumer;  
import javax.jms.MessageListener;  
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 {  

    /** 
     * @param args 
     * @throws JMSException  
     */  
    public static void main(String[] args) throws JMSException {  
        // TODO Auto-generated method stub  
        ConnectionFactory factory = new ActiveMQConnectionFactory("vm://localhost");    

        Connection connection = factory.createConnection();    
        connection.start();    
        //建立訊息的Destination   
        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);   
        //訊息的消費者接收訊息的第一種方式：consumer.receive() 或 consumer.receive(int timeout)；  
        //Message recvMessage = comsumer.receive();    
        //System.out.println(((TextMessage)recvMessage).getText());   
        //訊息的消費者接收訊息的第二種方式：註冊一個MessageListener  
        comsumer.setMessageListener(new MessageListener(){  
            public void onMessage(Message msg) {  
                // TODO Auto-generated method stub  
                TextMessage textMsg=(TextMessage)msg;  
                try {  
                    System.out.println(textMsg.getText());  
                } catch (JMSException e) {  
                    e.printStackTrace();  
                }  
            }  

        });  
    }  

}