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

王朝other·作者佚名  2006-01-08
窄屏简体版  字體: |||超大  

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

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

关键字: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

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
 
 
© 2005- 王朝網路 版權所有 導航