activiti流程部署
activit部署方法api
activiti共有六种部署方式，最终实现都是DeploymentEntityImpl的addResource方法
代码语言：javascript复制public interface DeploymentBuilder {
//根据流进行部署,获取bpmn文件的流进行部署,resourceName是资源名可以自定义
DeploymentBuilder addInputStream(String resourceName, InputStream inputStream);
//通过文件路径进行部署
DeploymentBuilder addClasspathResource(String resource);
//根据文本字符串进行部署，文本字符串可以是读取文件的，也可以自己手写
DeploymentBuilder addString(String resourceName, String text);
//根据字节码尽心部署
DeploymentBuilder addBytes(String resourceName, byte[] bytes);
//根据zip流进行部署
DeploymentBuilder addZipInputStream(ZipInputStream zipInputStream);
//根据BpmnModel实例进行部署
DeploymentBuilder addBpmnModel(String resourceName, BpmnModel bpmnModel);}activiti部署前提
预设某些情况有了bpmn文件，首先我们需要repositoryService这个实例，接下来进行部署使用的都是这个实例
代码语言：javascript复制@Before
public void init() {
processEngine = ProcessEngineConfiguration
.createProcessEngineConfigurationFromResource(
"com/activiti_study/ch10/activiti1.cfg.xml")
.buildProcessEngine();
repositoryService = processEngine.getRepositoryService();
}activiti部署过程
zip流部署
这种方式是把其压缩成zip文件，然后进行部署
代码语言：javascript复制 @Test
public void testAddZipInputStream() throws Exception {
InputStream in = App.class.getClassLoader().getResourceAsStream(
"com/activiti_study/ch10/common.zip");
ZipInputStream zipInputStream = new ZipInputStream(in);
DeploymentBuilder deployment = repositoryService.createDeployment();
deployment.addZipInputStream(zipInputStream).deploy();
}普通流部署
根据资源文件路径，获取其流，进行部署
代码语言：javascript复制 @Test
public void testAddInputStream() throws Exception {
DeploymentBuilder deployment = repositoryService.createDeployment();
InputStream inputStream = App.class.getClassLoader()
.getResource("com/activiti_study/ch10/common.bpmn")
.openStream();
deployment.addInputStream(resourceName, inputStream).deploy();
}根据资源文件路径进行部署
代码语言：javascript复制 @Test
public void testAddClasspathResource() {
DeploymentBuilder deployment = repositoryService.createDeployment();
deployment.addClasspathResource(
"com/activiti_study/ch10/common.bpmn").deploy();
}根据bpmnModel实例进行部署
代码语言：javascript复制 @Test
public void testAddBpmnModel() {
DeploymentBuilder deployment = repositoryService.createDeployment();
BpmnModel bpmnModel = getBpmnModel();
deployment.addBpmnModel(resourceName, bpmnModel).deploy();
} private BpmnModel getBpmnModel() {
BpmnModel bpmnModel = new BpmnModel();
// 连线1
SequenceFlow flow1 = new SequenceFlow();
flow1.setId("flow1");
flow1.setName("开始节点-->任务节点1");
flow1.setSourceRef("start1");
flow1.setTargetRef("userTask1");
// 连线2
SequenceFlow flow2 = new SequenceFlow();
flow2.setId("flow2");
flow2.setName("任务节点1-->任务节点2");
flow2.setSourceRef("userTask1");
flow2.setTargetRef("userTask2");
// 连线3
SequenceFlow flow3 = new SequenceFlow();
flow3.setId("flow3");
flow3.setName("任务节点2-->结束节点");
flow3.setSourceRef("userTask2");
flow3.setTargetRef("endEvent");
// 开始节点
StartEvent start = new StartEvent();
start.setId("start1");
start.setName("开始节点");
start.setOutgoingFlows(Arrays.asList(flow1));
// 任务节点1
UserTask userTask1 = new UserTask();
userTask1.setId("userTask1");
userTask1.setName("任务节点1");
userTask1.setIncomingFlows(Arrays.asList(flow1));
userTask1.setOutgoingFlows(Arrays.asList(flow2));
// 任务节点2
UserTask userTask2 = new UserTask();
userTask2.setId("userTask2");
userTask2.setName("任务节点2");
userTask2.setIncomingFlows(Arrays.asList(flow2));
userTask2.setOutgoingFlows(Arrays.asList(flow3));
//结束节点
EndEvent endEvent = new org.activiti.bpmn.model.EndEvent();
endEvent.setId("endEvent");
endEvent.setName("结束节点");
endEvent.setIncomingFlows(Arrays.asList(flow3));
Process process=new Process();
process.setId("process1");
process.addFlowElement(start);
process.addFlowElement(flow1);
process.addFlowElement(flow2);
process.addFlowElement(flow3);
process.addFlowElement(userTask1);
process.addFlowElement(userTask2);
process.addFlowElement(endEvent);
bpmnModel.addProcess(process);
return bpmnModel;
}
根据纯文本进行部署
@Test
public void testAddSrtring() {
DeploymentBuilder deployment = repositoryService.createDeployment();
String text = readTxtFile("E:/activitilearing/activiti-study/src/main/java/com/shareniu/activiti_study/ch10/common.bpmn");
deployment.addString(resourceName, text).deploy();
}
public static String readTxtFile(String filePath) {
StringBuffer stringBuffer = new StringBuffer();
InputStreamReader read = null;
try {
String encoding = "UTF-8";// UTF-8编码
File file = new File(filePath);
if (file.isFile() && file.exists()) { // 判断文件是否存在
read = new InputStreamReader(new FileInputStream(file),
encoding);// 考虑到编码格式
BufferedReader bufferedReader = new BufferedReader(read);
String lineTxt = null;
while ((lineTxt = bufferedReader.readLine()) != null) {
stringBuffer.append(lineTxt);
}
return stringBuffer.toString();
} else {
System.out.println("找不到指定的文件");
}
} catch (Exception e) {
System.out.println("读取文件内容出错");
} finally {
try {
read.close();
} catch (IOException e) {
}
}
return "";
}
activiti部署后表数据
a) act_re_deployment
存放流程定义的显示名和部署时间，每部署一次增加一条记录
b) act_re_procdef
存放流程定义的属性信息，部署每个新的流程定义都会在这张表中增加一条记录。
c) act_ge_bytearray
存储流程定义相关的部署信息。即流程定义文档的存放地。每部署一次就会增加两条记录，一条是关于bpmn规则文件的，一条是图片的（如果部署时只指定了bpmn一个文件，activiti会在部署时解析bpmn文件内容自动生成流程图）。两个文件不是很大，都是以二进制形式存储在数据库中。
