WebSphere MQ傳輸環(huán)境搭建和測試

傳輸環(huán)境搭建和測試公司的WebSphere產品可以方便地實現分布式異構系統(tǒng)之間的消息傳遞。對于大型的分布式系統(tǒng)，使用MQ進行據通信可以說是非常有效，而且用于構環(huán)境如NT和多種UNIX之間通信）。本文主要介紹MQ核組件簡介、MQ環(huán)的搭建及過寫簡單的程序對MQ進行試，希望能起到拋磚引玉的作用。一、核組簡MQ的核心組包括：隊列管理器QueueManager）、隊列（Queue）通道（Channel）消息（Message）集群（）隊列管理器（）供隊列服務，管理屬于隊管理器的列和通等所有對象隊列Queue）是于存儲消息（Message）的數據結構，有種型本隊列（LocalQueue）、遠程隊列（RemoteQueue）、別名隊列（AliasQueue）和模型隊列（ModelQueue），最常用到的是本地隊列遠程隊列。通道Channel）是提供了從一個隊列管理器到其他隊列管理的數據輸路徑。通道類型有若干種，其中常用的是發(fā)送方通道SenderChannel）接方道（ReceiverChannel）消息Message）是應用程序之間傳遞的一系列字節(jié)數據MQ傳遞消息有兩部分組成：消息描述符）應用數據（ApplicationData）。默認最大傳遞的消息大小是4MB，可以根據需進行設置，最大可到100MB。集群Cluster）是分布式網絡上的多個隊列管理器的集合，文不涉集群的具體內容，有興趣的讀者可參考相關資料。二、環(huán)的建本文搭建的環(huán)境以平臺為例，搭建步驟如下：（一）、準備工作準備臺Win2000環(huán)（也可），通過以太網連通。機器A：IP地為：

機器B：IP地為：均安裝MQ，如需進行第三部分的程序測試，需要安裝JDK并置應類徑（二）、創(chuàng)建MQ對A機器：、打開“WebSphereMQ資管理器”，新建隊列管器，名稱為QM_AAA，其余采用默認設置、在QM_AAA隊管器中創(chuàng)建本地隊列，名稱為LQ_AAA;、創(chuàng)建傳輸隊列，名稱為XQ_BBB（建時選擇“本隊”，將“用法”設為“傳輸”）、創(chuàng)建遠程隊列定義，名稱為RQ_BBB指定遠程隊名為LQ_BBB，遠程隊列管理器名稱為QM_BBB，輸列名稱為XQ_BBB;、創(chuàng)建發(fā)送方通道，名稱為AAA.BBB，輸協議為TCP/IP，連接名稱為(1414，輸隊列為XQ_BBB;、創(chuàng)建接受方通道，名稱為BBB.AAA，用默認設置；、創(chuàng)建服務器連接通道，名稱為DC.SVRCONN，采用默認設置（該通道主要給后面的測試程序使用）。B機器A機器上的操作一樣，只是命名不同，如下：、打開“WebSphereMQ資管理器”，新建隊列管器，名稱為QM_BBB，其余采用默認設置、在QM_BBB隊管器中創(chuàng)建本地隊列，名稱為LQ_BBB;、創(chuàng)建傳輸隊列，名稱為XQ_AAA（建時選擇“本隊”，將“用法”設為“傳輸”）、創(chuàng)建遠程隊列定義，名稱為RQ_AAA指定遠程隊名為LQ_AAA，遠程隊列管理器名稱為QM_AAA，輸列名稱為XQ_AAA;、創(chuàng)建發(fā)送方通道，名稱為BBB.AAA，輸協議為TCP/IP，連接名稱為(1414，輸隊列為XQ_AAA;、創(chuàng)建接受方通道，名稱為AAA.BBB，用默認設置；、創(chuàng)建服務器連接通道，名稱為DC.SVRCONN，采用默認設置。

在A、器上分啟動其發(fā)送方通道，如配置正通狀態(tài)應為“正在運行”。三、測試程序編寫測試程序采用JAVA語言編寫，需要讀者具備相關的JAVA編程識以更好地理解本測試程序。程序文件名為MQSample.java，具內容如下，在器A上行（如在B上行請自行適當修改）。-------------------------------------------------------------------------------------------importjava.io.IOException;importjava.util.Hashtable;importcom.ibm.mq.MQException;importcom.ibm.mq.MQMessage;importcom.ibm.mq.MQPutMessageOptions;importcom.ibm.mq.MQQueue;importcom.ibm.mq.MQQueueManager;publicclassMQSample{//定隊列管理器和隊列的名稱privatestaticqmName="QM_AAA";privatestaticqName="RQ_BBB";privatestaticMQQueueManagerqMgr;privatestaticHashtableproperties=newHashtable(;publicstaticvoidmain(Stringargs[]{try{properties.put("hostname","";properties.put("port",newInteger(1414;

properties.put("channel","DC.SVRCONN";properties.put("CCSID",newInteger(1381;properties.put("transport","MQSeries";//CreateconnectiontothequeuemanagerqMgr=newMQQueueManager(qmName,properties;//SopenOptions16;//Nowspecifythequeuethatwewishtoopen,//andtheopenoptions...MQQueueremoteQ=qMgr.accessQueue(qName,openOptions;//DefinesimpleWebSphereMQmessage,andwritesometextinUTFformat..MQMessageputMessagenewMQMessage(;putMessage.writeUTF("Test";//specifythemessageoptions...MQPutMessageOptionspmo=newMQPutMessageOptions(;//acceptthedefaults,sameasMQPMO_DEFAULT//putthemessageonthequeueremoteQ.put(putMessage,pmo;System.out.println("MessagehasbeeninputintotheRemoteQueue";//Closethequeue...remoteQ.close(;

//DisconnectfromqueuemanagerqMgr.disconnect(;}catch(MQExceptionex{//Ifanerrorhasoccurredinabove,trytoidentifywhatwentwrong//WasitWebSphereMQerror?System.out.println("AWebSphereMQerroroccurred:Completioncode+pletionCode+"Reasoncode"+ex.reasonCode;}catch(IOExceptionex{//Wasitbufferspaceerror?System.out.println("Anerroroccurredwhilstwritingtothemessagebuffer:+ex;}catch(Exceptionex{ex.printStackTrace(;}}}-------------------------------------------------------------------------------------------運行程序后，請在B機器本地隊列LQ_BBB中查否消存，果說明測試成功。以上測試程序在JDK1.4.2的境中測試成。通過以上內容的介紹，使我們了解MQ有哪主要的對象，環(huán)如搭，以及何對