JBPM「建议收藏」

JBPM

大家好,又见面了,我是全栈君。

JBPM简介

什么是jbpm

   JBPM,全称是Java Business Process Management(业务流程管理),它是覆盖了业务流程管理、工作流、服务协作等领域的一个开源的、灵活的、易扩展的可执行流程语言框架。

为什么用jbpm

     业务分析师和开发人员使用的是同一种语言来交谈,大大降低了开发的风险,如果要开发一个项目,速度也更快了,因为开发人员不用再将用户需求转化成软件设计了。其次,JBPM采用的不是一般的开发工具,而是自己的图形化开发工具,非常方便随时了解和掌握运行的进程。最后,JBPM的流程框架非常灵活,使用起来也非常安全,它经过了安全认证,因此可以保证一些商业机密不被

 

JBPM所需要的jar包

JBPM「建议收藏」

JBPM「建议收藏」

JBPM「建议收藏」

1.创建表结构

@Test
public void create(){

new org.hibernate.cfg.Configuration().configure("jbpm.hibernate.cfg.xml").buildSessionFactory();
System.out.println("ok");

}

2.创建ProcessEngine对象

    ProcessEngine pro=Configuration.getProcessEngine();

3.部署流程定义

@Test
    //部署流程定义
    public void getDeploy(){
    
        String re=pro.getRepositoryService()
                .createDeployment()
                .addResourceFromClasspath("jbpms.jpdl.xml")
                .addResourceFromClasspath("jbpms.png").deploy();
        System.out.println(re);
     }
    

4. 启动流程实例  通过key,key是process节点中的key,如果不写,默认为name的值

@Test
    public void testStart(){
         //启动流程实例  通过key,key是process节点中的key,如果不写,默认为name的值
      ProcessInstance pi=pro.getExecutionService().startProcessInstanceByKey("jbpms");
      System.out.println("start ok!");
      System.out.println("id:"+pi.getId()+",状态:"+pi.getState()+",流程定义的ID:"+pi.getProcessDefinitionId());
    }
    

5.查看任务列表

    
    @Test
    public void selectTask(){
        //查看任务列表
        String user="hh";
        String user2="boss";
        List<Task> tasks = pro.getTaskService().findPersonalTasks(user);
        for (Task task : tasks) {
            System.out.println("任务ID:"+task.getId()+"\t任务名称:"+task.getName()+"\t任务的办理人:"+task.getAssignee());
        }
        

6.查询当前任务所在点

    @Test
    public void findSelect(){
        //查询当前任务所在点
        String name=pro.getExecutionService().createProcessInstanceQuery().processInstanceId("jbpms.130001").uniqueResult().findActiveActivityNames().toString();
        System.out.println(name);
    }

7.办理任务

@Test
    public void testCompleteTask(){
        pro.getTaskService().completeTask("130002");
        System.out.println("ok");
    }

流程管理

 

public class ProcessTest {
    
    ProcessEngine pro=Configuration.getProcessEngine();
    
    @Test
    public void findAll(){
        //查询所有流程定义
        List<ProcessDefinition> list=pro.getRepositoryService().createProcessDefinitionQuery().list();
        
        for (ProcessDefinition pd : list) {
            System.out.println("id:"+pd.getId()+"\tname:"+pd.getName()+"\tkey:"+pd.getKey()+"\t版本号:"+pd.getVersion()+"\t部署的id:"+pd.getDeploymentId());
        }
        
    }

 

查看所有流程定义的信息

@Test

public void findAll(){

List<ProcessDefinition> list = pe.getRepositoryService().createProcessDefinitionQuery().list();

for (ProcessDefinition pd : list) {

/**

 * id的格式  name-版本号

 * name:jbpm.cfg.xml文件中根据点的name属性值

 * key,如果在配置文件中指定了,那么就是根据点中的test的 值,如果不指定默认是name的值

 * version版本号,同一个名称的第一个为1后续的自增

 */

System.out.println("id:"+pd.getId()+"\tname:"+pd.getName()+"\tkey"+pd.getKey()+"\t版本号:"+pd.getVersion()+"\t部署的id:"+pd.getDeploymentId());

}

}

 

删除指定id流程信息

  @Test
    public void deleteByid(){
        pe.getRepositoryService().deleteDeploymentCascade("100001");
        System.out.println("删除成功");
    }

删除指定key的所有流程信息

 

 @Test
    public void deleteByids(){
        //01.取出当前key对应的版本信息
    List<ProcessDefinition> list = pe.getRepositoryService().createProcessDefinitionQuery().processDefinitionKey("jbpmtest").list();
        for (ProcessDefinition pd : list) {
              pe.getRepositoryService().deleteDeploymentCascade(pd.getDeploymentId());
        }
        System.out.println("删除成功");
    }

 

获取流程图

 @Test
    public void getImage() throws Exception{
        String deploymentId="10001";
        String resouceName="jbpmtest.png";
        //根据id去查询所有对应的资源名
        Set<String> resourceNames = pe.getRepositoryService().getResourceNames(deploymentId);
        for(String item: resourceNames){
            System.out.println("资源名称:"+item);
        }
        InputStream in=pe.getRepositoryService().getResourceAsStream(deploymentId, resouceName);
        OutputStream os=new FileOutputStream("D:\\1.png");
        int a=in.read();
        while (a!=-1) {
            os.write(a);
            a=in.read();
        }
        in.close();
        os.close();
        System.out.println("成功");
    }
    

部署zip格式的资源

public void addZipResource(){
        InputStream is=this.getClass().getClassLoader().getResourceAsStream("two.zip");
        ZipInputStream zs=new ZipInputStream(is);
        String id= pe.getRepositoryService().createDeployment().addResourcesFromZipInputStream(zs).deploy();
          System.out.println("部署成功:deploymentid:"+id);
    }

找到所有最新版本的流程定义

@Test
    public void findNewVersionInfo(){
        //查询所有
        List<ProcessDefinition> list = pe.getRepositoryService().createProcessDefinitionQuery()//
        .orderAsc(ProcessDefinitionQuery.PROPERTY_VERSION)
                .list();
        Map<String,ProcessDefinition> map=new java.util.HashMap<String,ProcessDefinition>();
        for (ProcessDefinition item : list) {
            map.put(item.getKey(),item);
        }
        for (ProcessDefinition pd : map.values()) {
            System.out.println("id:"+pd.getId()+"\tname:"+pd.getName()+"\tkey"+pd.getKey()+"\t版本号:"+pd.getVersion()+"\t部署的id:"+pd.getDeploymentId());
        }
    }

设置流程变量

public void setVariable() {
        pe.getExecutionService().setVariable("jbpm01.90001", "请假天数", 18);
    }

@Test
    public void getVariable() {
        Integer days = (Integer) pe.getExecutionService().getVariable("jbpm01.90001", "请假天数");
        System.out.println(days);
    }

 

 

 

 

 

 

转载于:https://www.cnblogs.com/Smile-123/p/6150630.html

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/108733.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • 软测试总结

    软测试总结

    2022年1月12日
    43
  • Fibers_fiber bundle

    Fibers_fiber bundle要理解Fibers首先需要对抢占式多任务和协作式多任务有所了解抢占式多任务抢占式是指暂停或中断正在执行的计算任务,而不是与其合作。中断后再继续恢复该任务的执行,这种改变又称为上下文切换。其缺点在于操作系统可能会在一个不适当的时间进行上下文切换。例如:Linux的调度程序特权任务Scheduler采用的就是取消进程任务,而不是与其合作。协作式多任务早期的多任务处理系…

    2025年8月21日
    3
  • 计算机三级数据库技术复习资料总结

    计算机三级数据库技术复习资料总结第7章数据库及数据库对象一、创建及维护数据库1、两大类:系统数据库(自动创建和维护的):master:最重要的数据库,记录所有系统级信息,主要的信息都是存放在这。msdb:保存报警、作业、操作员等信息。(考的不多)model:所有创建数据库的模板。tempdb:临时数据库,每次启动SQL都会重新创建,因此不需要备份。Resource:只读数据库。(没见过考)用户数据库(用户创建和维护)经常考选择题:系统数据库如何备份?(未完成)2、数据库文件分类数据文件:主要数据文件:每个数据

    2022年6月18日
    27
  • Android开发—-简单几步教你制作一个简易的音乐播放器

    Android开发—-简单几步教你制作一个简易的音乐播放器前言:本博文只教你编程的思想,就举一个简单的例子来实现我们的简易的音乐播放器,大家不喜勿喷啊友情提示:本博文用到的是AndroidStudio进行开发的,软件安装教程:AndroidStudio安装教程:文章目录:一.缓冲界面实现:二:播放音乐界面:一.缓冲界面实现:在前面的博客中也讲到了关于界面缓冲跳转的方法,详情请查:3种方式实现界面缓冲,为什么要设置这个呢?自我感觉当用户点进应用后,至少有一个缓冲时间,不仅仅是让用户缓冲也是为了让程序内部进行缓冲缓冲,话不多说一起来看看设计:当然首先是界

    2022年7月16日
    17
  • linux读写锁_共享内存读写锁

    linux读写锁_共享内存读写锁一、读写锁是什么?读写锁其实还是一种锁,是给一段临界区代码加锁,但是此加锁是在进行写操作的时候才会互斥,而在进行读的时候是可以共享的进行访问临界区的ps:读写锁本质上是一种自旋锁二、为什么需要读写锁?有时候,在多线程中,有一些公共数据修改的机会比较少,而读的机会却是非常多的,此公共数据的操作基本都是读,如果每次操作都给此段代码加锁,太浪费时间了而且也很浪费资源…

    2022年8月12日
    8
  • Linux下Open函数

    Linux下Open函数文章目录Open介绍参数案例输出结果:文件描述符fdOpen介绍 Open函数用来打开一个文件,建立一个文件描述符到文件路径的映射,建立文件标识。 open函数原型如下所示:#include&amp;lt;fcntl.h&amp;gt;intopen(constchar*pathname,intflag,…);参数pathname是要打开或者创建的文件路径名,可以是绝对路径也…

    2022年5月26日
    33

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号