1-背景知識

IBM MQ支援多種語言開發，本文主要是考慮Java應用開發，MQ提供了相關的Java類庫，可以很方便整合到Java應用中。
IBM MQ Java相關類庫允許Java應用直接與佇列管理器互動，或者連線MQ伺服器和客戶端進行互動。
類庫主要有兩個，一個是MQ classes for Java，另一個是支援JMS標準的MQ classes for JMS。

由於是示例學習，本文主要嘗試利用MQ classes for Java建立MQ簡單應用，從MQ 8.0開始，類庫是基於Java 7建立，因此需要Java 7以上執行時環境。

當然官方推薦使用JMS，因為最新的功能例如非同步消費、自動重連等功能，都只在JMS中支援

開發有兩種通訊模式連線MQ：
客戶端模式（client mode)：應用作為客戶端使用TCP/IP連線MQ伺服器，應用可以部署在相同機器上或者不同機器上；
繫結模式(binding mode)：通過JNI（Java Native Interface）直接連線MQ伺服器，避免網路通訊，效能更佳，必須和MQ伺服器在相同機器上；

2-開發環境準備

2.1 開發環境

VMware Workstation 11.1.4 
SuSE Linux Server x64 SP4 虛擬機器
JDK 8.0
MQ 8.0安裝包

2.2 安裝

安裝好虛擬機器，SuSE Linux SP4,接下來安裝MQ本地開發環境

**安裝MQ相關元件**
# tar -xvf WSMQ_8.0_IFR_TRIAL_LNX_ON_X86_64_.tar.gz
# cd server

安裝MQ執行時元件:
# rpm -ivh MQSeriesRuntime-8.0.0-2.x86_64.rpm

安裝伺服器元件：
# rpm -ivh MQSeriesServer-8.0.0-2.x86_64.rpm

安裝MQ Java庫：這裡面提供MQ Java開發相關的類庫
# rpm -ivh MQSeriesJava-8.0.0-2.x86_64.rpm 

安裝MQ JRE：java執行時用來執行MQ Java應用
# rpm -ivh MQSeriesJRE-8.0.0-2.x86_64.rpm 


**安裝JDK**
下載JDK壓縮包,放入/home目錄下
# cd /home
# tar xvfz jdk-8u102-linux-x64.tar.gz 
# cd jdk1.8.0_102
# ./java -version 

出錯：
Error occurred during initialization of VM
Could not allocate metaspace: 1073741824 bytes
很明顯記憶體空間不夠導致，原虛擬機器只有768MB記憶體，增加到2GB，然後重啟虛擬機器

# reboot
# cd /home/jdk1.8.0_102/bin
# ./java -version
# ./javac 
提示安裝成功


**配置MQ伺服器**
# useradd mquser1 -u 3001
# passwd mquser1  設定密碼為mqtest2016
# su - mqm
~ cd /opt/mqm/bin
設定mq環境變數
~ source setmqenv -s

建立佇列管理器JAVA.QUEUE.MANAGER.1,並啟動
~ crtmqm JAVA.QUEUE.MANAGER.1
~ strmqm JAVA.QUEUE.MANAGER.1
~ dspmq  檢視所有佇列管理器執行狀態

啟動指令碼執行器，進行設定
~ runmqsc JAVA.QUEUE.MANAGER.1
輸入： 
    DEFINE QLOCAL(QUEUE1)    建立本地佇列QUEUE1
    授權mquser1使用者（id為3001）使用佇列QUEUE1，其中PROFILE是對該條記錄進行命名，PRINCIPAL指定特定使用者，表明許可權授權某使用者。
    SET AUTHREC PROFILE(QUEUE1) OBJTYPE(QUEUE) PRINCIPAL('mquser1') AUTHADD(PUT,GET)
    授權使用者mquser1可以連線佇列管理器
    SET AUTHREC OBJTYPE(QMGR) PRINCIPAL('mquser1') AUTHADD(CONNECT)

    定義伺服器連線通道
    DEFINE CHANNEL(JAVA.CLIENT.CHANNEL1) CHLTYPE(SVRCONN) TRPTYPE(TCP)

    授權MQ客戶端可以連線上面定義的通道，通過ip地址和使用者名稱方式授權
    SET CHLAUTH(JAVA.CLIENT.CHANNEL1) TYPE(ADDRESSMAP) ADDRESS('127.0.0.1') MCAUSER('mquser1')

    定義監聽器，接受連線
    DEFINE LISTENER(JAVA.CLIENT.LISTENER1) TRPTYPE(TCP) CONTROL(QMGR) PORT(1316)
    啟動：
    START LISTENER(JAVA.CLIENT.LISTENER1)
    結束：
    end

**編寫Java程式**
MQ Java應用主要需要包含兩個Jar包：com.ibm.mq.allclient.jar 和 com.ibm.mq.traceControl.jar
在安裝目錄下/opt/mqm/java/lib
# cd /opt/mqm/java/lib
# java -java com.ibm.mq.allclient.jar  檢視該jar詳細資訊

接下來可以用vim或者IDE編寫程式
 

3-客戶端模式進行連線

簡單應用，讀寫本機佇列，傳送訊息和讀取訊息，以客戶端模式，利用TCP/IP進行通訊

# cd /home/mq
# vim MQTest.java
輸入以下內容：

import java.io.IOException;
import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQGetMessageOptions;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQPutMessageOptions;
import
 
 com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;
import com.ibm.mq.constants.CMQC;
import com.ibm.mq.constants.MQConstants;

public class MQTest {

    public static void main(String[] args) throws MQException, IOException 
    {
        //傳送訊息給佇列
        put();

        //從佇列讀取訊息
        get();
    }

    static void put() throws MQException, IOException
    {
        //配置MQ伺服器連線引數
        MQEnvironment.hostname = "127.0.0.1";
        MQEnvironment.port = 1316;
        MQEnvironment.channel = "JAVA.CLIENT.CHANNEL1";

        //設定應用名稱,方便伺服器MQ 檢視應用連線
        MQEnvironment.properties.put(MQConstants.APPNAME_PROPERTY, "MQ Test By Java");

        //建立例項，連線佇列管理器
        MQQueueManager queueManager = new MQQueueManager("JAVA.QUEUE.MANAGER.1");

        //以可寫的方式訪問佇列管理器已定義的佇列QUEUE1，當然也可以建立佇列
        MQQueue putQueue = queueManager.accessQueue("QUEUE1", CMQC.MQOO_OUTPUT);

        //新建併發送訊息給佇列
        MQMessage myMessage = new MQMessage();
        String name = "MePlusPlus's 部落格";
        myMessage.writeUTF(name);

        //使用預設的訊息選項
        MQPutMessageOptions pmo = new MQPutMessageOptions();
        //傳送訊息
        putQueue.put(myMessage, pmo);
        putQueue.close();

        //斷開連線
        queueManager.disconnect();
    }

    static void get() throws MQException, IOException
    {
        //配置MQ伺服器連線引數
        MQEnvironment.hostname = "127.0.0.1";
        MQEnvironment.port = 1316;
        MQEnvironment.channel = "JAVA.CLIENT.CHANNEL1";

        //設定應用名稱,方便伺服器MQ 檢視應用連線
        MQEnvironment.properties.put(MQConstants.APPNAME_PROPERTY, "MQ Test By Java");

        //建立例項，連線佇列管理器
        MQQueueManager queueManager = new MQQueueManager("JAVA.QUEUE.MANAGER.1");

        //以可讀的方式訪問佇列管理器已定義的佇列QUEUE1
        MQQueue getQueue = queueManager.accessQueue("QUEUE1", CMQC.MQOO_INPUT_AS_Q_DEF);

        //從佇列讀取訊息
        MQMessage theMessage = new MQMessage();
        MQGetMessageOptions gmo = new MQGetMessageOptions();
        getQueue.get(theMessage, gmo);

        String name = theMessage.readUTF();

        System.out.println(name);
        getQueue.close();

        //斷開連線
        queueManager.disconnect();
    }
}

編譯：
# /home/jdk1.8.0_102/bin/javac -cp /opt/mqm/java/lib/com.ibm.mq.allclient.jar -Xlint:unchecked MQTest.java

執行：
# /home/jdk1.8.0_102/bin/java -cp /opt/mqm/java/lib/com.ibm.mq.allclient.jar:/home/mq MQTest

**注意**
路徑必須以冒號分割，windows下cp引數是分號分割，執行時必須加上MQText.class所在的目錄/home/mq，否則提示 
錯誤：找不到或者無法載入主類MQTest；
此外必須指明引用的jar檔案完整路徑，否則提示 java.lang.ClassNotFoundException:com.ibm.mq.MQException.

執行可能出錯：

  com.ibm.mq.MQQueueManager.<init>(MQQueueManager.java:675)
    at MQTest.put(MQTest.java:35)
    at MQTest.main(MQTest.java:18) Caused by: com.ibm.mq.jmqi.JmqiException: CC=2;RC=2538;AMQ9204:
    與主機 '127.0.0.1(1316)' 的連線被拒絕。 
    [1=com.ibm.mq.jmqi.JmqiException[CC=2;RC=2538;AMQ9213: 發生 'TCP' 的通訊錯誤。 

解決：明顯是和MQ伺服器通訊問題，可能是MQ伺服器沒有啟動
# telnet 127.0.0.1 1316 是否連通
# su - mqm
~ cd /opt/mqm/bin
~ dspmq  檢視佇列管理器狀態，如果沒有啟動，啟動它
~ source setmqenv -s
~ strmqm JAVA.QUEUE.MANAGER.1

錯誤程式碼：網上查明，是因為與MQ伺服器連線錯誤導致，是因為使用者許可權問題
com.ibm.mq.MQException: MQJE001: 完成程式碼為 '2'，原因為 '2035'

在MQTest.java檔案中加入：（**以下兩句不用加，這個不是用來驗證連線的使用者，具體分析見最後小結，這個是後面實驗發現**）
MQEnvironment.userID = "myuser1";
MQEnvironment.password = "mqtest2016";

此外在官方文件上找到解決方法：為在佇列管理器重新增加使用者mquser1使用者的許可權，MQ Java類庫用到了其它許可權。
 # su - mqm
~ cd /opt/mqm/bin
設定mq環境變數
~ source setmqenv -s
啟動指令碼執行器，進行設定
~ runmqsc JAVA.QUEUE.MANAGER.1
    SET AUTHREC OBJTYPE(QMGR) PRINCIPAL('mquser1') AUTHADD(CONNECT,INQ)
    SET AUTHREC PROFILE('QUEUE1') OBJTYPE(QUEUE) PRINCIPAL('mquser1') AUTHADD(PUT,GET,INQ,BROWSE)
其中：
INQ：查詢佇列的屬性資訊
PUT：傳送給佇列
GET：從佇列讀取訊息
BROWSE：從佇列讀取訊息，以瀏覽的選項設定
CONNECT：允許應用連線MQ
具體參見官網文件 [SET AUTHREC](http://www.ibm.com/support/knowledgecenter/en/SSFKSJ_9.0.0/com.ibm.mq.ref.adm.doc/q086620_.htm)
文件中例項進行的的配置命令如下：

    runmqlsr -t tcp -m JAVA.QUEUE.MANAGER.1 -p 1317  （通過檢視程序知道，該方式和上述方式設定效果一樣，但這樣更簡單）
    runmqsc JAVA.QUEUE.MANAGER.1
        DEFINE CHANNEL('JAVA.CHANNEL.1') CHLTYPE(SVRCONN) TRPTYPE(TCP) DESCR('TEST FOR JAVA')
        SET CHLAUTH('JAVA.CHANNEL.1') TYPE(ADDRESSMAP) ADDRESS('192.168.98.1') MCAUSER('mquser1')
        DEFINE QLOCAL('QUEUE1') DESCR('TEST FOR QUUE')
        SET AUTHREC OBJTYPE(QMGR) PRINCIPAL('mquser1') AUTHADD(CONNECT,INQ)
        SET AUTHREC PROFILE('QUEUE1') OBJTYPE(QUEUE) PRINCIPAL('mquser1') AUTHADD(PUT,GET,INQ,BROWSE)
        end

修改後的程式碼如下：

import java.io.IOException;

import com.ibm.mq.MQEnvironment;
import com.ibm.mq.MQException;
import com.ibm.mq.MQGetMessageOptions;
import com.ibm.mq.MQMessage;
import com.ibm.mq.MQPutMessageOptions;
import com.ibm.mq.MQQueue;
import com.ibm.mq.MQQueueManager;
import com.ibm.mq.constants.CMQC;
import com.ibm.mq.constants.MQConstants;

public class MQTest {

    public static void main(String[] args) throws MQException, IOException 
    {
        //傳送訊息給佇列
        put();

        //從佇列讀取訊息
        get();
    }

    static void put() throws MQException, IOException
    {
        //配置MQ伺服器連線引數
        MQEnvironment.hostname = "127.0.0.1";
        MQEnvironment.port = 1316;
        MQEnvironment.channel = "JAVA.CLIENT.CHANNEL1";
        MQEnvironment.userID = "mquser1";
        MQEnvironment.password = "mqtest2016";
        //設定應用名稱,方便伺服器MQ 檢視應用連線
        MQEnvironment.properties.put(MQConstants.APPNAME_PROPERTY, "MQ Test By Java");

        //建立例項，連線佇列管理器
        MQQueueManager queueManager = new MQQueueManager("JAVA.QUEUE.MANAGER.1");

        //以可寫的方式訪問佇列管理器已定義的佇列QUEUE1，當然也可以建立佇列
        MQQueue putQueue = queueManager.accessQueue("QUEUE1", CMQC.MQOO_OUTPUT);

        //新建併發送訊息給佇列
        MQMessage myMessage = new MQMessage();
        String name = "MePlusPlus's 部落格";
        myMessage.writeUTF(name);

        //使用預設的訊息選項
        MQPutMessageOptions pmo = new MQPutMessageOptions();
        //傳送訊息
        putQueue.put(myMessage, pmo);
        putQueue.close();

        //斷開連線
        queueManager.disconnect();
    }

    static void get() throws MQException, IOException
    {
        //配置MQ伺服器連線引數
        MQEnvironment.hostname = "127.0.0.1";
        MQEnvironment.port = 1316;
        MQEnvironment.channel = "JAVA.CLIENT.CHANNEL1";
        MQEnvironment.userID = "mquser1";
        MQEnvironment.password = "mqtest2016";
        //設定應用名稱,方便伺服器MQ 檢視應用連線
        MQEnvironment.properties.put(MQConstants.APPNAME_PROPERTY, "MQ Test By Java");

        //建立例項，連線佇列管理器
        MQQueueManager queueManager = new MQQueueManager("JAVA.QUEUE.MANAGER.1");

        //以可讀的方式訪問佇列管理器已定義的佇列QUEUE1
        MQQueue getQueue = queueManager.accessQueue("QUEUE1", CMQC.MQOO_INPUT_AS_Q_DEF);

        //從佇列讀取訊息
        MQMessage theMessage = new MQMessage();
        MQGetMessageOptions gmo = new MQGetMessageOptions();
        getQueue.get(theMessage, gmo);

        String name = theMessage.readUTF();

        System.out.println(name);
        getQueue.close();

        //斷開連線
        queueManager.disconnect();
    }
}

# /home/jdk1.8.0_102/bin/javac -cp /opt/mqm/java/lib/com.ibm.mq.allclient.jar MQTest.java
# /home/jdk1.8.0_102/bin/java -cp /opt/mqm/java/lib/com.ibm.mq.allclient.jar:/home/mq  MQTest