上幾篇關於MQ的部落格裡，並沒有介紹的透徹，今天我把用到的類整理到裡一起，集成了監視、查詢、傳送、接收、儲存報文的功能。

首先，新建TemoteTest類

申明：

    private static MQQueueManager qMgr; // 佇列管理器名稱
    private static MQQueue qQueue; // 訊息通道
    private static String Q_MANAGER; // QueueManager名
    private static String HOST_NAME; // 主機名
    private static int PORT; // 埠號
 

    private static String MQ_NAME; // 本地佇列
    private static String CHANNEL; // 連線通道
    private static int CCSID; // 字符集

    public static String dir = "C:/Users/admin/Desktop/遠端測試報文/";

在桌面新建一個名為【遠端測試報文】的資料夾，作為資料來源。

    /**
     * 迴圈所有檔案傳送
     * @param pa
     * @throws Exception
     */
    public static
 
 void search(File pa) throws Exception
    {
        File[] fs = pa.listFiles();
        for (int i = 0; i < fs.length; i++)
        {
            if (fs[i].isDirectory())
            {
                search(fs[i]);
            }
            StringBuffer sb = new StringBuffer();
            Reader rd = null
 
;
            try
            {
                rd = new FileReader(fs[i]);
            } catch (FileNotFoundException e)
            {
                e.printStackTrace();
            }
            char[] cr = new char[20348];
            try
            {
                while (rd.read(cr) > -1)
                {
                    sb.append(new String(cr));
                }
            } catch (IOException e)
            {
                e.printStackTrace();
            }
            sendMsg(sb.toString());
        }
    }

在這個方法中，將資料夾裡所有檔案都拿到，並將它讀成字串，再呼叫sendMsg()方法。

關於MQ初始化的方法：

    /**
     * 初始化
     */
    private static void init()
    {
        Properties prop = new Properties();
        InputStream is = RemoteTest.class.getResourceAsStream("/constant.properties");
        try
        {
            prop.load(is);
            Q_MANAGER = prop.getProperty("Q_MANAGER").trim();
            HOST_NAME = prop.getProperty("HOST_NAME").trim();
            PORT = Integer.parseInt(prop.getProperty("PORT").trim());
            MQ_NAME = prop.getProperty("MQ_NAME").trim();
            CHANNEL = prop.getProperty("CHANNEL").trim();
            CCSID = Integer.parseInt(prop.getProperty("CCSID").trim());

            MQEnvironment.hostname = HOST_NAME;
            MQEnvironment.port = PORT;
            MQEnvironment.channel = CHANNEL;
            MQEnvironment.CCSID = CCSID;

            qMgr = new MQQueueManager(Q_MANAGER);
            int qOptioin = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_INQUIRE | MQC.MQOO_OUTPUT;
            qQueue = qMgr.accessQueue(MQ_NAME, qOptioin);
        } catch (IOException e)
        {
            e.printStackTrace();
        } catch (MQException e)
        {
            e.printStackTrace();
        }
    }

這裡可以直接把這些常量寫死，不過不建議這樣做。
如果在同一臺機器上測試，ip可以填寫127.0.0.1
在我的機器上它是這樣子的：

#佇列管理器名稱
Q_MANAGER = SEND
#主機
HOST_NAME = 127.0.0.1
#埠
PORT = 1414
#佇列
MQ_NAME = QUEUE
#通道
CHANNEL = CHANNEL
CCSID = 1383

傳送訊息的方法：

    /**
     * 傳送訊息
     */
    public static void sendMsg(String msgStr)
    {
        try
        {
            init();
            MQMessage qMsg = new MQMessage();
            qMsg.encoding = CCSID;
            qMsg.characterSet = CCSID;
            qMsg.writeString(msgStr);
            MQPutMessageOptions pmo = new MQPutMessageOptions();
            qQueue.put(qMsg, pmo);
            System.out.println("傳送成功");
        } catch (MQException e)
        {
            System.out.println("發生了一起異常，異常原因：" + e.reasonCode);
        } catch (IOException e)
        {
            System.out.println("發生了一起IO異常：" + e.getMessage());
        } finally
        {
            finalizer();
        }
    }

最後釋放：

    /**
     * 手動釋放
     */
    private static void finalizer()
    {
        try
        {
            qQueue.close();
            qMgr.disconnect();
        } catch (MQException e)
        {
            System.out.println("發生了一起異常，錯誤程式碼：" + e.reasonCode);
            e.printStackTrace();
        }
    }

OK，接下來，Main方法中：

public static void main(String[] args) throws Exception
    {
        File path = new File(dir);
        search(path);
    }

右鍵-Run以下，提示傳送成功，可以在MQ客戶端先檢視以下訊息佇列深度。

由於在寫部落格的時候，我只能在家裡的業餘時間寫，所以環境不允許，沒辦法截圖，不過所有的程式碼都是經得起考驗的可放心使用。

接下來，接收方法：

    /**
     * 接收訊息
     * 
     * @return
     */
    public static String getMsg()
    {
        final MQMessage revMessage = new MQMessage();
        try
        {
            init();
            MQGetMessageOptions gmo = new MQGetMessageOptions();
            revMessage.characterSet = CCSID;
            revMessage.encoding = CCSID;
            gmo.options += MQC.MQPMO_SYNCPOINT;
            if (qQueue.getCurrentDepth() <= 0)
            {
                System.out.println("當前佇列深度為0，佇列中沒有訊息。");
                return null;
            }
            qQueue.get(revMessage, gmo);
            String revString = revMessage.readStringOfByteLength(revMessage.getMessageLength());
            saveToXml(revString, System.currentTimeMillis());
            return revString;
        } catch (MQException e)
        {
            if (e.reasonCode == 2033) // 沒有訊息
            {
                System.out.println("沒收到訊息！");
            }
        } catch (IOException e)
        {
            e.printStackTrace();
        } finally
        {
            finalizer();
        }
        return null;
    }

查看了MQ文件，發現錯誤程式碼2033是空訊息。當然那一段異常程式碼可以刪掉了，因為在try方法中，我們首先判斷了佇列深度，如果佇列深度為0，那就返回null，。所以2033異常應該是沒有效果的。在來看一下儲存檔案：

    /**
     * 儲存檔案
     * 
     * @param content
     *            報文
     * @param number
     *            時間戳
     */
    private static void saveToXml(String content, long  name)
    {
        FileWriter fw;
        String path = "C:/Users/admin/Desktop/遠端測試報文2/";
        File filePath = new File(path);
        if (!filePath.exists())
        {
            filePath.mkdirs();
        }
        try
        {
            File newFile = new File("C:/Users/admin/Desktop/遠端測試報文2/" + name + ".xml");
            if (!newFile.exists())
            {
                fw = new FileWriter("C:/Users/admin/Desktop/遠端測試報文2/" + name + ".xml");
            } else 
            {
                fw = new FileWriter("C:/Users/admin/Desktop/遠端測試報文2/" + name + "2" + ".xml");
            }
            fw.write(content);
            fw.flush();
            fw.close();
        } catch (IOException e)
        {
            e.printStackTrace();
        }
    }

然後在main方法中，呼叫：

        while(true)
        {
            getMsg();
        }

將所有報文儲存成xml格式，這個只是我專案裡的需求，大家在開發中根據需求自己修改修改就可以用了。

下載地址：http://download.csdn.net/download/u012552275/9815601
（注：在下載的類中，和本章的程式碼稍有不同，下載好的類裡，儲存檔案的格式是用報文裡的節點擷取的，在開發中大家直接將本章的儲存程式碼稍加替換就可以使用了。）

自此，部落格將不再更新有關MQ的知識。
有什麼不懂的地方，歡迎留言，或者加群159143965

請支援我，掃描左側二維碼打賞，謝謝。