zoukankan      html  css  js  c++  java
  • 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

  • 相关阅读:
    Tree
    a letter and a number
    A problem is easy
    connect设置超时的方法
    C++客户端访问Java服务端发布的SOAP模式的WebService接口
    gSoap的“error LNK2001: 无法解析的外部符号 _namespaces”解决方法
    先序序列和后序序列并不能唯一确定二叉树
    二叉树的非递归遍历
    web service,soap ,http,tcp,udp
    byte[]数组和int之间的转换
  • 原文地址:https://www.cnblogs.com/zhaobin/p/1409512.html
Copyright © 2011-2022 走看看