ActiveMQ的入門demo

　

步驟：　

1 ：下載ActiveMQ 

官網：http://activemq.apache.org/

2 ：解壓AcitveMQ,

根據自己的操作系統選擇運行win64或者win32下的activemq.bat，雙擊運行。注意：千萬不能選擇bin目錄下的activemq.bat，這樣會閃退。

我的解壓目錄為：

3：創建Java項目：

引入jar包。注意：不能少了hawtbuf-1.11.jar這個包，這個包是不能缺少的。

目錄結構如圖：

 

4：登錄本地的MQ服務：

登錄地址：http://localhost:8161/

初始賬號以及密碼：admin,admin

截圖如下：

登錄后的界面如下：

 

 

5：代碼實現：

Sender.java:

package com.lm.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;
/**
 * 
 * @author Wei
 * @time  2016年12月28日 下午8:37:38
 * 參考：http://heisetoufa.iteye.com/blog/1908335
 */
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://192.168.0.104:61616");*/
        connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,
                ActiveMQConnection.DEFAULT_PASSWORD, "tcp://localhost:61616");
        //打印出用戶和密碼
        System.out.println("ActiveMQConnection.DEFAULT_USER:" + ActiveMQConnection.DEFAULT_USER
                + ",ActiveMQConnection.DEFAULT_PASSWORD:" + ActiveMQConnection.DEFAULT_PASSWORD);
        try { // 構造從工廠得到連接對象
            connection = connectionFactory.createConnection();
            // 啟動
            connection.start();
            // 獲取操作連接
            session = connection.createSession(Boolean.TRUE, Session.AUTO_ACKNOWLEDGE);
            // 獲取session注意參數值xingbo.xu-queue是一個服務器的queue，須在在ActiveMq的console配置
            destination = session.createQueue("foo.bar");
            // 得到消息生成者【發送者】
            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);
        }
    }
}

Receiver.java:

package com.lm.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;
/**
 * 
 * @author Wei
 * @time  2016年12月28日 下午8:37:51
 * 參考：http://heisetoufa.iteye.com/blog/1908335
 */
public class Receiver {
    public static void main(String[] args) {
        int i = 0;
        
        // 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://192.168.0.104:61616");
        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注意參數值 foo.bar 是一個服務器的queue，須在在ActiveMq的console配置
            destination = session.createQueue("foo.bar");
            consumer = session.createConsumer(destination);
            while (true) {
                // 設置接收者接收消息的時間，為了便於測試，這里誰定為100s
                TextMessage message = (TextMessage) consumer.receive();
                if (null != message) {
                    i++;
                    System.out.println("收到消息" + i +":"+ message.getText());
                } else {
                    break;
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            try {
                if (null != connection)
                    connection.close();
            } catch (Throwable ignore) {
            }
        }
    }
}

使用 MQ編輯內容點擊send按鈕進行發送，

eclipse中Receiver的控制台的輸出為：

收到消息17:Enter some text here for the message body...

這里可以編輯發送的內容等。
當然了，也可用過Java代碼來進行消息隊列的發送。

 

源碼：鏈接：http://pan.baidu.com/s/1hsskzic 密碼：8bty