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);
分享到:
相关推荐
本人自学IBM的WebSphereMQ自学笔记,内有MQ安装文档,建MQ的例子等。 1、 MQ6.0安装 2 1.1 启动MQ v6.0 安装程序 2 1.2 软件需求检查 2 1.3 WebSphere Eclipse Platform V3.0.1软件安装 2 1.4 网络配置检查 3 1.5 ...
本文档主要介绍websphere MQ的工作原理以及各种概念的解释
WebSphere MQ For JAVA编程实例 主要讲解通过Java语言怎样与MQ进行进行数据通信,里面有示例代码
第二部分 Websphere MQ系统管理 43 第三章WebSphere MQ系统安装 43 目标 43 3.1 规划安装 43 3.1.1 硬件要求 43 3.1.2 软件要求 44 3.2 安装 WebSphere MQ 46 3.2.1 WebSphere MQ 文档 46 3.2.2 WebSphere MQ安装 47...
IBM WEBSPHERE MQ 客户端--服务器端安装配置
使用WebSphere MQ管理远程队列管理器.doc
个人收集整理,非常全面的WebsphereMQ的PDF学习资料。Websphere MQ Programming Guide,Websphere MQ Using C++,WebSphere MQ Using Java,WEBSPHERE MQ6.0 JAVA编程,WebSphere MQ基础教程,IBM WEBSPHERE MQ教程...
IBM WebSphere MQ是IBM业界领先面向消息的中间件产品,也是MQ系列产品的基础和核心,它使不同的应用程序能够以企业级的性能,在广泛的平台上安全而可靠地通讯。
博文链接:https://sivyer.iteye.com/blog/117267
全书共分为3部分共14章,第一部分 WebSphere MQ原理和体系结构,分为两章;第二部分 WebSphere MQ系统管理,分为六章,分别介绍安装、配置、管理、控制命令和问题确定;第三部分 WebSphere MQ应用开发,由五章组成,...
WebSphere MQ HP-UX 版,版本 5 发行版 3 提供以下新增的和更改的功能: WebSphere MQ HP-UX 版现在支持使用工业标准安全套接字层(SSL)保护的 WebSphere MQ 通道。有关详细信息,请参阅 WebSphere MQ Security...
WebSphere MQ - Messages.pdf
WebSphere® MQ (也称MQSeries)以一致的、可靠的和易于管理的方式来连接应用程序,并为跨部门、企业范围的集成提供了可靠的基础。通过为重要的消息和事务提供可靠的、一次且仅一次的传递,Websphere MQ 可以处理...
MQ学习资料,websphere mq,有3本关于mq的电子书
Websphere MQ入门教程-高清文字版+学习点评, 含层级目录书签, 浏览方便.
WebSphere MQ 开发培训 IBM软件部 软件部 WebSphere MQ 议程 WebSphere MQ 概览 WebSphere MQ 安装配置 WebSphere MQ 应用开发 WebSphere MQ 参考
IBM Websphere mq安装IBM Websphere mq安装
IBM WebSphere MQ 8.0 linux 安装包 part3,IBM WebSphere MQ 8.0 linux 安装包 part3
IBM Websphere MQ 教程之备份与恢复