1.JMS介紹
JMS源于企業應用對于消息中間件的需求，使應用程序可以通過消息進行異步處理而互不影響。Sun公司和它的合作伙伴設計的JMS API定義了一組公共的應用程序接口和相應語法，使得Java程序能夠和其他消息組件進行通信。JMS有四個組成部分：JMS服務提供者、消息管理對象、消息的生產者消費者和消息本身。
1)JMS服務提供者實現消息隊列和通知，同時實現消息管理的API。JMS已經是J2EE API的一部分，J2EE服務器都提供JMS服務。
2) 消息管理對象提供對消息進行操作的API。JMS API中有兩個消息管理對象：創建jms連接使用的工廠（ConnectionFactory）和目的地（Destination），根據消息的消費方式的不同ConnectionFactory可以分為QueueConnectionFactory和TopicConnectionFactory，目的地（Destination）可以分為隊列（Queue）和主題（Topic）兩種。
3)消息的生產者和消費者。消息的產生由JMS的客戶端完成，JMS服務提供者負責管理這些消息，消息的消費者可以接收消息。消息的生產者可以分為――點對點消息發布者（P2P）和主題消息發布者（TopicPublisher）。所以，消息的消費者分為兩類：主題消息的訂閱者（TopicSubscriber)和點對點消息的接收者（queue receiver）
4)消息。消息是服務提供者和客戶端之間傳遞信息所使用的信息單元。JMS消息由以下三部分組成：
消息頭（header）――JMS消息頭包含了許多字段，它們是消息發送后由JMS提供者或消息發送者產生，用來表示消息、設置優先權和失效時間等等，并且為消息確定路由。
屬性（property）――用來添加刪除消息頭以外的附加信息。
消息體（body）――JMS中定義了5種消息體：ByteMessage、MapMessage、ObjectMessage、StreamMessage和TextMessage。
2.Messages 通信方式
上面提到JMS通信方式分為點對點通信和發布/訂閱方式
1)點對點方式（point-to-point）
點對點的消息發送方式主要建立在 Message Queue,Sender,reciever上，Message Queue 存貯消息，Sneder 發送消息，receive接收消息.具體點就是Sender Client發送Message Queue ,而 receiver Cliernt從Queue中接收消息和"發送消息已接受"到Quere,確認消息接收。消息發送客戶端與接收客戶端沒有時間上的依賴，發送客戶端可以在任何時刻發送信息到Queue，而不需要知道接收客戶端是不是在運行
2)發布/訂閱 方式（publish/subscriber Messaging）
發布/訂閱方式用于多接收客戶端的方式.作為發布訂閱的方式，可能存在多個接收客戶端，并且接收端客戶端與發送客戶端存在時間上的依賴。一個接收端只能接收他創建以后發送客戶端發送的信息。作為subscriber ,在接收消息時有兩種方法，destination的receive方法，和實現message listener 接口的onMessage 方法。
3.為什么選用ActiveMQ
1）ActiveMQ是一個開放源碼
2）基于Apache 2.0 licenced 發布并實現了JMS 1.1。
3）ActiveMQ現在已經和作為很多項目的異步消息通信核心了
4）在很多中小型項目中采用ActiveMQ+SPRING+TOMCAT開發模式。
4.編程模式
4.1消息產生者向JMS發送消息的步驟
(1)創建連接使用的工廠類JMS ConnectionFactory
(2)使用管理對象JMS ConnectionFactory建立連接Connection
(3)使用連接Connection 建立會話Session
(4)使用會話Session和管理對象Destination創建消息生產者MessageSender
(5)使用消息生產者MessageSender發送消息
4.2消息消費者從JMS接受消息的步驟
(1)創建連接使用的工廠類JMS ConnectionFactory
(2)使用管理對象JMS ConnectionFactory建立連接Connection
(3)使用連接Connection 建立會話Session
(4)使用會話Session和管理對象Destination創建消息消費者MessageReceiver
(5)使用消息消費者MessageReceiver接受消息，需要用setMessageListener將MessageListener接口綁定到MessageReceiver
消息消費者必須實現了MessageListener接口，需要定義onMessage事件方法。
5.ActiveMQ運行
ActiveMQ5.0版本默認啟動時，啟動了內置的jetty服務器，提供一個demo應用和用于監控ActiveMQ的admin應用。運行%activemq_home%bin/目錄下的 activemq.bat , 之后你會看見如下一段話表示啟動成功。
打開http://www.bt285.cn /admin/queues.jsp ，可以查看相應的queue中是否有消息
6.SendMessage(用于發送消息)
import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
public class SendMessage 
{
private static final String url ="tcp://www.5a520.cn :61616";
private static final String QUEUE_NAME ="choice.queue";
protected String expectedBody = "<hello>http://www.guihua.org 中國桂花樹!</hello>";
public void sendMessage() throws JMSException{
Connection connection =null;
try{
ActiveMQConnectionFactory connectionFactory =new ActiveMQConnectionFactory(url);
connection = (Connection)connectionFactory.createConnection();
connection.start();
Session session = (Session)connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue(QUEUE_NAME);
MessageProducer producer = session.createProducer(destination);
TextMessage message = session.createTextMessage(expectedBody);
message.setStringProperty("headname", "remoteB");
producer.send(message);
}catch(Exception e){
e.printStackTrace();
}
}
public static void main(String[] args){
SendMessage sndMsg = new SendMessage();
try{
sndMsg.sendMessage();
}catch(Exception ex){
System.out.println(ex.toString());
}
}
}
7.ReceiveMessage(用于接收消息)
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import javax.jms.BytesMessage;
import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
public class ReceiveMessage {
private static final String url = "tcp:// www.5a520.cn :61616";
private static final String QUEUE_NAME = "choice.queue";
public void receiveMessage() {
Connection connection = null;
try {
try {
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
connection = connectionFactory.createConnection();
} catch (Exception e) {
System.out.println(e.toString());
}
connection.start();
Session session = connection.createSession(false,
Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue(QUEUE_NAME);
MessageConsumer consumer = session.createConsumer(destination);
consumeMessagesAndClose(connection, session, consumer);
} catch (Exception e) {
System.out.println(e.toString());
}
}
protected void consumeMessagesAndClose(Connection connection,Session session, MessageConsumer consumer)
throws JMSException {
for (int i = 0; i < 1;) {
Message message = consumer.receive(1000);
if (message != null) {
i++;
onMessage(message);
}
}
System.out.println("Closing connection");
consumer.close();
session.close();
connection.close();
}
public void onMessage(Message message) {
try {
if (message instanceof TextMessage) {
TextMessage txtMsg = (TextMessage) message;
String msg = txtMsg.getText();
System.out.println("Received: " + msg);
}
} catch (Exception e) {
e.printStackTrace();
}
}
public static void main(String args[]) {
ReceiveMessage rm = new ReceiveMessage();
rm.receiveMessage();
}
}