1.下載ActiveMQ

2.執行ActiveMQ

解壓縮apache-activemq-5.10.0-bin.zip，

window系統啟動方式：

cd bin

activemq.bat start

linux系統啟動方式：

cd bin

./activemq console

停止：

ctrl + c

後臺執行啟動方式（linux）:

./bin/activemq start

這是日誌會寫到 data/activemq.log 檔案中。

停止命令：

window：

 cd bin
 activemq.bat stop

linux:

./bin/activemq stop

3.建立Eclipse專案並執行

建立project匯入jar檔案:

3.1.Sender.java  生產者程式

package com.xuwei.activemq;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.MessageProducer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection;
import
 
 org.apache.activemq.ActiveMQConnectionFactory;

public class Sender {
private static final int SEND_NUMBER = 5;

public static void main(String[] args) {
// ConnectionFactory ：連線工廠，JMS 用它建立連線        ConnectionFactory connectionFactory;
// Connection ：JMS 客戶端到JMS Provider 的連線        Connection connection = null
 
;
// Session： 一個傳送或接收訊息的執行緒        Session session;
// Destination ：訊息的目的地;訊息傳送給誰.        Destination destination;
// MessageProducer：訊息傳送者        MessageProducer producer;
// TextMessage message;
// 構造ConnectionFactory例項物件，此處採用ActiveMq的實現jar        connectionFactory = new ActiveMQConnectionFactory(
                ActiveMQConnection.DEFAULT_USER,
                ActiveMQConnection.DEFAULT_PASSWORD,
                "tcp://localhost:61616");
try {
// 構造從工廠得到連線物件            connection = connectionFactory.createConnection();
// 啟動            connection.start();
// 獲取操作連線            session = connection.createSession(Boolean.TRUE,
                    Session.AUTO_ACKNOWLEDGE);
// 獲取session注意引數值xingbo.xu-queue是一個伺服器的queue，須在在ActiveMq的console配置            destination = session.createQueue("FirstQueue");
// 得到訊息生成者【傳送者】            producer = session.createProducer(destination);
// 設定不持久化，此處學習，實際根據專案決定            producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
// 構造訊息，此處寫死，專案就是引數，或者方法獲取            sendMessage(session, producer);
            session.commit();
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
try {
if (null != connection)
                    connection.close();
            } catch (Throwable ignore) {
            }
        }
    }

public static void sendMessage(Session session, MessageProducer producer)
throws Exception {
for (int i = 1; i <= SEND_NUMBER; i++) {
            TextMessage message = session
                    .createTextMessage("ActiveMq 傳送的訊息" + i);
// 傳送訊息到目的地方            System.out.println("傳送訊息：" + "ActiveMq 傳送的訊息" + i);
            producer.send(message);
        }
    }
}

3.2.Receiver.java    消費者程式

package com.xuwei.activemq;

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

public class Receiver {
public static void main(String[] args) {
// ConnectionFactory ：連線工廠，JMS 用它建立連線        ConnectionFactory connectionFactory;
// Connection ：JMS 客戶端到JMS Provider 的連線        Connection connection = null;
// Session： 一個傳送或接收訊息的執行緒        Session session;
// Destination ：訊息的目的地;訊息傳送給誰.        Destination destination;
// 消費者，訊息接收者        MessageConsumer consumer;
        connectionFactory = new ActiveMQConnectionFactory(
                ActiveMQConnection.DEFAULT_USER,
                ActiveMQConnection.DEFAULT_PASSWORD,
                "tcp://localhost:61616");
try {
// 構造從工廠得到連線物件            connection = connectionFactory.createConnection();
// 啟動            connection.start();
// 獲取操作連線            session = connection.createSession(Boolean.FALSE,
                    Session.AUTO_ACKNOWLEDGE);
// 獲取session注意引數值xingbo.xu-queue是一個伺服器的queue，須在在ActiveMq的console配置            destination = session.createQueue("FirstQueue");
            consumer = session.createConsumer(destination);
while (true) {
//設定接收者接收訊息的時間，為了便於測試，這裡誰定為100s                TextMessage message = (TextMessage) consumer.receive(100000);
if (null != message) {
                    System.out.println("收到訊息" + message.getText());
                } else {
break;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
try {
if (null != connection)
                    connection.close();
            } catch (Throwable ignore) {
            }
        }
    }
}

4.注意事項

1. 專案所引用的jar最好在ActiveMQ下的lib中找，這樣不會出現版本衝突。

5.測試過程

因為是在單機上測試，所以需要開啟兩個eclipse，每一個eclipse都有自身的workspace。我們在eclipse1中執行Receiver，在eclipse2中執行Sender。

剛開始eclipse1中執行Receiver以後console介面沒有任何資訊，在eclipse2中執行Sender以後，eclipse2中的console顯示如下資訊：

傳送訊息：ActiveMq 傳送的訊息1
傳送訊息：ActiveMq 傳送的訊息2
傳送訊息：ActiveMq 傳送的訊息3
傳送訊息：ActiveMq 傳送的訊息4
傳送訊息：ActiveMq 傳送的訊息5

而回到eclipse1中發現console介面出現如下資訊：

收到訊息ActiveMq 傳送的訊息1
收到訊息ActiveMq 傳送的訊息2
收到訊息ActiveMq 傳送的訊息3
收到訊息ActiveMq 傳送的訊息4
收到訊息ActiveMq 傳送的訊息5

 PS:2012-2-27

今天發現測試並不需要開啟兩個eclipse，在一個eclipse下頁可以啟動多個程式，並且有多個console，在上面的Receiver.java中，設定一個較大的時間，比如receive(500000)，如下程式碼所示：

TextMessage message = (TextMessage) consumer.receive(500000);

這個時候執行Receiver.java的話，會使得這個Receiver.java一直執行500秒，在eclipse中可以發現：

點選那個紅色方塊可以手動停止執行程式。

執行玩receiver以後我們在執行sender，在執行完sender以後，我們要切換到receiver的console，如下圖所示：