欢迎来到天天文库
浏览记录
ID:22372912
大小:57.50 KB
页数:5页
时间:2018-10-28
《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
此文档下载收益归作者所有