| |
在“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)
|
|
