厚積而薄發(fā)

轉(zhuǎn)http://hi.baidu.com/yonered/blog/item/a38d77188dbc9e0f34fa412d.html

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

按照上一講的這個簡圖,

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

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

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

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

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

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

下面就可以發(fā)送剛才創(chuàng)建的消息了：
producer.send(message);

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

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

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

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());
    }

}