websphere mq传输环境搭建和测试

《websphere mq传输环境搭建和测试》由会员上传分享，免费在线阅读，更多相关内容在学术论文-天天文库。

1、WebSphereMQ传输环境搭建和测试　　在Q程序设计初探一文中，讨论了从MQ队列管理器的本地队列中放置和读出消息的程序，本文主要通过两台机器，搭建MQ消息传输的环境，并编写测试程序进行测试。　　第一、准备工作　　准备2台Q5.3　　第二、创建MQ对象　　A机器上：　　1、打开Q资源管理器，新建队列管理器，名称为QM_00000000，其余采用默认设置;　　2、在QM_00000000队列管理器中创建本地队列，名称为LQ_00000000;　　3、创建传输队列，名称为XQ_88888888（新建时选择本地队列，将用法设置为传输）;　　4、创建远程队列定义，名称为R

2、Q_88888888，指定远程队列名称为LQ_88888888，远程队列管理器名称为QM_88888888，传输队列名称为XQ_88888888;　　5、创建发送方通道，名称为00000000.88888888，传输协议为TCP/IP，连接名称为10.1.1.2(1414)，传输队列为XQ_88888888;　　6、创建接受方通道，名称为88888888.00000000，采用默认设置；　　7、创建服务器连接通道，名称为DC.SVRCONN，采用默认设置（该通道主要给后面的测试程序使用）。　　B机器和A机器上的操作一样，只是命名不同，如下：　　1、打开Q资源管理器，

3、新建队列管理器，名称为QM_88888888，其余采用默认设置;　　2、在QM_88888888队列管理器中创建本地队列，名称为LQ_88888888;　　3、创建传输队列，名称为XQ_00000000（新建时选择本地队列，将用法设置为传输）;　　4、创建远程队列定义，名称为RQ_00000000，指定远程队列名称为LQ_00000000，远程队列管理器名称为QM_00000000，传输队列名称为XQ_00000000;　　5、创建发送方通道，名称为88888888.00000000，传输协议为TCP/IP，连接名称为10.1.1.1(1414)，传输队列为XQ_0

4、0000000;　　6、创建接受方通道，名称为00000000.88888888，采用默认设置；　　7、创建服务器连接通道，名称为DC.SVRCONN，采用默认设置。　　第三、消息测试　　在A、B机器上分别启动其发送方通道，正常情况通道状态应为正在运行。　　通过如下测试程序进行测试，文件名为：MQTest.java，在机器A上进行运行（如在B上运行请读者自行适当修改）。importjava.io.IOException;importjava.util.Hashtable;import.ibm.mq.MQException;import.ibm.mq.MQMessag

5、e;import.ibm.mq.MQPutMessageOptions;import.ibm.mq.Mueue;import.ibm.mq.MueueManager;publicclassMQSample{//定义队列管理器和队列的名称privatestaticStringqmName=QM_00000000;privatestaticStringqName=RQ_88888888;privatestaticMueueManagerqMgr;privatestaticHashtableproperties=neain(Stringargs[]){try{proper

6、ties.put(hostname,10.1.1.1);properties.put(port,neanagerqMgr=neName,properties);//SetuptheoptionsonthequeueoteQ=qMgr.accessQueue(qName,openOptions);//DefineasimpleQmessage,andetextinUTFformat..MQMessageputMessage=neessageoptions...MQPutMessageOptions12下一页....，。pmo=neeasMQPMO_DEFAULT//p

7、utthemessageonthequeueremoteQ.put(putMessage,pmo);System.out.println(MessagehasbeeninputintotheRemoteQueue);//Closethequeue...remoteQ.close();//DisconnectfromthequeuemanagerqMgr.disconnect();}catch(MQExceptionex){//Ifanerrorhasoccurredintheabove,trytoidentify.out.println(AQerroroccur