IBM WebSphere MQ 7.5基本用法
一、下載7.5 Trial版本
http://www.ibm.com/developerworks/downloads/ws/wmq/
這是下載網址，下載前先必須註冊IBM ID，下載完成後一路Next即可（註：windows上安裝時，會詢問是否域環境，初次學習時，為簡單起見，建議選擇No）
安裝完成後，MQ的Bin目錄會自動添加到環境變量Path中，以後就可以直接用Dos命令行窗口操作(當然，也可以用圖形化GUI方式通過IBM WebSphere MQ Explorer來管理)
註：安裝時，強烈建議用管理員Administrator身份安裝，否則安裝完成後，有可能license無法生效、runmqsc命令模式下無法正常執行命令.
二、創建隊列管理器
WIN + R鍵，輸入cmd，進入命令行窗口，鍵入:
crtmqm QM_TEST
創建一個隊列管理器QM_TEST(你可以改成自己想要的名字)，如果把整個MQ理解成一個數據庫實例，QM_TEST相當於就是db instance中的schema(或user)
命令行創建的隊列管理器默認是不活動狀態的，可以用
strmqm QM_TEST
來啟動隊列管理器
三、創建隊列
如果說“隊列管理器”是db中的schema，那麽"隊列"就相當於db中的Table了，而隊列中的每條"消息"，就相當於Table中的每條記錄，繼續在命令行窗口模式下，輸入
runmqsc QM_TEST
將進入MQ的交互命令模式，繼續輸入
define qlocal(Q1)
將創建一個本地隊列Q1(你可以改成自己需要的名字)，如果此時你打開 "開始菜單->程序->IBM WebSphere MQ->WebSphere MQ Explorer (Installation1)"也能同步在圖形界面下，看到這個隊列
最後鍵入end，退出MQ的交互命令模式。
四、發送消息
繼續在Windows命令模式下，輸入
amqsput Q1 QM_TEST
這裏系統將處於等待用戶輸入的狀態，隨便輸入一些消息，然後連敲二次回車，完成消息發送
五、接收消息
amqsget Q1 QM_TEST
把剛才的put換成了get，將從隊列管理器QM_TEST的隊列Q1中，把消息取出來
六、進階指南
熟悉以上命令行操作後，還可以用圖形化的操作方式再強化一遍（建議還是多用命令行模式，因為有些操作只能用命令行完成，比如後面要提到的修改隊列管理器編碼）
WebSphere MQ Explorer中，從"幫助"菜單裏調出幫助文檔，裏面有一個不錯的教程，強烈推薦新手看一遍
不過，"教程2：將消息發送至遠程隊列"這裏，幫助文檔上有幾個細節沒講透，導致初次用命令行照著做，可能會不成功，幾個要點如下：
1、通道命名問題
發送方與接收方的通道名稱，必須一樣，這樣二邊才能對應起來
2、接收方必須要有偵聽器，而且要處於激活狀態
3、發送方的發送通道中，連接名稱格式為："<接收方HostName或IP地址>(接收方-隊列管理器-偵聽器的TCP端口) ，不包括"<>“，比如比如：yangjm(1514)或172.12.134.14(1514)
4、發送方的發送通道必須處於激活狀態，如果通道啟動失敗，嘗試右鍵->ping/復位，如果還不行，檢查上述要點1-3是否設置有問題
七、遠程連接問題
圖形方式添加“遠程隊列管理器”時，如果遠程隊列也是7.x或以上版本，當前登錄用戶是管理員時，將提示權利不足，拒絕連接，原因是7.0以上，MQ提高了安全性，會默認攔截管理員，詳情可參考IBM上的解釋 http://www-01.ibm.com/support/docview.wss?uid=swg21636532
解決方式：
1. 更換當前用戶，建一個mqm用戶組(MQ安裝後，會默認創建該Windows用戶組)的用戶，然後以該用戶身份登錄操作
2.參考IBM上的解釋，如果出於學習目的，最簡單的做法，就是在runmqsc交互模式下，鍵入
ALTER QMGR CHLAUTH(DISABLED) 直接關閉通道認證(生產環境不推薦這麽做)
另外，要想本機上的隊列能被遠程管理，前提是該隊列管理器允許遠程管理，操作方式：隊列管理器上右擊->選擇"遠程管理..."，接下來的事情大家都知道
八、字符集編碼問題
每個隊列管理器，都有一個CCSID的屬性，對應的就是字符集編碼，在windows系統中，這個編碼應該是1381，如果你是用其它OS(比如linux)的配置通過腳本導入MQ的，可能編碼就不是1381了，這會導致在windows上無法連接\啟動隊列管理器，可以通過MQ交互命令行修改，
runmqsc QM_TEST 進入QM_TEST的MQ交互模式
DISPLAY QMGR CCSID 查看當前的CCSID屬性
ALTER QMGR CCSID(1381) 修改字符集編碼為1381
九、如何從“試用版”升級成“正式版”
試用版默認只能用90天，到期後，如果購買了正式版的license，可以通過命令行導入license，命令如下：
setmqprd x:\license\amqpcert.lic
註：amqpcert.lic中的P即代表這是Product生產版本，setmqprd 後面的路徑即為license文件的所在路徑
十、java連接示例代碼
import com.ibm.mq.MQC; 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; /* * 可以在MQ的資源管理器的某一個隊列上放入測試消息、瀏覽消息等 * 可以放入多條消息，按先進先出的方式取得 */ public class MQTest { private String qManager;// QueueManager名 private MQQueueManager qMgr; private MQQueue qQueue; String HOST_NAME; int PORT = 0; String Q_NAME; String CHANNEL; int CCSID; String Msg; public void init() { try { HOST_NAME = "yangjm";//Hostname或IP PORT = 1414;//要有一個偵聽器，處於活動狀態，且監聽1414端口 qManager = "QM_APPLE"; Q_NAME = "Q1";//Q1是一個本地隊列 CHANNEL = "DC.SVRCONN";//QM_APPLE上要建一個名為DC.SVRCONN的服務器連接通道 CCSID = 1381; // 表示是簡體中文， // CCSID的值在AIX上一般設為1383，如果要支持GBK則設為1386，在WIN上設為1381。 MQEnvironment.hostname = HOST_NAME; // 安裝MQ所在的ip address MQEnvironment.port = PORT; // TCP/IP port MQEnvironment.channel = CHANNEL; MQEnvironment.CCSID = CCSID; qMgr = new MQQueueManager(qManager); int qOptioin = MQC.MQOO_INPUT_AS_Q_DEF | MQC.MQOO_INQUIRE | MQC.MQOO_OUTPUT; qQueue = qMgr.accessQueue(Q_NAME, qOptioin); } catch (MQException e) { System.out .println("A WebSphere MQ error occurred : Completion code " + e.completionCode + " Reason Code is " + e.reasonCode); } } void finalizer() { try { qQueue.close(); qMgr.disconnect(); } catch (MQException e) { System.out .println("A WebSphere MQ error occurred : Completion code " + e.completionCode + " Reason Code is " + e.reasonCode); } } /* * 取過一次，下次就沒有了 */ public void GetMsg() { try { MQMessage retrievedMessage = new MQMessage(); MQGetMessageOptions gmo = new MQGetMessageOptions(); gmo.options += MQC.MQPMO_SYNCPOINT; qQueue.get(retrievedMessage, gmo); int length = retrievedMessage.getDataLength(); byte[] msg = new byte[length]; retrievedMessage.readFully(msg); String sMsg = new String(msg); System.out.println(sMsg); } catch (RuntimeException e) { e.printStackTrace(); } catch (MQException e) { if (e.reasonCode != 2033) // 沒有消息 { e.printStackTrace(); System.out .println("A WebSphere MQ error occurred : Completion code " + e.completionCode + " Reason Code is " + e.reasonCode); } } catch (java.io.IOException e) { System.out .println("An error occurred whilst to the message buffer " + e); } } public void SendMsg(byte[] qByte) { try { MQMessage qMsg = new MQMessage(); qMsg.write(qByte); MQPutMessageOptions pmo = new MQPutMessageOptions(); qQueue.put(qMsg, pmo); System.out.println("The message is sent!"); System.out.println("\tThe message is " + new String(qByte, "GBK")); } catch (MQException e) { System.out .println("A WebSphere MQ error occurred : Completion code " + e.completionCode + " Reason Code is " + e.reasonCode); } catch (java.io.IOException e) { System.out .println("An error occurred whilst to the message buffer " + e); } } /** * @param args */ public static void main(String[] args) { MQTest mqst = new MQTest(); mqst.init(); try { mqst.SendMsg("你好,Webshpere MQ 7.5!".getBytes("GBK")); mqst.GetMsg(); } catch (Exception e) { e.printStackTrace(); } mqst.finalizer(); } }View Code
需要引用的jar包(在MQ的安裝目錄下都有)
附示例源代碼下載地址： http://pan.baidu.com/s/1qWrs9iO
十一、機器之間遷移
如果要在多臺機器上配置相同的隊列管理器，一臺臺機器去創建、設置十分繁瑣，可以用命令
dmpmqcfg -m QM_TEST -A > C:\SCRIPT\QM_TEST_SCRIPT.DUMP
註：其中QM_TEST即為要導出的隊列管理器名稱，而 "QM_TEST_SCRIPT.DUMP"是導出腳本的文件名，可以隨便修改，執行完後會在"C:\SCRIPT\"下生成一個“.dump”的腳本文件，這裏我們借用了管道操作符號">"
在另一臺機器上，先把dump文件復制過去(比如就放在c盤根目錄下)，然後按下列步驟執行
crtmqm QM_TEST
strmqm QM_TEST
runmqsc QM_TEST < C:\QM_TEST_SCRIPT.DUMP > C:\QM_TEST_SCRIPT.OUT
這表示runmqsc命令將對 QM_TEST操作，操作的命令來源於腳本文件 C:\QM_TEST_SCRIPT.DUMP，而執行結果會輸出到 C:\QM_TEST_SCRIPT.OUT
出處：http://www.cnblogs.com/yjmyzz/p/3505325.html
IBM WebSphere MQ 7.5基本用法