`
jeffen2006
  • 浏览: 259663 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

jbpm的调度应用1

阅读更多

以前开始接触jbpm的时候,也曾经发表了一篇关于调度的文章http://blog.csdn.net/jeffen2006/archive/2006/10/20/1342167.aspx,其中有很多不甚了解的东东,这几天又研究了一下,共享给各位学友。

本系列仅从应用的角度出发进行介绍:

jbpm的调度部分只要分为2块,timer主要是流程设计人员的工作,将timer放置到流程中;scheduler是jbpm自己维护的,我们只需要在后台进行调用即可。

根据吃甘蔗的方法,我们先说相对容易一点的scheduler。我们可以认为scheduler就是一个后台线程在不停的监听着timer(jbpm_timer表),如果有需要触发的timer生成了,就按照timer的属性定时或者循环触发它。

jbpm提供了2种调用scheduler的方法:
一种是用在web应用的,采用org.jbpm.scheduler.impl.SchedulerServlet,具体的方法这个类的javadoc有很好的示例,我们只需在web.xml中加载它就行了;
另一种是针对的c-s程序,jbpm提供了一个很好的示例org.jbpm.scheduler.impl.SchedulerMain,我们可以参照它编写我们自己的Scheduler。

下面我就编写一个cs程序来实现Scheduler,并调用一个最简单的timer。

这个timer从第5秒开始每隔3秒执行script中的内容。

xml 代码
  1. <!---->xml version="1.0" encoding="UTF-8"?>  
  2. <process-definition xmlns="" name="yytest">  
  3.    <start-state name="start">  
  4.       <transition name="" to="a">transition>  
  5.    start-state>  
  6.    <state name="a">  
  7.         <timer name='reminder'    
  8.              duedate='5 seconds'    
  9.              repeat='3 seconds'  
  10.              >  
  11.         <script>System.out.println(new Date()+"----node enter:send mail to operator.");script>  
  12.      timer>  
  13.       <transition name="" to="end">transition>  
  14.    state>  
  15.    <end-state name="end">end-state>  
  16.        
  17. process-definition>  

下面的程序看注释就很清楚了:

java 代码
  1. package com.jeffentest;   
  2.   
  3. import org.jbpm.*;   
  4. import org.jbpm.graph.def.ProcessDefinition;   
  5. import org.jbpm.graph.exe.*;   
  6. import org.jbpm.scheduler.impl.Scheduler;   
  7.   
  8.   
  9. public class Jeffentest {   
  10.     static JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance();   
  11.     static ProcessDefinition processDefinition = null;   
  12.     static ProcessInstance processInstance = null;   
  13.     static Scheduler scheduler = null;   
  14.   
  15.     public static void initSchedular() {//设置Schedular的属性   
  16.         scheduler = new Scheduler();   
  17.         int interval = 5000;   
  18.         scheduler.setInterval(interval);   
  19.         int historyMaxSize = 0;   
  20.         scheduler.setHistoryMaxSize(historyMaxSize);   
  21.         scheduler.start();   
  22.     }   
  23.          
  24.     public static void destroy() {//这个例子没用到   
  25.         scheduler.stop();   
  26.     }   
  27.     static class MySchedularThread extends Thread{//实际业务处理线程   
  28.         public void run(){   
  29.             JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();   
  30.             try {   
  31.                 long processInstanceId =1;   
  32.                    processInstance = jbpmContext.loadProcessInstance(processInstanceId);   
  33.                    Token token = processInstance.getRootToken();   
  34.                    System.out.println(token.getNode());   
  35.                    //一定要运行到有timer生成,触发   
  36.                    token.signal();   
  37.                    System.out.println(token.getNode());   
  38.                    jbpmContext.save(processInstance);   
  39.                    //如果这里程序到这里退出的话可以看到jbpm_timer表里有一条数据   
  40.                    Thread.sleep(30*1000);//为模拟效果,此线程停止30秒   
  41.                    //节点跳过,timer结束,jbpm_timer表该数据清空   
  42.                    token.signal();   
  43.                    System.out.println(token.getNode());   
  44.                    jbpmContext.save(processInstance);   
  45.             }catch(Exception e){   
  46.                 e.printStackTrace();   
  47.             }finally {   
  48.                   jbpmContext.close();   
  49.             }   
  50.         }   
  51.     }   
  52.            
  53.     public static void main(String[] args) {   
  54.         initSchedular ();   
  55.         MySchedularThread mst=new MySchedularThread();   
  56.         mst.start();   
  57.     }   
  58. }   

运行结果:

StartState(start)
State(a)
Thu Dec 07 13:17:11 CST 2006----node enter:send mail to operator.
Thu Dec 07 13:17:16 CST 2006----node enter:send mail to operator.
Thu Dec 07 13:17:21 CST 2006----node enter:send mail to operator.
Thu Dec 07 13:17:26 CST 2006----node enter:send mail to operator.
Thu Dec 07 13:17:31 CST 2006----node enter:send mail to operator.
EndState(end)

scheduler就先说这么多了,至于timer等我下篇吧,等下要去参加jbuilder2007的深圳发布会。

 

分享到:
评论
6 楼 shaucle 2006-12-14  
俺做的项目也要改为jBpm了
5 楼 liu_hua1984cf 2006-12-14  
我按照这个执行,可是还是没有调度,jbmp_timer表中为空的
4 楼 anders0913 2006-12-12  
定时调度。
3 楼 e3002 2006-12-11  
作业调度框架quartz
2 楼 lighter 2006-12-08  
presses 写道
好像jdk的timer和opensynphony的quartz已经很方便

汗......
jBPM为设计及开发工作流和业务流程管理系统提供了一个先进的平台。由API、特定领域的语言和图形建模工具组成的框架让开发人员和业务分析人员能够使用通用平台进行沟通及操作。
1 楼 presses 2006-12-08  
好像jdk的timer和opensynphony的quartz已经很方便

相关推荐

    JBPM3.2与Spring结合时任务调度的实现.doc

    JBPM3.2与Spring的整合主要是为了实现任务调度的功能,这在企业级应用中是非常重要的,因为它能够自动化执行定时任务,如流程启动、数据同步、报告生成等。在JBPM3.1.x版本中,通过SpringModules提供的`spring-...

    jbpm简介\jbpm简介

    1. **嵌入式的工作流引擎**:jBPM采用嵌入式设计,这意味着它可以作为应用程序的一部分运行,无需额外的硬件投入,降低了网络和集群的复杂度。 2. **图形化开发工具**:提供可视化流程控制台,使得开发者可以通过...

    jbpm4案例源码

    这个"jbpm4案例源码"包含了jbpm4系统的核心组件和示例代码,帮助开发者深入理解jbpm4的工作原理和实践应用。《jBPM4工作流应用开发指南.pdf》这本书则进一步阐述了如何利用jbpm4来构建工作流应用。 jbpm4的核心功能...

    简单的spring2+struts2+hibernate3.2+jbpm3应用框架

    例如,Spring作为中央调度者,管理Struts和Hibernate的生命周期,同时利用jBPM来处理流程控制。此外,这个框架也展示了如何在实际项目中实现模块化和分层设计,以提高代码的可读性和可维护性。 总的来说,"简单的...

    jbpm开发指南

    预配置的服务器集成了核心jBPM服务、集成数据库、jBPM控制台Web应用、调度程序和命令执行器,还有一个示例流程实例。 1.3 jBPM图形化流程设计器 jBPM提供了一个Eclipse插件形式的图形化流程设计器,该设计器支持...

    JBPM文档(详解)

    1. **jBPM流程定义**: - jBPM不遵循传统的WfMC's XPDL、BPML、ebXML或BPEL4WS等规范,而是使用自定义的jBoss jBPM Process Definition Language (jPdl)。jPdl基于UML状态图模型,使流程定义图形化,易于理解和维护...

    JBPM工作原理及表结构详解

    本文将深入探讨JBPM的工作原理、表结构及其在实际操作中的应用。 1. **JBPM特色** - **灵活的建模**:JBPM支持BPMN 2.0标准,允许用户通过图形化界面设计复杂的工作流程。 - **持久化存储**:JBPM将流程实例和...

    jbpm中文教程-详细

    建议初学者首先阅读这份文档,理解jbpm的基本概念和操作,然后通过实际项目练习,掌握jbpm的实战应用。 总结,jbpm作为企业级的业务流程管理工具,其强大之处在于它提供的完整流程生命周期管理、灵活的流程定义和...

    jbpm3.2.3可运行实例源码

    1. 配置并启动数据库,确保jbpm需要的表存在。 2. 将jbpm3.2.3的库添加到项目的类路径中,包括核心库、持久化库以及Web应用所需的库。 3. 配置jbpm的配置文件以指向你的数据库。 4. 部署"jbpm_web"到Web服务器,如...

    jbpm介绍jbpm介绍jbpm介绍jbpm介绍jbpm介绍

    jBPM 可以在任何 JavaEE 应用服务器或配置了 JDBC 的 JVM 上运行。 #### 二、选择 jBPM 的十大理由 1. **嵌入式工作流引擎**:jBPM 作为嵌入式引擎减少了硬件投入,降低了网络和集群的复杂度。 2. **图形化开发工具...

    jBPM4.4开发指南

    - **运行控制功能**:在运行环境中管理工作流过程,对工作流过程中的活动进行调度。 - **运行交互功能**:在工作流运行中,WfMS与用户(活动的参与者)及外部应用程序工具交互的功能。 **3. 采用工作流管理系统的...

    JBPM工作流详解

    2. **运行控制功能**:在运行环境中管理工作流过程,对工作流过程中的活动进行调度; 3. **运行交互功能**:在工作流运行期间,WfMS与用户(活动参与者)及外部应用程序之间的交互功能。 采用工作流管理系统的优势...

    ssh整合jbpm5.4

    它提供了强大的动作调度、拦截器机制以及丰富的插件支持,使开发者能更好地组织和控制应用程序的行为。 Spring3.1则是一个全面的后端应用程序框架,提供了依赖注入(Dependency Injection,DI)、面向切面编程...

    jbpm4.2 doc(JBPM开发文档)

    这个文档集合主要面向开发者,帮助他们理解和应用JBPM 4.2进行业务流程的开发和管理。 【核心概念】 1. **工作流引擎**:JBPM的核心组件,负责执行定义好的业务流程。它解析流程定义文件,调度任务,处理流程实例...

Global site tag (gtag.js) - Google Analytics