使用MQ的触发器机制的大致原理及过程如下
2009-09-09 15:28
609 查看
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中指定的命令串)。
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中指定的命令串)。
相关文章推荐
- IBM-MQ原理及使用场景
- Android中measure过程、view绘制原理和MeasureSpec介绍及使用详解
- Hadoop学习笔记—3.Hadoop RPC机制、原理及使用
- flex4 + spring + blazeds , 使用anonation(注解)机制,利用push技术的实现例子和过程。
- Java学习之类加载全过程_JVM内存分析_反射机制核心原理_常量池理解
- Dubbo学习过程、使用经验分享及实现原理简单介绍
- dubbo学习过程、使用经验分享及实现原理简单介绍,dubbo经验分享
- XenStore:使用,结构和原理(3. XenStore启动过程分析)
- 使用CRF++进行分词的原理和实现过程
- dubbo学习过程、使用经验分享及实现原理简单介绍,dubbo经验分享
- C++ Assert()断言机制原理以及使用
- springfox-swagger原理解析与使用过程中遇到的坑
- mysql 储存过程、触发器的创建、删除及使用
- Window7系统的完整开机加载过程的原理和机制
- sql触发器与约束,存储过程的比较,及其触发器在综合交易--变更付费关系中的使用的设想
- Windows同步机制原理及使用方法
- MQ原理及框架使用
- flex4 + spring + blazeds , 使用anonation(注解)机制,利用push技术的实现例子和过程。
- Visual C++异常处理机制原理与应用(一)—— C/C++结构化异常处理之try-finally终止处理的使用与原理(上)
- MFC的消息机制的实现原理和消息处理的过程