第 2 部分：使用 BPEL 构建 Web 服务网络
作者：Yves Coene 和 The Hoa Nguyen

欧洲航天局使用 BPEL 作用域、BPEL 域和 Oracle BPEL 流程管理器 API 构建易于合作伙伴使用的 Web 服务网络的案例研究。

本文相关下载： Oracle BPEL 流程管理器和 Designer

受不断成熟的 Web 服务标准的鼓舞，越来越多的组织正在协作环境中使用 Web 服务。BPEL 正快速成为为实现企业间协作而编排这些 Web 服务的平台。BPEL 为构建在线市场或协作网络的公司提供了引人瞩目的好处，即基于标准的方法和松散耦合的流程集成。

而 Web 服务提供的激动人心的新功能却隐藏着某些风险。在许多情况下，如果在设计时未解决某些技术和管理难题，则合作伙伴关系将会破裂或集成成本飙升：

• 合作伙伴必须事先进行充分的协商，约定根据特定标准开展业务。传输协议、交互目的、消息格式以及业务约束必须实现清晰地通信。
• 连接网络必须是一个简单的过程；协作网络主要通过不断壮大取得成功。
• 用户必须在运行时轻松地找到业务服务，否则将在很大程度上无法实现面向服务体系结构 (SOA) 这一承诺。（服务信息库在这方面很有用。）如果开发人员无法轻松地找到和重用服务，则这些服务本质上就算不存在。
• 合作伙伴应能够实时监控 Web 服务。最终用户应能跟踪特定订单的进度，并且贸易合作伙伴应能诊断业务流程中的特定瓶颈。

在 BPEL 指南的这一部分中，我将把欧洲航天局 (ESA) 项目（来自 Spacebel s.a. 的小组参与了该项目）作为一个案例分析，介绍与这些挑战相关的体系结构注意事项。此外，我还将介绍该项目如何利用 BPEL 作用域、BPEL 域和 Oracle BPEL 流程管理器 API 构建一个“易于合作伙伴使用的”协作网络。

图 1 SSE 体系结构

• 承载和管理充当可用服务目录的中央信息库
• 在中央目录内部注册和搜索服务
• 在 Oracle BPEL 引擎内部执行短期和长期的业务流程
• 使合作伙伴能够使用 Oracle BPEL 流程管理器控制台监控 Web 服务的执行

SSE 支持同步和异步的交互模型。ESA 广泛使用 Oracle BPEL 流程管理器 API 来为提供商和最终用户提供最大程度的灵活性和易用性体验。

• 设置接口关系
• 简化合作伙伴支持
• 创建集中的服务注册表
• 为合作伙伴和最终用户提供自助监视功能

• 交互的目的 — 是请求报价还是订单？
• 消息格式 - 消息是如何编码的？
• 词汇 — 应如何构造消息，以便其他各方可以理解和处理它们？
• 业务约束 - 应在多长时间内响应请求？
• 通信渠道 - 是否应把消息加密？

• 根据选定的交互模型（搜索、RFQ、订购）选择的操作
• 服务的物理位置
• 服务 XSD 模式的导入

                               
<xsl:stylesheet version="1.0" xmlns:xsl="http://www.w3.org/1999/XSL/Transform" xmlns:oi="http://www.esa.int/oi">
<!-- Import statements -->
<xsl:import href="./SSE.xsl"/>
<!-- Apply the template for the root element from SSE standard template -->
<xsl:template match="/">
<xsl:apply-imports/>
</xsl:template>
...

                            

• 与集线器的集成 - 合作伙伴如何创建和提交他们的 Web 服务？集线器能否支持不同的传输协议？
• 流程管理 - 不同合作伙伴流程之间是否有清晰的界限？合作伙伴能否修改它的业务流程而不影响整个网络的可靠性？能否使用元数据定义即时生成流程？

以下是一个 createDomain 方法示例：

                               
/**
* Create new domain space for a service provider to hold her/his services workflow
* definitions files in
     *
* @param domainName The Id to identify the domain
* @param password The password used to login to the corresponding domain
* @exception RemoteException System communication error
* @exception WorkflowException Thrown if any error happens on the server that prevent the delete
     *
     */
public void createDomain(String domainName, String password)
throws RemoteException, WorkflowException{
if(ml.isDebugEnabled()) ml.debug("Enter createDomain(domain = " + domainName + " password = " + password);
      /**
* check if the being created domain exist?
       */
      
try {
                Locator locator = new Locator(domainName, password);
                ml.info("Stop creating domain:" + domainName + " because it has already existed.");
                throw new WorkflowException("1019");
                
} catch (com.oracle.bpel.client.ServerException e) {
                ;
      }
try {
//obtain the domain admin password from the system configuration SSE.properties file
String domainAdminPassword = SystemConfigurationInfo.getProperty(WorkflowConstant.BPEL_DOMAIN_ADMIN_PASSWORD);
ServerAuth auth = ServerAuthFactory.authenticate( domainAdminPassword, "localhost" );
if(ml.isDebugEnabled()) ml.debug("obtain authentication ok");
// Create server object ... this is our service interface
          //
Server server = new Server( auth );
// Domain id is "newDomain", the password is "myPassword"
if(ml.isDebugEnabled()) ml.debug("create server instance ok");
          //
                  Map domainProperties = new HashMap();
                  domainProperties.put( Configuration.DATASOURCE_JNDI, SystemConfigurationInfo.getProperty
(CommonConstant.DEFAULT_BPELDOMAIN_DS_JNDI));
                  domainProperties.put( Configuration.TX_DATASOURCE_JNDI, SystemConfigurationInfo.getProperty
(CommonConstant.DEFAULT_BPELDOMAIN_DS_JNDI));
                  
                  if(ml.isDebugEnabled()) ml.debug("create domain - ds jndi property key/value: 
" + Configuration.DATASOURCE_JNDI + "/" + SystemConfigurationInfo.getProperty
(CommonConstant.DEFAULT_BPELDOMAIN_DS_JNDI));                       
                  if(ml.isDebugEnabled()) ml.debug("create domain - tx_ds jndi property key/value: 
" + Configuration.TX_DATASOURCE_JNDI + "/" + SystemConfigurationInfo.getProperty
(CommonConstant.DEFAULT_BPELDOMAIN_DS_JNDI));
server.createDomain(domainName, password, domainProperties);
                            
          
                if(ml.isDebugEnabled()) ml.debug("Enter createDomain(domain = " + domainName + " password = " + password);

} catch( com.oracle.bpel.client.ServerException se ){
ml.error(se.getMessage());
if(ml.isDebugEnabled()) se.printStackTrace();
throw new WorkflowException("1018", se.getCause());
      }
    }

                            

                               
/**
* execute the ant script to build an Oracle BPEL process that implements the workflow.
* The script also deploys the workflow to the service domains.
* All input information is provided under the props at the input param.
* @param props Contain all necessary properties used to build/deploy the workflow BPEL process
* @throws WorkflowException
     */
private void runBuildScript(String buildFilename, Properties props) throws WorkflowException{
if(ml.isDebugEnabled())ml.debug("Enter runBuildScript(buildFileName = " + buildFilename +
", properties = ...");
try {
Project project = new Project();
project.init();
File buildFile = new File(buildFilename);

if (!buildFile.exists()) throw new WorkflowException("1015");
if(ml.isDebugEnabled()) ml.debug("ant build file:" + buildFile.getAbsolutePath());

ProjectHelper.configureProject(project, buildFile);
//prepare logger for the project build
PrintStream out = System.out;
BuildLogger logger = new DefaultLogger();
logger.setMessageOutputLevel(Project.MSG_DEBUG);
logger.setOutputPrintStream(out);
logger.setErrorPrintStream(out);
project.addBuildListener(logger);

//set project properties
Enumeration keys = props.keys();
while(keys.hasMoreElements()){
String key = keys.nextElement().toString();
project.setProperty(key, props.getProperty(key));
            
          }
// test 
//excute default target
project.executeTarget(project.getDefaultTarget());
                  if(ml.isDebugEnabled())ml.debug("Exit runBuildScript(buildFileName = " + buildFilename +
                                  ", properties = ...");
        }
catch (Exception ex) {
ml.error(ex.getMessage());
if(ml.isDebugEnabled()) ex.printStackTrace();
throw new WorkflowException("1002",ex.getCause());
        } 
  }

                            

• 将单个 Oracle BPEL 流程管理器实例划分为多开发人员环境。这种情况下，域 ID 通常标识拥有该域的开发人员。
• 将单个 Oracle BPEL 流程管理器实例划分为开发环境和 QA 环境。这种情况下，域 ID 可能为“test”和“QA”。
• 将单个 Oracle BPEL 流程管理器实例划分为一个可以由多个部门或合作伙伴使用的环境。这些情况下，域 ID 是部门或合作伙伴的名称。

SSE 网络频繁使用中央 Web 服务信息库；合作伙伴使用 Web 服务检查语言 (WSIL) 发现可用服务。服务提供商可以通过选择相应的 WSDL 文件重用现有的 Web 服务（由网络中的其他提供商提供）。可以在 Oracle BPEL Designer 工具配置文件 UDDIProviderList.xml 中添加 WS-Inspection URL http://services.eoportal.org/inspection.wsil 来完成此任务，如下所示。

<provider>     
<description>ESA SSE Portal</description>     
<type>wsil</type> 
<inquiryURL>
http://services.eoportal.org/inspection.wsil
</inquiryURL>  
</provider>

图 2 可用 SSE 服务列表

尽管您不必建立服务信息库即可构建 SOA 并获得它的众多好处，但从长远来看，信息库是不可或缺的。如果服务的作用域只是一个项目，则架构师不用信息库也能处理。但大多数企业都拥有各种服务和合作伙伴，并且这些服务和合作伙伴的大部分都在不断变化。

提供自助式监视。在多方参与业务流程的协作网络中，对业务流程执行情况的监视非常关键，因此可以将围绕业务流程的关键性能指标与服务级协议相联系。（例如，加入网络的关键要求之一可能是确认两小时内的报价请求。）监视业务流程可以更好地获知特定业务流程实例执行的时间、出现延迟的原因以及如何为未来事务修复此问题。

图 3 使用 Oracle BPEL 控制台监视业务流程

作用域 按层次结构组织，一个复杂的业务流程可以分为几个作用域。它们为活动提供了行为上下文。通过在 BPEL 流程中使用有意义的作用域名称，合作伙伴可以跟踪“短期”和“长期”业务流程的状态。

                               
* call the Oracle BPEL API to get current status of the workflow instance, corresponding to
* the ordered supplied at the input
* @param ordered The order identified
* @param workflowId The workflow name (or Id) that is processing the order stage.
* Normally, there are two stages of an order:send(process)rfq and send(process) order
* @param domain The domain that the order workflow belongs to
* @param password The password used to login to the workflow domain
* @return the current status of the workflow instance - particularly, it is the name of the current
* active scope in the workflow BPEL file. 
* @throws RemoteException
* @throws WorkflowException
 */
public String getOrderSubstatus(String ordered, String workflowId, String domain,  String password)
        throws RemoteException, WorkflowException 
 {
                if(ml.isDebugEnabled()) ml.debug("Enter getOrderSubstatus(ordered = " + ordered
                         + ", workflowId = " + workflowId + ", domain = " + domain + ", password = " + password);
                String status = "";
                try {
                                
                        Locator locator = new Locator(domain, password);
                        IinstanceHandle instance = locator.lookupInstance(ordered + "_" + workflowId);
                                
                        if( instance.isComplete() )  status = "Completed";
                        else status = instance.getStatus();
                                
                        return status;
                } catch (com.oracle.bpel.client.ServerException e) {
                        // TODO Auto-generated catch block

                        ml.error(e.getMessage());
                        if(ml.isDebugEnabled()) e.printStackTrace(); 
                        throw new WorkflowException("1016", e.getCause());
                }
                        
}

                            

将您的意见发送给我们