分享

WebSphere MQ触发原理

 yespon 2017-06-02

websphere mq 触发机制:

触发所涉及的对象:

应用队列:是一个本地队列,并设置为可触发的。当触发条件满足时,将会产生触发消息。
进程定义:一个应用队列可能由一个进程定义对象和它关联。进程定义中包含应用程序的信息。该应用程序负责从应用队列中取出消息。
传输队列:如果用触发方式来启动通道,则需一个传输队列。传输队列的TriggerData属性中设置成将被启动的通道名。这将可省略进程的定义。
触发事件:它是一种引起队列管理器产生触发消息的事件。
触发消息:当触发事件发生时,队列管理器将产生触发消息。触发信息来自于应用队列和与应用队列关联的进程定义,它包含了将要被启动的程序名。
启动队列:也是一个本地队列,它是被用来存放触发消息的队列。一个队列管理器可以拥有多个启动队列。一个启动队列可以为多个应用队列服务
触发监控器:是一个持续运行的程序,当一个触发消息到达启动队列时,触发监控器获取触发消息,并利用触发消息中的信息,启动应用程序来处理应用队列中的消息,并把触发消息头发送传递给应用程序,消息头中包括应用队列名。

在所有平台上,有一个特殊的触发监控器叫做通道启动器(channel initator),它的作用是启动通道。
触发类型
EVERY:当应用队列中每接收到一个消息时,都将产生触发消息。如果应用程序仅处理一个消息就结束时,可采用这种触发类型。
FIRST:当应用队列中的消息从0变为1才会发生触发事件。如果当队列中的一个消息到达时启动应用程序,直到处理完所有消息就结束,则采用这种触发类型。
DEPTH:当应用队列中的消息数目和TriggerDepth的属性值相同时,才会产生触发事件。当一系列请求的恢复都收到时,才启动应用程序,则采用这种触发类型。

当采用depth触发时,产生触发消息后,队列将被修改成非触发方式,如果需要再次触发,将要重新设置成允许触发。

队列的TriggerDepth属性表示引起depth触发事件发生时,队列中的消息数目。

为了更好地能理解触发机制,我们举一个触发类型为FIRST的例子。

1.只有一个本地或远程的应用程序A,往应用队列(Application Queue)中PUT了一条消息。
2.当队列原来的深度为0时,也即队列为空,这时PUT一条消息到队列中,将会形成触发事件,同时会产生一条触发消息,触发消息中将包含进程定义(Process)中的信息。
3.队列管理器创建触发消息,并把它PUT到与应用队列相关的启动队列(Initiation Queue)。
4.触发监控器从启动队列中GET出触发消息。
5.触发监控器处理触发消息,发出启动应用程序B的命令。
6.应用程序B打开应用队列,并处理队列中的消息。

WebSphere <wbr>MQ触发原理

注意:

1.如果队列的触发类型为FIRST或DEPTH,同时有多个应用程序往应用队列发送消息,这种情况下将不会形成触发事件。
2.如果启动队列设置成不允许PUT消息,那么队列管理器将不产生任何触发消息,直到把启动队列的属性修改成允许PUT消息。
3.如果通道设置成触发方式,建议触发类型为FIRST或DEPTH。

    本站是提供个人知识管理的网络存储空间,所有内容均由用户发布,不代表本站观点。请注意甄别内容中的联系方式、诱导购买等信息,谨防诈骗。如发现有害或侵权内容,请点击一键举报。
    转藏 分享 献花(0

    0条评论

    发表

    请遵守用户 评论公约

    类似文章 更多