ActiveMQ監聽者接收信息

import java.text.SimpleDateFormat;
import java.util.Date;

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.MessageListener;
import javax.jms.Session;
import javax.jms.TextMessage;

import org.apache.activemq.ActiveMQConnectionFactory;

public class ActiveMQReceive {
    //連接賬號
    private String userName = "";
    //連接密碼
    private String password = "";
    //連接地址
    private String brokerURL = "tcp://192.168.18.161:61616";
    //connection的工廠
    private ConnectionFactory factory;
    //連接對象
    private Connection connection;
    //一個操作會話
    private Session session;
    //目的地，其實就是連接到哪個隊列，如果是點對點，那么它的實現是Queue，如果是訂閱模式，那它的實現是Topic
    private Destination destination;
    //消費者，就是接收數據的對象
    private MessageConsumer consumer;
    
    public static void main(String[] args) {
        ActiveMQReceive receive = new ActiveMQReceive();
        receive.start();
    }
    
    public void start(){
        try {
            //根據用戶名，密碼，url創建一個連接工廠
            factory = new ActiveMQConnectionFactory(userName, password, brokerURL);
            //從工廠中獲取一個連接
            connection = factory.createConnection();
            //連接啟動
            connection.start();
            //創建一個session
            //第一個參數:是否支持事務，如果為true，則會忽略第二個參數，被jms服務器設置為SESSION_TRANSACTED
            //第二個參數為false時，paramB的值可為Session.AUTO_ACKNOWLEDGE，Session.CLIENT_ACKNOWLEDGE，DUPS_OK_ACKNOWLEDGE其中一個。
            //Session.AUTO_ACKNOWLEDGE 為自動確認，客戶端發送和接收消息不需要做額外的工作。哪怕是接收端發生異常，也會被當作正常發送成功。
            //Session.CLIENT_ACKNOWLEDGE 為客戶端確認。客戶端接收到消息后，必須調用javax.jms.Message的acknowledge方法。jms服務器才會當作發送成功，並刪除消息。
            //DUPS_OK_ACKNOWLEDGE 允許副本的確認模式。一旦接收方應用程序的方法調用從處理消息處返回，會話對象就會確認消息的接收；而且允許重復確認。
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            //創建一個到達的目的地，activemq不可能同時只能跑一個隊列吧，這里就是連接了一個名為"Alarm"的隊列，這個會話將會到這個隊列，當然，如果這個隊列不存在，將會被創建
            destination = session.createTopic("Alarm");
            //根據session，創建一個接收者對象
            consumer = session.createConsumer(destination);
            
            
            //實現一個消息的監聽器
            //實現這個監聽器后，以后只要有消息，就會通過這個監聽器接收到
            consumer.setMessageListener(new MessageListener() {
                @Override
                public void onMessage(Message message) {
                    try {
                        //獲取到接收的數據
                        String text = ((TextMessage)message).getText();
                        String time = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS").format(new Date().getTime());
                        System.out.println(time+":");
                        System.out.println(text);
                        System.out.println();
                    } catch (JMSException e) {
                        e.printStackTrace();
                    }
                }
            });
            //關閉接收端，也不會終止程序哦
//            consumer.close();
        } catch (JMSException e) {
            e.printStackTrace();
        }
    }
}