首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >(9)Shark工作流的实现和WMFC&OMG规范的对比

(9)Shark工作流的实现和WMFC&OMG规范的对比

作者头像
田春峰-JCJC错别字检测
发布2019-02-14 14:57:14
3340
发布2019-02-14 14:57:14
举报

Shark工作流的实现和WMFC&OMG规范的对比

-----第九部分:分析obe自带例子的执行过程

<?xml:namespace prefix = o ns = "urn:schemas-microsoft-com:office:office" />

关键字:Shark 工作流 WMFC OMG 规范

Obe工作流的执行过程,下面来说说自带test中的例子的执行过程:

初始化工作流引擎的时候需要一个RepositoryManager 的实例

RepositoryManager 代表工作流执行中需要的资源库,比如:活动的参与者,活动中需要调用的外部工具信息,等等。然后进行工作流引擎的初始化:

WorkflowEngine engine = new WorkflowEngine(repositoryManager);

引擎初始化后用obe的xpdl解析类从用户定义的xpdl流程中实例化Package。

XPDLParser parser = new Dom4JXPDLParser();

FileInputStream in = new FileInputStream(file);

Package pkg = null;

try{

pkg = parser.parse(in);

} catch(Exception e){

log.fatal("Error parsing configuration: " + e.getMessage());

e.printStackTrace();

return;

}

然后把初始化后的package加入到引擎实例中:

engine.addPackage(pkg);

随后就执行了:

try{

log.info("Executing workflow process " + packageId + ":" + processId);

if(executionMode.equalsIgnoreCase("asynch")){

log.info("Executing asynchronously");

engine.executeAsynch(packageId, processId, getParameters());

} else {

log.info("Executing synchronously");

engine.executeSynch(packageId, processId, getParameters());

}

} catch(Exception e){

log.error("Error executing workflow process " + processId + " in package " + packageId);

e.printStackTrace();

}

看起来整个执行流程很简单。

上面提到的RepositoryManager是如何初始化的呢?

例子中带的资源库有如下类型:

1、 BasicApplicationRepository

2、 BasicProcedureRepository

3、 BasicParticipantRepository

其中BasicParticipantRepository下面又包括: 1)RoundRobinGroup

2)WorkflowSystem

比如:添加管理和编辑人员信息:

RoundRobinGroup editors = new RoundRobinGroup();

editors.add(new Human("Bob Smith"));

editors.add(new Human("Joe User"));

RoundRobinGroup administrators = new RoundRobinGroup();

administrators.add(new Human("Anthony Eden"));

WorkflowSystem system = new WorkflowSystem();

participantRepository.put("P1", editors);

participantRepository.put("P2", administrators);

participantRepository.put("P3", system);

participantRepository.setDefaultConnector(system);

getParticipantRepositories().add(participantRepository);

BasicApplicationRepository appRepository = new BasicApplicationRepository();

appRepository.put("A1", new DebugApplicationConnector("App 1"));

appRepository.put("A2", new DebugApplicationConnector("App 2"));

appRepository.put("A3", new RuntimeApplicationConnector(TEST_EXE,

ExecutionType.SYNCHRONOUS));

appRepository.put("A4", new DebugApplicationConnector("App 4", 10000));

appRepository.put("A5", new DebugApplicationConnector("App 5"));

getApplicationRepositories().add(appRepository);

下面 我们根据obe提供的例子结合引擎分析 obe引擎的执行过程。

待续

田春峰

accesine@163.com

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2004年02月11日,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档