WebShpereMQ学习相关..docVIP

MQ-常用相关 理论相关 消息 消息组成：消息 = 消息描述符 + 用户数据 消息类型： 请求消息Request message 请求消息需要应答。请求消息中应该包含回复消息的路由信息。即回复消息发往什么地方。 回复消息Reply message 回复消息是对请求消息的应答。处理请求和回应的应用程序控制着消息间的关联，这种关联和队列管理器没有关系。 报文消息Datagram message 数据报消息是不需要回复的消息，报文消息只是一次单向的信息传送。 报告消息Report message 报告消息用于对一些系统故障的响应。 消息长度：最大消息长度为100MB，缺省最大消息长度为4MB。 消息内容：二进制数据、文本数据、结构化数据、任意数据 队列 先进先出，应用并行访问。 本地队列local queue： 一个物理上位于本地队列管理器的中的队列。 远程队列remote queue： 属于一个不与该应用程序直接相连的队列管理器。可写不可读。关联的目的队列可以是远程队列管理器的本地队列、远程队列。 传输队列transmission queue： 一个位于本地队列管理器上，是两个队列管理器之间的发送放一端。队列管理器利用传输队列把消息分阶段地发向远程队列。把消息从一个队列管理器发送到另一个队列管理器只需要一个传输队列。 死信队列dead letter queue 存储无法发送到其正确目的地的消息的队列。缺省死信队列SYSTEM.DEAD.LETTER.QUEUE。建议在生产系统上，需要独立创建一个死信队列，不使用系统缺省的。 回复队列reply queue 通道 消息通道是一种提供从一个队列管理器到另一个队列管理器的通信路径 1、发送通道（Sender） 2、接收通道（Receiver） 监听 一个队列管理器监听一个端口。 通讯流程 接收：从本地队列管理器的本地队列获取消息 发送：将消息放到远程队列中，发送到远程队列管理器相应的队列中。 关联关系 1、远程队列：关联远程队列管理器（管理器名称、队列名称）、关联本地传输队列 2、传输队列：关联本地发送通道 3、发送通道：关联本地传输队列、关联远程队列管理器的ip地址及监听端口 4、发送通道名称与远程队列管理器接收通道名称一致，接收通道名称与远程队列管理器发送通道名称一致。 操作相关 创建队列管理器 crtmqm QmgrName 删除队列管理器 dltmqm QmgrName 启动队列管理器 strmqm QmgrName 停止队列管理器 endmqm QmgrName：受控关闭 endmqm -i QmgrName：立即关闭 endmqm –p QmgrName：抢先关闭 队列管理器命令控制台 进入队列管理器命令控制台 runmqsc QmgrName 命令列表command display ALTER CLEAR DEFINE DELETE DISPLAY END PING REFRESH RESET RESOLVE RESUME START STOP SUSPEND 通道操作channel operator 定义发送方通道： def chl(channel name) chltype(SDR) discint(1800) conname(127.0.0.1(1414)) xmitq(QL_TRANS) + trptype(tcp) shortrty(10000) shorttmr(30) longtmr(300) longrty(999999999) batchsz(50) replace 通道名称：MPSMT.SAA 远程队列管理器IP及端口：127.0.0.1(1414) 管理本地传输队列：QL_TRANS 定义接收方通道： def chl(channel name) chltype(rcvr) trptype(tcp) 通道名称：channel name 启动通道 start chl(channel name) 通道状态 display chstatus(channel name) 队列操作queue operator 定义死信队列： def ql(queueName) defpsist(yes) maxdepth(20000) maxmsgl(104857600) replace 队列名称：queueName 定义本地队列： def ql(queueName) defpsist(yes) maxdepth(20000) maxmsgl(104857600) bothresh(3) boqname(deadQueueName) replace 队列名称：queueName 死信队列：deadQueueName 定义传输队列：