H5W3
当前位置:H5W3 > 其他技术问题 > 正文

WebSphere MQ传输环境搭建和测试

    在“WebSphere MQ程序设计初探”一文中,讨论了从MQ队列管理器的本地队列中放置和读出消息的程序,本文主要通过两台机器,搭建MQ消息传输的环境,并编写测试程序进行测试。第一、准备工作准备2台Win2000环境(XP也可),通过以太网连通。机器A:代码为00000000,IP地址为:10.1.1.1机器B:代码为88888888,IP地址为:10.1.1.2安装MQ 5.3第二、创建MQ对象A机器上:1、打开“WebSphere MQ资源管理器”,新建队列管理器,名称为QM_00000000,其余采用默认设置;2、在QM_00000000队列管理器中创建本地队列,名称为LQ_00000000;3、创建传输队列,名称为XQ_88888888(新建时选择“本地队列”,将“用法”设置为“传输”);4、创建远程队列定义,名称为RQ_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、打开“WebSphere MQ资源管理器”,新建队列管理器,名称为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_00000000;6、创建接受方通道,名称为00000000.88888888,采用默认设置;7、创建服务器连接通道,名称为DC.SVRCONN,采用默认设置。第三、消息测试在A、B机器上分别启动其发送方通道,正常情况通道状态应为“正在运行”。通过如下测试程序进行测试,文件名为:MQTest.java,在机器A上进行运行(如在B上运行请读者自行适当修改)。——————————————————————————————-import java.io.IOException;import java.util.Hashtable;import com.ibm.mq.MQException;import com.ibm.mq.MQMessage;import com.ibm.mq.MQPutMessageOptions;import com.ibm.mq.MQQueue;import com.ibm.mq.MQQueueManager;public class MQSample{    //定义队列管理器和队列的名称     private static String qmName = “QM_00000000”;     private static String qName = “RQ_88888888”;        private static MQQueueManager qMgr;     private static Hashtable properties = new Hashtable();    public static void main(String args[]) {        try {            properties.put(“hostname”, “10.1.1.1”);            properties.put(“port”, new Integer(1414));            properties.put(“channel”, “DC.SVRCONN”);            properties.put(“CCSID”, new Integer(1381));            properties.put(“transport”,”MQSeries”);                        // Create a connection to the queue manager             qMgr = new MQQueueManager(qmName,properties);             // Set up the options on the queue we wish to open…             int openOptions = 16;            // Now specify the queue that we wish to open,             // and the open options…             MQQueue remoteQ = qMgr.accessQueue(qName, openOptions);                         // Define a simple WebSphere MQ message, and write some text in UTF format..             MQMessage putMessage = new MQMessage();             putMessage.writeUTF(“Test”);             // specify the message options…             MQPutMessageOptions pmo = new MQPutMessageOptions();             // accept the defaults, same as MQPMO_DEFAULT            // put the message on the queue             remoteQ.put(putMessage,pmo);             System.out.println(“Message has been input into the Remote Queue”);            // Close the queue…             remoteQ.close();             // Disconnect from the queue manager             qMgr.disconnect();         }catch (MQException ex) {             // If an error has occurred in the above, try to identify what went wrong             // Was it a WebSphere MQ error?             System.out.println(“A WebSphere MQ error occurred : Completion code ” + ex.completionCode +           ” Reason code ” + ex.reasonCode);         }catch (IOException ex) {             // Was it a Java buffer space error?             System.out.println(“An error occurred whilst writing to the message buffer: ” + ex);         }catch(Exception ex){            ex.printStackTrace();        }    }}——————————————————————————————-运行程序后,请在B机器的本地队列LQ_88888888中检查是否有消息存在,如果有说明测试成功。读者可以自行编写把消息从对方的本地队列读取出来的程序。如果读者对以上的内容有任何疑问,可以和我联系,qianh@cntmi.com 版权所有,严禁转载参考资料:1、《WebSphere MQ System Administration Guide》Third edition (May 2004),SC34-6068-022、《WebSphere MQ Using Java》Third edition (January 2004),SC34-6066-02附件:MQTest.java(2K) 

本文地址:H5W3 » WebSphere MQ传输环境搭建和测试

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址