WebSphere MQ传输环境搭建和测试

　2008-01-05 08:30:06　来源：WEB开发网　　　

　在“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-02
2、《WebSphere MQ Using Java》Third edition (January 2004)，SC34-6066-02
附件：MQTest.java(2K)