上一章我們講解了簡單的activemq的定義和使用場景，這一節我們來看一下例項。
首先在官網下載相應的安裝包，如果是windows系統，直接下載安裝，解壓執行對應位數的activemq.bat命令就可以了，然後可以登入http://localhost:8161/檢視activemq的控制檯實時檢視訊息的去向和連線，帳號密碼都是admin。
首先建立一個簡單的maven專案，你用eclipse和idea都不影響。
新增依賴

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

先看佇列模式：
建立一個生產者AppProducer

package cn.com.queue;

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

import
 
 javax.jms.*;

/**
 * ${佇列模式的生產者}
 *
 * @author lightTrace
 * @create 2017-11-26 18:30
 **/
public class AppProducer {

    private static final String BROKER_URL = ActiveMQConnection.DEFAULT_BROKER_URL;//預設接收發送訊息地址，大家可酌情修改
    private final static String queueName = "queue-test";
    public static void main
 
(String[] args) throws JMSException {
        //1.建立我們的連線工廠
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);
        //2.建立連線
        Connection connection = connectionFactory.createConnection();
        //3.啟動連線
        connection.start();
        //4.建立回話
        Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
        //5.指定一個目的地
        Destination destination = session.createQueue(queueName);
        //6.建立一個生產者
        MessageProducer messageProducer = session.createProducer(destination);
        for(int i=0;i<100;i++){
            //7.建立訊息
            TextMessage textMessage = session.createTextMessage("test"+i);
            //8.釋出訊息
            messageProducer.send(textMessage);
            System.out.println("傳送訊息"+textMessage.getText());
        }
        //9.關閉連線
        session.close();
        connection.close();
    }
}

然後main方法執行檢視後臺QUEUES：

發現有一百個訊息建立，name就是程式碼中的queueName，用於指定目的地，下面的消費者就從這個目的地就收訊息
消費者：

package cn.com.queue;

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;
import javax.jms.*;

/**
 * ${DESCRIPTION}
 * @author lightTrace
 * @create 2017-11-26 19:07
 **/
public class AppCosumer {

    private static final String BROKER_URL = ActiveMQConnection.DEFAULT_BROKER_URL;
    private final static String queueName = "queue-test";
    public static void main(String[] args) throws JMSException {
        //1.建立我們的連線工廠
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);
        //2.建立連線
        Connection connection = connectionFactory.createConnection();
        //3.啟動連線
        connection.start();
        //4.建立回話
        Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
        //5.指定一個目的地
        Destination destination = session.createQueue(queueName);
        //6.建立一個消費者
        MessageConsumer messageConsumer = session.createConsumer(destination);
        //7.建立一個監聽器
        messageConsumer.setMessageListener(new MessageListener() {
            public void onMessage(Message message) {
                TextMessage textMessage = (TextMessage) message;
                try {
                    System.out.println("接收訊息"+textMessage.getText());
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        });

    }
}

執行消費者之後：

大家可以看到控制檯的變化，如果你先開啟兩個消費者，再用生產者生產訊息會發現兩個消費者會交替消費，一條資訊只會被一個消費者消費

下面再看下主題模式：
主題模式只需要在佇列模式的基礎上修改少部分即可，首先生產者：

package cn.com.topic;

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * ${DESCRIPTION}
 *
 * @author lightTrace
 * @create 2017-11-26 18:30
 **/
public class AppProducer {

    private static final String BROKER_URL = ActiveMQConnection.DEFAULT_BROKER_URL;
    private final static String topicName = "topic-test";//換一個名字
    public static void main(String[] args) throws JMSException {
        //1.建立我們的連線工廠
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);
        //2.建立連線
        Connection connection = connectionFactory.createConnection();
        //3.啟動連線
        connection.start();
        //4.建立回話
        Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
        //5.指定一個目的地，這裡不同
        Destination destination = session.createTopic(topicName);
        //6.建立一個生產者
        MessageProducer messageProducer = session.createProducer(destination);
        for(int i=0;i<100;i++){
            //7.建立訊息
            TextMessage textMessage = session.createTextMessage("test"+i);
            //8.釋出訊息
            messageProducer.send(textMessage);
            System.out.println("傳送訊息"+textMessage.getText());
        }
        //9.關閉連線
        session.close();
        connection.close();
    }
}

執行：

然後消費者：

package cn.com.topic;

import org.apache.activemq.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

import javax.jms.*;

/**
 * ${DESCRIPTION}
 * @author lightTrace
 * @create 2017-11-26 19:07
 **/
public class AppCosumer {

    private static final String BROKER_URL = ActiveMQConnection.DEFAULT_BROKER_URL;
    private final static String topicName = "topic-test";//名字對應上，指向同一個目的地
    public static void main(String[] args) throws JMSException {
        //1.建立我們的連線工廠
        ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(BROKER_URL);
        //2.建立連線
        Connection connection = connectionFactory.createConnection();
        //3.啟動連線
        connection.start();
        //4.建立回話
        Session session = connection.createSession(false,Session.AUTO_ACKNOWLEDGE);
        //5.指定一個目的地，這裡不同
        Destination destination = session.createTopic(topicName);
        //6.建立一個消費者
        MessageConsumer messageConsumer = session.createConsumer(destination);
        //7.建立一個監聽器
        messageConsumer.setMessageListener(new MessageListener() {
            public void onMessage(Message message) {
                TextMessage textMessage = (TextMessage) message;
                try {
                    System.out.println("接收訊息"+textMessage.getText());
                } catch (JMSException e) {
                    e.printStackTrace();
                }
            }
        });
    }
}

執行，發現控制檯沒有變化和反應，這是因為主題模式消費者需要先訂閱才能消費資訊，所以我們要先啟動消費者，再啟動生產者，會看到相應的資訊被消費。如果我們同時啟動兩個消費者，再用生產者生產訊息，發現兩個消費者同時消費所有的資訊，這兩點就是和佇列模式不同的地方,那麼大家思考下他們分別的應用場景？
最後附上一張JMS編碼介面之間的關係，大家聯絡上面的例子看下。