概述
1 要有一个触发消息的初始化队列,MQ提供了一个系统队列SYSTEM.DEFAULT.INITQ,但在生产系统中一般都指定专用的初始化队列,就是定义一个本地队列就可以了:
DEF QLOCAL(QFORTRIGGER)
2 为应用程序使用的队列指定触发条件:
DEF QLOCAL(APPLQ) INITQ(QFORTRIGGER) TRIGGER TRIGTYPE(FIRST) PROCESS(RECIEVEPRO)
其中APPLQ是将会接收到消息的队列,通过TRIGGER 和TRIGTYPE开启触发功能,这里指定了FIRST即第一条消息到达时触发条件满足而生成一个触发消息,这条触发消息会放入INITQ参数指定的本地队列QFORTRIGGER中,我们希望因此而触发一个应用程序的处理,这个应用程序被定义为一个PROCESS,在下一步会作出配合的定义,这里的关键是PROCESS的名字会被放到触发消息中而进入触发消息的初始化队列QFORTRIGGER。
3 PROCESS的定义就要告诉MQ应该如何启动相关的程序,如果你已经写好了一个应用程序,可执行文件为/usr/mqrecv(仅仅是举例),相应的PROCESS定义就是:
DEF PROCESS(RECIEVEPRO) APPLTYPE(UNIX) APPLCID('/usr/mqrecv')
PROCESS的名字与第二步中的要完全一样,如果有用小写字母记得用单引号括起来,APPLCID即为要执行的程序的名字,甚至可以加上参数,总之在操作系统中如何启动就把启动的命令串再写一次就是了。
4 启动一个触发器监控程序去监控在第二步中指定的初始化队列QFORTRIGGER
runmqtrm -q QFORTRIGGER
这样就可以了,只要有消息来到产生触发消息,runmqtrm进程就会读到触发消息,根据触发消息中的内容去启动指定的程序(实际上就是fork出一个子进程,执行APPLCID中指定的命令串)。
最后
以上就是跳跃鲜花为你收集整理的使用MQ的触发器机制的大致原理及过程如下的全部内容,希望文章能够帮你解决使用MQ的触发器机制的大致原理及过程如下所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
发表评论 取消回复