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);