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

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

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

在A、器上分啟動(dòng)其發(fā)送方通道，如配置正通狀態(tài)應(yīng)為“正在運(yùn)行”。三、測(cè)試程序編寫測(cè)試程序采用JAVA語(yǔ)言編寫，需要讀者具備相關(guān)的JAVA編程識(shí)以更好地理解本測(cè)試程序。程序文件名為MQSample.java，具內(nèi)容如下，在器A上行（如在B上行請(qǐng)自行適當(dāng)修改）。-------------------------------------------------------------------------------------------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{//定隊(duì)列管理器和隊(duì)列的名稱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(;}}}-------------------------------------------------------------------------------------------運(yùn)行程序后，請(qǐng)?jiān)贐機(jī)器本地隊(duì)列LQ_BBB中查否消存，果說(shuō)明測(cè)試成功。以上測(cè)試程序在JDK1.4.2的境中測(cè)試成。通過(guò)以上內(nèi)容的介紹，使我們了解MQ有哪主要的對(duì)象，環(huán)如搭，以及何對(duì)