WebSphere MQ 学习笔记(3) - 远程管理

1. 在消息送往远程队列管理器之前, 本地队列管理器必需有
 1)至少一个通道
 2)一个传输队列
 3)一个通道初始化器
 4)一个远程队列定义
2. 对于本地队列管理器, 则需要一个侦听器
3. 一个通道的两端各有一个通道的定义, 两个定义必需有相同的名字,共通构成一个消息通道.
4. 每个消息通道两端都有一个消息通道代理(MCA), 他们从传输队列中提取消息.
5. 传输队列是一个本地队列, 用于在MCA提取消息并传递到远程队列管理器之前临时存放消息. 定义远程队列时,应该声明传输队列.
6. 可以使用pipelining使MCA能够多线程传递消息.
7. 建立集群
 在每个队列管理器上,都应该定义集群发送(CLUSSDR)和集群接收(CLUSRCVR)
8. 远程管理示例:
 1) crtmqm source.queue.manager; //源队列管理器
 crtmqm target.queue.manager; //目标队列管理器
 2) 源队列管理器:
定义从源队列管理器向目标队列管理器发送明令的通道
 DEFINE CHANNEL('source.to.target') +
CHLTYPE(SDR) +
CONNAME(192.168.1.90) +
XMITQ('target.queue.manager') +
TRPTYPE(TCP)
定义接收反馈信息的接收通道
 DEFINE CHANNEL('target.to.source') +
CHLTYPE(RCVR) +
TRPTYPE(TCP)
定义侦听器
 DEFINE LISTENER('source.queue.manager') +
TRPTYPE(TCP)
定义传输队列(名字应该与远程队列管理器一致)
 DEFINE QLOCAL('target.queue.manager') +
USAGE(XMITQ)
 3) 目标队列管理器
定义用于反馈给源队列管理器信息的通道
 DEFINE CHANNEL('target.to.source') +
CHLTYPE(SDR) +
CONNAME(192.168.1.90) +
XMITQ('source.queue.manager') +
TRPTYPE(TCP)
定义用于接受源队列管理器命令的通道
DEFINE CHANNEL('source.to.target') +
CHLTYPE(RCVR) +
TRPTYPE(TCP)
定义侦听器
DEFINE LISTENER('target.queue.manager') +
TRPTYPE(TCP)
定义传输队列
DEFINE QLOCAL('source.queue.manager') +
USAGE(XMITQ)
 4) 在源端启动侦听器
 START LISTENER('source.queue.manager')
 在目的端启动侦听器
 START LISTENER('target.queue.manager')
 5) 分别启动两端的传送通道
 源： START CHANNEL('source.to.target')
 目的：START CHANNEL('target.to.source')
 6) 每一个队列管理器都有一个命令服务器（command server）用来处理从远程队列管理器传来得命令。
 通常命令服务器自动启动，也可以手动启动： strmqcsv MQM_NAME
 显示命令服务器状态：
 DISPLAY QMSTATUS CMDSERV
 停止命令服务器： endmqcsv MQM_NAME ( -c, 受控方式关闭， -i立即关闭)
 7) 在源端间接运行目标队列管理器的MQSC
 runmqsc -w 30 target.queue.manager
 (注：使用了-w参数，则source.queue.manager应该是其所在结点的默认队列管理器)
 运行结果：
5724-H72 (C) Copyright IBM Corp. 1994, 2005. ALL RIGHTS RESERVED.
启动队列管理器 target.queue.manager 的 MQSC。

end
 1 : end
未读取 MQSC 命令。
接收到 0 命令响应。

源队列管理器的定义脚本
DEFINE CHANNEL('source.to.target') +
CHLTYPE(SDR) +
CONNAME('192.168.1.90(1414)') +
XMITQ('target.queue.manager') +
TRPTYPE(TCP);
DEFINE CHANNEL('target.to.source') +
CHLTYPE(RCVR) +
TRPTYPE(TCP);
DEFINE LISTENER('source.queue.manager') +
TRPTYPE(TCP) +
port(1415);
DEFINE QLOCAL('target.queue.manager') +
USAGE(XMITQ);
目标队列管理器的定义脚本
DEFINE CHANNEL('target.to.source') +
CHLTYPE(SDR) +
CONNAME('192.168.1.90(1415)') +
XMITQ('source.queue.manager') +
TRPTYPE(TCP);
DEFINE CHANNEL('source.to.target') +
CHLTYPE(RCVR) +
TRPTYPE(TCP);
DEFINE LISTENER('target.queue.manager') +
TRPTYPE(TCP) +
port(1414);
DEFINE QLOCAL('source.queue.manager') +
USAGE(XMITQ);

评论

1 楼 txy821 2010-12-29