Activiti简单的应用程序，业务颗粒与工作流程结合。让流程带动业务颗粒运行的过程。此次的监听我们应用抽象的监听来实现，也就是说全部的普通业务类均应用此抽象监听，而不须要每个类一个监听的来操作。

新建两个普通类：

package com.tgb.itoo.activiti.controller;public class milaoshi {	public static void SayHello(){		System.out.println("milaoshi--sayHello--");	}/*	public static void SayHi(){		System.out.println("milaoshi--sayHi--");	}*/}package com.tgb.itoo.activiti.controller;public class tanghuan {	public static void SayHello(){		System.out.println("tanghuan--sayHello--");	}	public static void SayHi(){		System.out.println("tanghuan--sayHi--");	}}

抽象监听类：

package com.tgb.itoo.activiti.controller;import java.lang.reflect.InvocationTargetException;import java.lang.reflect.Method;import java.util.HashMap;import java.util.Map;import org.activiti.engine.delegate.DelegateTask;import org.activiti.engine.delegate.TaskListener;public class CommonDelegate implements TaskListener{	static Map
    
      map;	public CommonDelegate(){}	public CommonDelegate(Map
     
       map){		this.map=map;	}			@Override	public void notify(DelegateTask delegateTask) {					Object obj=map.get("object");		Class clazz=obj.getClass();		Method[] methods=clazz.getDeclaredMethods();		for(int i=0;i
     
    

业务流程图 如图（tanghuan类和milaoshi类均绑定同一个监听）：

流程变量 如图（不允许如图，允许为${result}）：

终于生成的配置文件 例如以下：

启动流程相应的代码：

import java.io.BufferedReader;import java.io.IOException;import java.io.InputStreamReader;import java.util.HashMap;import java.util.Map;import org.activiti.engine.ProcessEngine;import org.activiti.engine.ProcessEngineConfiguration;import org.activiti.engine.RepositoryService;import org.activiti.engine.RuntimeService;import org.activiti.engine.TaskService;import org.activiti.engine.runtime.ProcessInstance;import org.activiti.engine.task.Task;import com.tgb.itoo.activiti.controller.CommonDelegate;import com.tgb.itoo.activiti.controller.milaoshi;import com.tgb.itoo.activiti.controller.tanghuan;public class MapDemo {	private static String readDataFromConsole(String prompt) {		BufferedReader br = new BufferedReader(new InputStreamReader(System.in));		String str = null;		try {			System.out.print(prompt);			str = br.readLine();		} catch (IOException e) {			e.printStackTrace();		}		return str;	}	public static void main(String[] args) {		String str = readDataFromConsole("Please input string：");		System.out.println("The information from console： " + str);		// 创建流程引擎		ProcessEngineConfiguration processEngineConfiguration = ProcessEngineConfiguration				.createStandaloneProcessEngineConfiguration();		// 连接数据库的配置		processEngineConfiguration.setJdbcDriver("com.mysql.jdbc.Driver");		processEngineConfiguration				.setJdbcUrl("jdbc:mysql://localhost:3306/activitiexam?

useUnicode=true&characterEncoding=utf8"); processEngineConfiguration.setJdbcUsername("root"); processEngineConfiguration.setJdbcPassword("root"); ProcessEngine processEngine = processEngineConfiguration .buildProcessEngine(); System.out.println(processEngine); // 获取流程存储服务组件 RepositoryService repositoryService = processEngine .getRepositoryService(); // 获取运行时服务组件 RuntimeService runtimeService = processEngine.getRuntimeService(); // 获取流程任务组件 TaskService taskService = processEngine.getTaskService(); // 1、部署流程文件 repositoryService.createDeployment().name("MyProcess") .addClasspathResource("diagrams/" + str + ".bpmn").deploy(); Map<Object,Object> map=new HashMap<Object,Object>(); tanghuan th=new tanghuan(); milaoshi mxj=new milaoshi(); //向map里面扔对象 map.put("object", th); /*map.put("milaoshi", mxj);*/ CommonDelegate common=new CommonDelegate(map); // 2、启动流程 ProcessInstance processInstance = runtimeService .startProcessInstanceByKey("myProcess"); String end="1";//processInstance.getId() != null while (end.equalsIgnoreCase("1")) { map.remove("object"); map.put("object", mxj); // 3、查询第一个任务 Task task = taskService.createTaskQuery() .processInstanceId(processInstance.getId()).singleResult(); ; if (task != null) { System.out.println("============" + task.getId() + "============" + task.getName() + "============"); str = readDataFromConsole("Please input result:"); Map<String, Object> variables = new HashMap<String, Object>(); Boolean result; if (str.equalsIgnoreCase("true")) { result = true; } else { result = false; } variables.put("result", result); taskService.complete(task.getId(), variables); // 完毕任务 }else { end="0"; System.out.println("任务已经完毕"); } } } }

运行结果：

总结：

    以上这样的方式主要是应用了反射技术实现。我们在client动态的向监听内扔对象，依据扔的对象来去运行相应的方法，降低了我们编写监听的个数。