2014-02-22 16:21:02,843 | WARN  | Transport Connection to: tcp://10.18.222.21:4751 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: tcp:///10.18.222.21:[email protected]
2014-02-22 16:21:02,843 | WARN  | Transport Connection to: tcp://127.0.0.1:4743 failed: java.net.SocketException: Connection reset | org.apache.activemq.broker.TransportConnection.Transport | ActiveMQ Transport: tcp:///127.0.0.1:

在專案中終於解決了這個困擾很久的問題，一直想不到是這個原因，還以為MQ有BUG，

  mqConnFactory = new ActiveMQConnectionFactory(config.getMqConfig().getUrl());

 connection = mqConnFactory.createConnection();

當時有2個方法都使用mqConnFactory.createConnection();一個是初始化，一個是檢查mq狀態，mqConnFactory.createConnection();一次就行了！

以下程式碼是另外一個測試程式，以上面無關。

傳送端:

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.Message;
import javax.jms.MessageProducer;
import javax.jms.Session;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.quartz.CronScheduleBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class MessageSendAndReceive {

    public static Scheduler sched;

    public static void main(String[] args) throws Exception {
        MessageSendAndReceive.run();
    }

    public static void send() throws Exception {
        ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
        Connection connection = factory.createConnection();
        connection.start();
        Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
        Destination destination = session.createQueue("TestQueue");
        Message message = session.createTextMessage("Hello JMS!");
        MessageProducer producer = session.createProducer(destination);
        producer.send(message);
        System.out.println("Send Message Completed!");
        // MessageConsumer comsumer = session.createConsumer(destination);
        // Message recvMessage = comsumer.receive();
        // System.out.println("Received:" + ((TextMessage)
        // recvMessage).getText());
        producer.close();
        session.close();
        connection.close();
    }

    public static void run() throws Exception {
        SchedulerFactory schedulerFactory = new StdSchedulerFactory();
        // 通過schedulerFactory獲取一個排程器
        sched = schedulerFactory.getScheduler();
        // 建立jobDetail例項，繫結Job實現類
        // 指明job的名稱，所在組的名稱，以及繫結job類
        // 建立LzstoneTimeTask的定時任務
        JobDetail jobDetail = JobBuilder.newJob(LzstoneTimeTask.class)
                .withIdentity("lzstoneJob", Scheduler.DEFAULT_GROUP).build();
        // 目標 建立任務計劃
        Trigger trigger = TriggerBuilder.newTrigger().withIdentity("simpleTrigger", "triggerGroup")
                .withSchedule(CronScheduleBuilder.cronSchedule("0/10 * * * * ?")).startNow().build();

        // 0 0 12 * * ? 代表每天的中午12點觸發
        // 把作業和觸發器註冊到任務排程中
        sched.scheduleJob(jobDetail, trigger);
        // 啟動排程
        sched.start();
    }

    // 停止
    public static void stop() throws Exception {
        sched.shutdown();
    }

}

Job：

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.Message;
import javax.jms.MessageProducer;
import javax.jms.Session;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class LzstoneTimeTask implements Job {
    public void execute(JobExecutionContext context) throws JobExecutionException {
        try {
            // 執行的定時器任務
            ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
            Connection connection = factory.createConnection();
            connection.start();
            Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            Destination destination = session.createQueue("TestQueue");
            Message message = session.createTextMessage("Hello JMS!");
            MessageProducer producer = session.createProducer(destination);
            // 訊息為非持久化訊息
            producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
            // 設定心跳訊息的存活時間，因為會定時傳送，所以，沒有必要永久存在。
            producer.setTimeToLive(1 * 1000);
            producer.send(message);
            System.out.println("Send Message Completed!");
            // MessageConsumer comsumer = session.createConsumer(destination);
            // Message recvMessage = comsumer.receive();
            // System.out.println("Received:" + ((TextMessage)
            // recvMessage).getText());
            producer.close();
            session.close();
            connection.close();
        } catch (Exception e) {

        }
    }
}

監聽：

import javax.jms.Connection;
import javax.jms.ConnectionFactory;
import javax.jms.Destination;
import javax.jms.ExceptionListener;
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.ActiveMQConnection;
import org.apache.activemq.ActiveMQConnectionFactory;

public class Jms_Receiver_Listener extends Thread implements MessageListener, ExceptionListener {
    // ConnectionFactory ：連線工廠，JMS 用它建立連線
    ConnectionFactory connectionFactory;
    // Connection ：JMS 客戶端到JMS Provider 的連線
    Connection connection = null;
    // Session：一個傳送或接收訊息的執行緒
    Session session;
    // Destination ：訊息的目的地
    Destination destination;
    // 訊息接收者
    MessageConsumer consumer;

    public Jms_Receiver_Listener() {
        String url = "tcp://localhost:61616";
        // 在ActiveMq的console配置的queue的名字
        String queue = "TestQueue";
        connectionFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_USER,
                ActiveMQConnection.DEFAULT_PASSWORD, url);
        // 構造從工廠得到連線物件
        try {
            connection = connectionFactory.createConnection();
            connection.setExceptionListener(this);// 異常處理
            connection.start();// 連線啟動
            // 如果為true，則佇列裡面的訊息沒有被取走，繼續存在
            session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
            // 獲取session，
            destination = session.createQueue(queue);
            consumer = session.createConsumer(destination);
        } catch (JMSException e) {
            System.err.println("Create fail!");
            e.printStackTrace();
        }
    }

    public void run() {
        try {
            consumer.setMessageListener(this);
        } catch (JMSException e) {
            System.err.println(" MessageListener failed...");
            e.printStackTrace();
        }

    }

    public void onMessage(Message message) {
        try {
            if (message instanceof TextMessage) {
                TextMessage txtMsg = (TextMessage) message;
                String msg = txtMsg.getText();
                System.out.println("Received: " + msg);
            }

        } catch (JMSException e) {
            System.err.println("The process of getting a message failed...");
            e.printStackTrace();
        }
    }

    // 非同步訊息異常處理
    public void onException(JMSException arg0) {
        System.err.println("JMS異常！");
    }

    // 測試程式
    public static void main(String[] args) {
        Jms_Receiver_Listener jrl = new Jms_Receiver_Listener();
        jrl.start();
    }
}