IBM MQSeries的触发(Triggering)机制

一、 触发器原理

       触发(Triggering),是一种自动启动应用程序的机制。

队列管理器把某种条件称为触发事件。如果队列被设置为触发类型,并且触发事件发生了,那么队列管理器将发送一个触发消息到一个称作启动队列的队列中。触发消息被放置到启动队列的过程意味着产生了触发事件。

       处理队列管理器中的消息是触发监控程序(Trigger-Monitor Application),他的工作是读取触发消息并根据触发消息的信息做出相应的处理。触发监控程序没有什么特殊,它只不过是启动队列读取消息的应用程序。

当队列管理器发现由一条消息到达被触发的队列之后,它产生的触发消息将被存放到启动队列中,触发监控程序将从启动队列中取出触发消息,并根据触发消息中的内容,启动相应的消息处理程序来处理被触发队列中的消息。

       触发所涉及的对象如下:

       1 应用队列:一个本地队列并设置为可触发。当触发条件满足时,将会产生触发消息。

       2 进程定义:一个应用队列可能由一个进程定义对象和它关联。进程定义中包含应用程序的信息。该应用程序负责从应用队列中取出消息。

       3 传输队列:如果用触发方式来启动通道,则需要一个传输队列。在传输队列的TriggerData属性中设置为将被启动的通道名,这将省略进程的定义。

       4 触发事件:它是一种引起队列管理器产生触发消息的事件。

       5 触发消息:当触发事件发生时,队列管理器将产生触发消息。触发信息来自于应用队列和于应用队列关联的进程定义,它包含了将要被启动的程序名。

       6 启动队列:一个本地队列。被用来存发触发消息的队列。一个队列管理器可用拥有多个启动队列。一个启动队列可以为多个应用队列服务。

       7 触发监控器:是一个持续运行的程序,当一个触发消息到达启动队列时,触发监控器获取触发消息,并利用触发消息中的信息,启动应用程序来处理应用队列中的消息,并把触发消息头发送传递给应用程序,消息头中包含应用队列名。

       在所有平台上,都有一个特殊的触发监控器叫做通道启动器(Channel Initator),它的作用就是启动通道。

二、触发类型

1EVERY

       应用队列中每接受到一个消息时,都将产生触发消息。如果应用程序仅仅处理一个消息就结束,可采用这种触发类型。

2FIRST

       应用队列中消息从0变为1时会触发事件。如果当队列中的一个消息到达时启动程序,直到处理完所有消息才结束,则采用这种触发类型。

3DEPTH

       应用队列中消息数目和TriggerDepth(引起触发事件发生时,队列中的消息数目)属性值相同时,才会产生触发事件。当一系列请求的回复都收到时,才启动应用程序,则可以采用这种方法。

       需要注意的时,当DEPTH属性值为0的时候,实际上就形成了同步通信。另外,当采用Depth触发时,产生触发消息以后,队列将被修改为非触发方式,如果需要再次触发,需要重新设置成允许触发。

       一般而言,在实际应用中,如果通道设置成触发方式,触发类型往往设置成为FIRSTDEPTH

三、触发器工作流程

1、              本地或远程应用程序A,往应用队列(Application Queue)PUT了一条消息。

2、              当队列原来深度为0时(队列为空),这是PUT一条消息到队列中将形成触发事件,同时产生一条触发消息,触发消息中将包含进程定义中的信息。

3、              队列管理器创建触发消息,并把它PUT入与应用队列相关的启动队列Initiation Queue

4、              触发监控器(Trigger Monitor)从启动队列(Initiation Queue)GET触发消息。

5、              触发监控器处理触发消息,发出启动应用程序B的命令。

6、              应用程序B打开应用队列(Application Queue),并处理队列中的消息。

 

本文转自 http://yefeng177.bokee.com/2666219.html

原文地址:https://www.cnblogs.com/zhaobin/p/1409512.html