準備工作

 下載

下載版本有Windows和Linux兩個版本，且都分為32位和64位。根據自己需要選擇下載。

 安裝

我這裡下載的為windows的32位版本（apache-activemq-5.8.0-bin.zip），下載後直接解壓到需要安裝的目錄或在直接解壓到當前目錄也可，解壓完安裝也完成。

解壓後目錄如上圖，裡面包含了示例和文件，及所有的jar包。

執行

進入到bin目錄（apache-activemq-5.8.0\bin），雙擊activemq.bat，就會執行，執行截圖如下：

此時表示ActiveMQ已經在運行了，當然正常生產環境下可以設定作為服務在後臺執行，並且隨系統啟動而啟動。

測試

預設使用者名稱和密碼都是admin，進入後則為主介面：

在這個介面上，我們可以管理佇列及其他的一些功能，為了下面的繼續，我們在這裡建立一個Queue和一個Topic。

點選目錄上的Queues進入建立Queue頁面，輸入Queue名稱，點選Create後下面就建立了G2Queue的queue佇列。

這裡也可以不用這樣手工建立，在傳送端指定了一個Queue或Topic名字後，會自動建立一個佇列，如上面的choice.queue和FirstQueue都是我測試程式時，程式裡面指定的Queue名稱，自動建立的。

同樣的方式建立一個Topic，如下：

需要引用的jar包

<dependency>
			<groupId>org.apache.activemq</groupId>
			<artifactId>activemq-all</artifactId>
			<version>5.11.2</version>
		</dependency>
 

傳送訊息

import java.util.Random;
 
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
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://localhost:61616";
    private static final String QUEUE_NAME = "G2Queue";
 
    public void sendMessage() throwsJMSException {
       // JMS 客戶端到JMSProvider 的連線
       Connection connection = null;
       try {
           // 連線工廠，JMS 用它建立連線
           // 構造ConnectionFactory例項物件，此處採用ActiveMq的實現jar
           ConnectionFactory connectionFactory = newActiveMQConnectionFactory(url);
           connection = (Connection)connectionFactory.createConnection();
           // 啟動連線
           connection.start();
           //Session：傳送或接收訊息的執行緒
           // 獲取session
           Session session = (Session) connection.createSession(false,
                  Session.AUTO_ACKNOWLEDGE);
           // 訊息的目的地，訊息傳送到那個佇列
           Destination destination = session.createQueue(QUEUE_NAME);
           //MessageProducer：訊息傳送者（生產者）
           // 建立訊息傳送者
           MessageProducer producer =session.createProducer(destination);
           // 設定是否持久化
           //DeliveryMode.NON_PERSISTENT：不持久化
           //DeliveryMode.PERSISTENT：持久化
           producer.setDeliveryMode(DeliveryMode.PERSISTENT);
          
           String msg = "";
           int i = 0;
        do {
            msg = "第"+i + "次傳送的訊息："+new Random();
                TextMessagemessage = session.createTextMessage(msg);
                Thread.sleep(1000);
                // 傳送訊息到目的地方
               producer.send(message);
                System.out.println("傳送訊息：" +msg);
                i++;
        } while (i<1000);
       } catch (Exception e) {
           e.printStackTrace();
       }
    }
 
    public static void main(String[] args) {
       SendMessage sndMsg = newSendMessage();
       try {
           sndMsg.sendMessage();
       } catch (Exception ex) {
           System.out.println(ex.toString());
       }
    }
}
 

執行結果如下：

接收訊息

package cn.g2room.mq.test;
 
import javax.jms.Connection;
import javax.jms.ConnectionFactory;
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;
 
/**
 * 訊息接收類
 *
 * @createTime:Apr 7, 2013 5:11:11 PM
 * @author:<a href="mailto:[email protected]">迷蝶</a>
 * @version:0.1
 *@lastVersion: 0.1
 * @updateTime:
 *@updateAuthor: <a href="mailto:[email protected]">迷蝶</a>
 * @changesSum:
 *
 */
public class ReceiveMessage {
         privatestatic final String url = "tcp://localhost:61616";
         privatestatic final String QUEUE_NAME = "G2Queue";
 
         publicvoid receiveMessage() {
                   Connectionconnection = null;
                   try{
                            try{
                                     ConnectionFactoryconnectionFactory = new ActiveMQConnectionFactory(
                                                        url);
                                     connection= connectionFactory.createConnection();
                            }catch (Exception e) {
                                     System.out.println(e.toString());
                            }
                            connection.start();
                            Sessionsession = connection.createSession(false,
                                               Session.AUTO_ACKNOWLEDGE);
                            Destinationdestination = session.createQueue(QUEUE_NAME);
                            //訊息接收者，也就是消費者
                            MessageConsumerconsumer = session.createConsumer(destination);
                           
                            consumeMessagesAndClose(connection,session, consumer);
                   }catch (Exception e) {
                            System.out.println(e.toString());
                   }
         }
         /**
          * 接收和關閉訊息，如遇到訊息內容為close則，關閉連線
          *
          * @param connection   JMS 客戶端到JMSProvider 的連線
          * @param session                   傳送或接收訊息的執行緒
          * @param consumer              訊息接收物件
          * @throws JMSException
          * @auther <ahref="mailto:[email protected]">迷蝶</a>
          * Apr 8, 2013 10:31:55 AM
          */
         protectedvoid consumeMessagesAndClose(Connection connection,
                            Sessionsession, MessageConsumer consumer) throws JMSException {
                   do{
                            Messagemessage = consumer.receive(1000);
                            if("close".equals(message)){
                                     consumer.close();
                                     session.close();
                                     connection.close();
                            }
                            if(message != null) {
                                     onMessage(message);
                            }
                   }while (true);
                  
         }
 
         publicvoid onMessage(Message message) {
                   try{
                            if(message instanceof TextMessage) {
                                     TextMessagetxtMsg = (TextMessage) message;
                                     Stringmsg = txtMsg.getText();
                                     System.out.println("Received:" + msg);
                            }
                   }catch (Exception e) {
                            e.printStackTrace();
                   }
 
         }
 
         publicstatic void main(String args[]) {
                   ReceiveMessagerm = new ReceiveMessage();
                   rm.receiveMessage();
         }
}

執行結果如下：

至此結束

本文轉自：http://blog.csdn.net/leadergg/article/details/8771218