ActiveMQ HelloWorld入門

在P2P的消息模型中，雙方通過隊列交流，一個隊列只有一個生產者和一個消費者。
a、消息生產者

package com.ljq.durian.test.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.ActiveMQConnectionFactory;

/**
 * 消息的生產者（發送者）
 * 
 * @author Administrator
 * 
 */
public class JMSProducer {

    
    public static void main(String[] args) {
        try {
            //第一步：建立ConnectionFactory工廠對象，需要填入用戶名、密碼、以及要連接的地址，均使用默認即可，默認端口為"tcp://localhost:61616"
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
                    ActiveMQConnectionFactory.DEFAULT_USER, 
                    ActiveMQConnectionFactory.DEFAULT_PASSWORD, 
                    "failover:(tcp://localhost:61616)?Randomize=false");
            
            //第二步：通過ConnectionFactory工廠對象我們創建一個Connection連接，並且調用Connection的start方法開啟連接，Connection默認是關閉的。
            Connection connection = connectionFactory.createConnection();
            connection.start();
            
            //第三步：通過Connection對象創建Session會話（上下文環境對象），用於接收消息，參數配置1為是否啟用是事務，參數配置2為簽收模式，一般我們設置自動簽收。
            Session session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
            
            //第四步：通過Session創建Destination對象，指的是一個客戶端用來指定生產消息目標和消費消息來源的對象，在PTP模式中，Destination被稱作Queue即隊列；在Pub/Sub模式，Destination被稱作Topic即主題。在程序中可以使用多個Queue和Topic。
            Destination destination = session.createQueue("HelloWorld");
            
            //第五步：我們需要通過Session對象創建消息的發送和接收對象（生產者和消費者）MessageProducer/MessageConsumer。
            MessageProducer producer = session.createProducer(null);
            
            //第六步：我們可以使用MessageProducer的setDeliveryMode方法為其設置持久化特性和非持久化特性（DeliveryMode），我們稍后詳細介紹。
            //producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
            
            //第七步：最后我們使用JMS規范的TextMessage形式創建數據（通過Session對象），並用MessageProducer的send方法發送數據。同理客戶端使用receive方法進行接收數據。最后不要忘記關閉Connection連接。
            
            for(int i = 0 ; i < 10 ; i ++){
                TextMessage msg = session.createTextMessage("我是消息內容" + i);
                // 第一個參數目標地址
                // 第二個參數 具體的數據信息
                // 第三個參數 傳送數據的模式
                // 第四個參數 優先級
                // 第五個參數 消息的過期時間
                producer.send(destination, msg, DeliveryMode.NON_PERSISTENT, 0 , 1000L);
                System.out.println("發送消息：" + msg.getText());
                session.commit(); //啟用事務時記得提交事務，不然消費端接收不到消息
                Thread.sleep(1000);
            }

            if(connection != null){
                connection.close();
            }            
        } catch (Exception e) {
            e.printStackTrace();
        }
        
    }

}

b、消息消費者

package com.ljq.durian.test.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.ActiveMQConnectionFactory;

/**
 * 消息的消費者（接受者）
 * 
 * @author Administrator
 * 
 */
public class JMSConsumer {


    public static void main(String[] args)  {
        try {
            //第一步：建立ConnectionFactory工廠對象，需要填入用戶名、密碼、以及要連接的地址，均使用默認即可，默認端口為"tcp://localhost:61616"
            ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(
                    ActiveMQConnectionFactory.DEFAULT_USER, 
                    ActiveMQConnectionFactory.DEFAULT_PASSWORD, 
                    "failover:(tcp://localhost:61616)?Randomize=false");
            
            //第二步：通過ConnectionFactory工廠對象我們創建一個Connection連接，並且調用Connection的start方法開啟連接，Connection默認是關閉的。
            Connection connection = connectionFactory.createConnection();
            connection.start();
            
            //第三步：通過Connection對象創建Session會話（上下文環境對象），用於接收消息，參數配置1為是否啟用是事務，參數配置2為簽收模式，一般我們設置自動簽收。
            Session session = connection.createSession(Boolean.FALSE, Session.AUTO_ACKNOWLEDGE);
            
            //第四步：通過Session創建Destination對象，指的是一個客戶端用來指定生產消息目標和消費消息來源的對象，在PTP模式中，Destination被稱作Queue即隊列；在Pub/Sub模式，Destination被稱作Topic即主題。在程序中可以使用多個Queue和Topic。
            Destination destination = session.createQueue("HelloWorld");
            //第五步：通過Session創建MessageConsumer
            MessageConsumer consumer = session.createConsumer(destination);
            
            while(true){
                TextMessage msg = (TextMessage)consumer.receive();
                if(msg == null) {
                    break;
                }
                System.out.println("收到的內容：" + msg.getText());
            }            
        } catch (Exception e) {
            e.printStackTrace();
        }
        
    }

}

 

1、首先，啟動ActiveMQ。在瀏覽器中輸入：http://localhost:8161/admin/。
2、運行消息生產者，eclipse控制台輸出，如下圖：

3、此時，我們先看一下ActiveMQ服務器，Queues內容如下：

我們可以看到創建了一個名稱為HelloWorld的消息隊列，隊列中有10條消息未被消費，我們也可以通過Browse查看是哪些消息，如下圖：

如果這些隊列中的消息，被刪除，消費者則無法消費。

4、我們繼續運行一下消息消費者，eclipse控制台打印消息，如下：

此時，我們先看一下ActiveMQ服務器，Queues內容如下：