Apache ODE开发指南
ODE的关键组成部分包括ODE BPEL编译器，ODE BPEL引擎 Runtime，ODE数据访问对象（ DAOs ） ，ODE整合层（ILS） ，以及用户工具。如下图所示： “编译器将BPEL文件转换成可在ODE BPEL引擎 Runtime中执行的对象，这些对象可通过一个可靠的方式依靠ODE数据访问对象进行可持久化的存取;运行时环境之上则是ODE整合层，它连接到外部世界更广泛的执行环境
如上图所示：
BPEL编译器负责将BPEL相关资源（BPEL描述文档，WSDL和Schema）编译成可执行的描述。编译成功之后会产生一个扩展名为.cbp的文件，该文件是BPEL运行时唯一需要的文件。编译失败时，编译器会列出与资源有关的错误信息。
BPEL引擎运行时负责执行编译后的BPEL过程，主要的功能包括：过程实例的创建、销毁、消息的收发等。它还为用户工具与引擎交互提供了过程管理API。执行过程中的实例状态跟踪和消息传递都会需要利用持久化机制，这由DAO组件来完成。引擎运行时(Runtime)利用java并发对象（java Concurrent Object，Jacob）来完成过程实例的状态表示和并发性管理。Jacob提供了应用性的并发机制，它不依赖于线程，这样就降低了系统的开销。
ODEDAO组件负责BPEL引擎运行时和底层数据存储的交互，数据存储一般使用关系数据库。此时。DAO由OpenJPA来实现。可以自定义不使用JDBC的DAO实现，目前ODE并不提供这种DAO实现。对于自定义DAO实现，需要处理以下持久化问题：
激活实例，跟踪哪些实例已经被创建；
消息路由，哪些实例在等待哪些消息；
变量，每个实例的BPEL变量的值；
合作伙伴链接(partner links)，每个实例的BPEL合作伙伴链接值；
过程执行状态，序列化JACOB的状态。
ODE BPEL引擎运行时依赖集成层(IL)与外界进行通信。在执行环境中，集成层内嵌了运行时。除了通信，集成层还给运行时提供了线程调度机制，并管理运行时的生命周期。当前版本提供了两种集成层实现：Apache AXIS2,使用WEB服务进行交互；ServiceMix ix,通过JBI消息总线进行交互。
webserver接口开发ODE所提供的流程管理接口通常定义了五种操作：
● List—获取流程的信息列表
● Details---获取流程定义的具体信息
● Set-properties---改变流程定义的属性
● Activate---激活新的流程定义
● Retire---撤销某些流程定义
对流程的管理通过org.apache.ode.bpel.pmapi包中的接口ProcessManagement来实现。它的实现类是org.apache.ine包中的BpelManagementFacadeImpl和ProcessAndInstanceManagementImpl。
其中ProcessManagement提供的方法有：
方法 | 描述 |
activate(l.namespace.QName pid) | 激活一个流程 |
getProcessInfo(l.namespace.QName pid) | 得到一个流程的详细信息 |
listAllProcesses() | 列出流程引擎中的所有流程 |
listProcesses(java.lang.String filter, java.lang.String orderKeys) | 列出符合某些过滤条件的流程 |
setPackageRetired(java.lang.String packageName, boolean retired) | 使某个包中的所有流程失去作用 |
setProcessProperty(l.namespace.QName pid, l.namespace.QName propertyName, java.lang.String value) | 为BPEL流程的某个属性赋值 |
setRetired(l.namespace.QName pid, boolean retired) Retire a process. | 使某个流程失去作用 |
在listProcesses函数中Filter字符串用来对流程进行某些条件的过滤处理，它有下面四种过滤方式：
● Name---由流程的名字来进行过滤
● Namespace---根据命名空间来进行过滤
● Status---根据流程状态来进行过滤
● Deployed---由流程部署时间来进行过滤。如：想得到2005年9月1号部署的所有流程，则filter字符串表示为”deployed>=20050901”.
BpelManagementFacadeImpl类中所定义的方法有：
方法 | 描述 |
getProcessInstance(java.lang.String pid, CorrelationKey ckey | 获取某个流程的实例，ckey代表实例的关联键值 |
getVariable(java.lang.Long iid, java.lang.Long scopeId, java.lang.String varName) | 获取流程变量 |
setVariable(java.lang.Long pid, java.lang.Long scopeId, java.lang.String varName, java.lang.String data) | 设置流程变量 |
getProcessDef(java.lang.String procid) | 获取流程定义 |
getStartTime(java.lang.Long iid) | 获取流程实例的开始时间 |
getState(java.lang.Long iid) | 获取流程实例状态 |
getEvents(java.lang.Long iid, int startIdx, int count) | 获取流程实例的事件历史纪录 |
getEventCount(java.lang.Long iid) | 获取流程实例的事件数目 |
getBreakpoints(java.lang.Long iid) | 获取流程实例的断点 |
getGlobalBreakpoints(java.lang.String procId) | 获取流程实例中的全局断点 |
removeBreakpoint(java.lang.Long iid, Breakpoint sp) | 移除断点 |
removeGlobalBreakpoint(java.lang.String procId, Breakpoint sp) | 移除全局断点 |
addActivityBreakpoint(java.lang.Long iid, java.lang.String activity) | 添加断点并激活 |
addGlobalActivityBreakpoint(java.lang.String procId, java.lang.String activity) | 添加全局断点 |
addVariableModificationBreakpoint(java.lang.Long iid, java.lang.String scopeName, java.lang.String variable) | 添加变量断点 |
对流程实例的管理主要通过org.apache.ode.bpel.pmapi包中的接口InstanceManagement来实现。它的实现类是org.apache.ine包中的BpelManagementFacadeImpl和ProcessAndInstanceManagementImpl。
其中InstanceManagement所提供的方法有：
方法 | 描述 |
listInstances(java.lang.String filter, java.lang.String order, int limit) | 获取符合条件的流程实例 |
listAllInstances() | 列出所有流程实例 |
listAllInstancesWithLimit(int limit) | 列出最多limit个数的所有流程实例 |
getInstanceInfo(java.lang.Long iid) | 获取流程实例信息 |
getScopeInfo(java.lang.String siid) | 获取实例范围信息 |
listEvents(java.lang.String instanceFilter, java.lang.String eventFilter, int maxCount) | 获取bpel事件信息 |
getEventTimeline(java.lang.String instanceFilter, java.lang.String eventFilter) | 获取事件的时间迹 |
suspend(java.lang.Long iid) | 暂停流程实例 |
resume(java.lang.Long iid) | 恢复流程实例 |
terminate(java.lang.Long iid) | 停止流程实例 |
fault(java.lang.Long iid, l.namespace.QName faultname, org.w3c.dom.Element faultData) | 将流程置为错误状态 |
delete(java.lang.String filter) | 删除一个流程实例 |
recoverActivity(java.lang.Long iid, java.lang.Long aid, java.lang.String action) | 覆盖一个活动的流程实例 |
流程实例的过滤可通过以下途径：
● Name---由实例名过滤
● Namespace---由命名空间过滤
● Status---由实例状态过滤
● Started---由某开始时间过滤
● Last-active---由上一次的激活时间过滤
● $property---由相关属性过滤
实例的状态有：
● active –-- 所有激活的实例
● completed –-- 所有完成的实例
● terminated –-- 所有中止的实例.
● failed –-- 所有失败的实例.
● suspended –--所有悬挂起的实例.
● error –--所有错误的实例.
对流程实例的操作：
● list ---返回符合条件的流程实例.
● detail ---获取某流程实例的详细信息
● suspend ---暂停流程实例
● resume ---唤醒暂停的流程实例
● terminate ---终止流程实例
● fault ---使流程实例运行失败
● delete ---删除流程实例
ProcessAndInstanceManagementImpl所提供的方法有：
方法 | 描述 |
ProcessAndInstanceManagementImpl(BpelServer server, ProcessStore store) | 构造方法，传递一个BPELServer进来 |
queryInstances(java.lang.String query) | 查询实例 |
Apache ODE通过传递BpelServer 接口对象给流程和流程实例的façade从而实现对流程和流程实例的管理与监控BpelServer 接口实现类BpelServerImpl定义出的方法如下：
方法 | 描述 |
Start() | 启动BPEL引擎，流程实例可以开始被执行 |
registerBpelEventListener(BpelEventListener listener) | 注册一个BPEL事件监听 |
unregisterBpelEventListener(BpelEventListener listener) | 取消一个BPEL事件监听 |
stop() | 停止BPEL引擎 |
init() | 初始化BPEL引擎 |
shutdown() | 关闭BPEL引擎 |
getEngine() | 获取BPEL引擎 |
register(ProcessConf conf) | 向BPEL引擎上注册一个流程 |
l.namespace.QName pid) | 从BPEL引擎上移除一个流程 |
setScheduler(Scheduler scheduler) | 在BPEL引擎上设置一个日程计划 |
setDaoConnectionFactory(BpelDAOConnectionFactory daoCF) | 设置DAO连接工厂 |
setBindingContext(BindingContext bc) | BPEL引擎利用绑定上下文进行服务注册 |
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论