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