随笔 - 181, 文章 - 2, 评论 - 85, 引用 - 0
数据加载中……

6月1日-----一个成功的团队要做到以下几点(转自IBMStar team blog)

尊重每个队员

虚心倾听

做出见识广博的决策

不要当众批评别人

了解自己的实力和自己做事的先后顺序

真诚的听取团队每个成员的意见和建议

对目标和交付产品有清楚的了解

在各个团队间提倡合作和信息共享

了解每个人的做事风格和他们的优缺点

表扬应以团队成员喜欢的方式,真诚地表达

将负面影响视为成长的机会

以积极的方式提供指导

posted @ 2006-06-01 17:13 wsdfsdf 阅读(451) | 评论 (6)编辑 收藏

6月1日-----在WPS中用human task manager来实现对第三方Service的异步调用

一、 引言

在developerWorks中,有许多文章介绍了WPS和WID在流程整合中的应用,比如BPEL开发、CEI监控和selector等等,那么,在实际的应用中,通常会有这样的场景:流程调用的一些第三方系统都是需要人工去审批,流程引擎发出调用第三方系统的请求后,是一个需要人审批的长流程(Long-runing process)。因此,这个调用是一个异步调用,只有第三方系统把审批结果传回给主流程,流程才能继续往下运行。这和直接在BPEL中直接实现的human task节点是不同的,因为用到了SCA组件的装配技术。

本文将详细介绍如何在WPS中利用SCA的编程模型实现human task manager对第三方系统的调用,并通过实际的例子加以说明,使读者能够掌握使用SCA和human task manager来实现对第三方系统的异步调用。







二、产品及其基本技术框架简介

1 WebSphere Process Server及其开发工具Integration Developer

WebSphere Process Server V 6.0(WebSphere流程服务器V 6.0)基于SOA体系架构并提供了统一的、简化的编程模型,是新一代的业务流程服务器,能够帮助我们基于SOA架构模型实现企业的业务流程转型。WebSphere流程服务器采用基于开放标准的技术来整合业务流程,实现自动化的流程服务器。采用WebSphere流程服务器可以通过统一的编程模型将企业的人员、工作流程、应用、系统、平台和基础设施整合在一起。

基于Eclipse技术的WPS专用开发工具WebSphere Integration Developer V6.0则为快速组装、开发业务解决方案提供了新一代的开发工具。采用这一工具可以基于统一的编程模型通过BPEL(Business Process Execution Language, 业务流程执行语言)来描述各类流程。它易于使用,仅需要少量的相关技能即可使用,并且提供了开发、测试和将应用部署到流程服务器的功能。

2 基本技术实现框架

2.1 SCA(服务组件编程架构模型)

为了使客户能够更加简单的实现向这种面向服务架构的转变,IBM在推出一系列WebSphere新产品的同时,提出了一种新的服务组件模型。这是一种全新的、跟语言无关的编程模型,它提供了一种统一的调用方式,从而使得客户可以把不同的组件类型,比如POJO, EJB, 流程组件,人工交互组件等都可以通过一种标准的接口来封装和调用。结合SDO的数据模型,这种服务组件的编程模型可以大大的简化客户的编程,提高应用的灵活性,这就是面向服务组件的架构(Service Component Architecture,SCA)。

2.2 human task

WPS V6中的人工任务管理器(Human Task Manager)模块实现了与人工任务相关的下列功能:

  • 让用户启动业务流程或者其他Service 组件
  • 实现业务流程中的Staff活动
  • 流程管理(Administration)
  • 动态创建含有与人工或者Service交互的任务

人工任务管理器针对三种基本场景:机器-人(Machine-to-Human),人-机器(Human-to-Machine),和人-人(Human-to-Human)。相应的,人工任务有四种不同类型,见下图。


图: 人工任务管理器
图: 人工任务管理器

其中,机器-人场景中的人工任务(participants)是我们这篇文章要主要介绍的,它使流程调用的service的执行中能融入人工交互,典型的例子是一个业务流程为参与业务执行的人创建任务。pTask是一个标准的SCA 组件,可以被用在任何希望引入人工交互的应用中而不仅仅是业务流程。

与其他工作流类的流程整合解决方案不同,WPS中引入了基于SCA service的人工任务,用户可以灵活地替换系统中基于SCA service的自动service和真正的人工实现。

2.3 Interface开发

在下面的实例中,我们是根据需求来确定出出第三方系统与主流程调用的接口(硬连接的方式),而在企业级应用中,也可以通过实施IBM WebSphere Message Broker来作为连接的应用接口,帮助WPS来连接企业应用。







三、样例背景及解决方案概述

3.1 方案背景

许多公司在不同时期都开发了企业内部的审批系统,某个部门内部的业务都各自有独立的系统来进行审批,而有的业务需要不同部门合作,那就只有通过人工来审批,手续相当繁琐,效率也不高。而为某项业务重新开发新的工作流引擎,又舍不得以前的IT投资,因此,企业就有了这样的需求:能否有这样的流程控制器可以将不同部门的独立系统统一的利用起来,实现跨系统的易更改工作流呢?

在我们这篇文章所举的范例中,是一个基于BPEL的审批流程,其中涉及到财务系统,项目管理系统2个独立的系统。其中财务系统是由Deiphi + OCX控件实现的,由SQL server存储数据;项目管理系统是一个J2EE系统,用DB2 数据库存储数据。

在需求中,项目管理系统必须依赖于财务系统才能进行审核等操作,需要把财务系统的数据传给项目管理系统,适当的时候,项目管理系统也要把相关数据传给财务系统。在此基础上,客户还可能有更高的需求,他们不但想要有流程的整合,还要有门户的整合,信息的整合。

3.2 IBM的解决方案

用WebSphere Process Server来做流程的整合,需要在不同的节点上完成与Deiphi和J2EE系统的异步调用,同时用Portal来做门户和信息的整合,并配置SSO, 用户只需要在Portal进行一次登陆,就可以相应的访问WPS系统、财务系统(DEiphi)、项目管理系统(J2EE)。相应用户登陆后可以看到自己的任务列表,如预算编制,项目建立,项目审批等。用户点击相应的任务,通过human task接口直接可以访问到第三方的系统,由第三方的系统得到与任务有关的数据,并直接组织数据发送给WPS.他们之间的通信方式是在SOAP协议上传输XML数据。

3.3 可行性分析

在WPS的装配图里可以实现的是,第三方的系统只需要提供一个接口,WPS就可以以异步或同步方式来访问组件。此需求里,客户要在系统里首先能看到自己的任务列表,点击不同的任务来决定到那个系统去。如客户任务列表里有一项的任务是"预算编制",用户一点击"预算编制",在Portal的另一个iframe就应把财务系统的相应界面调出来。Deiphi根据TaskID到WPS上把相应的数据取到本地并进行处理,用户进行适当的操作以后,Deiphi再把相应的数据发送给WPS,此过程可如下图所示:


图:HumantaskManager调用第三方系统流程
图:HumantaskManager调用第三方系统流程






四、解决方案开发

这一章将论述实现这个解决方案的每一个大的步骤,但并不详细论述如何step by step的实现,比如怎样定义BO,定义接口等,他们已超出了本次主题。因此,本文的读者必须对WID和WPS有一定的了解。

4.1 定义BO

BO是工作流平台与外界进行数据交互的数据格式,第一步我们首先明确工作流平台与第三方系统进行数据交互的定义,根据业务流程的需要,在每一个流程节点,第三方系统需要向WPS工作流平台放入哪些数据项,想要从工作流平台得到什么数据,都要定义出来。 如下图所示:

在BPEL每次调用第三方系统时,必须前期将输入输出的参数确定。主流程传出业务数据对象(BO),第三方系统接受后,进入自己的子流程,通过人工处理,将主流程需要的参数也以BO的方式传递给主流程,使流程能够继续运行。

在我们的例子中,主流程与2个子系统每次交互中,我们都定义了两个BO作为数据输入输出的数据格式,分别是OperationNameIN和OperationNameOut。在下图中,对应"编制预算"这个操作,我们分别定义2个BO,即BudgetBuildIn和BudgetBuildOut.


图:定义BO
图:定义BO

4.2 定义接口

这一步需要定义接口,如操作名称,输入数据及输出数据的定义,在WPS的开发流程里,每一个组件如果能在装配图里能被其他的组件所调用,就必须定义接口, Human Task 也不例外。

每个操作的输入和输出数据(input和output)的数据类型可以用默认的数据类型,如int、boolean等,也可以用我们定义好的BO。在我们的例子中,由于每次与财务系统或者项目管理系统交互时,都是组合数据,因此都用定义好的BO作为数据类型。如下图所示,在BudgetBuild接口中,定义了编制预算的操作:其输入输出的数据类型分别为budgetBuildIn和budgetBuildOut。


图:接口的定义
图:接口的定义

4.3 流程的具体定义

在Process里我们根据用户的具体业务需求,实现每一个节点,明确每一个节点是与那个系统进行交互的。整个Process有几次invoke,就表明与财务系统和项目管理系统有几次交互,即humantask实现的接口。


图:设计流程(BPEL)
图:设计流程(BPEL)

4.4 定义装配图

完成了所有的接口定义以后,我们需要在装配图里把他们都明确的用线连接起来,可以清楚地明确他们之间的调用关系及数据流向。如下图所示,把每个接口都拖入到装配图中,再分别用humantask来实现。最后,再把主流程Process拖到装配图中,通过"Wire to Existing"连接所有组件。


图:组件装配SCA
图:组件装配SCA

4.5 对外export 一个调用接口

所有的第三方系统通过这个component 来访问到WPS工作流平台。我们同样在装配图中建起连接。


图:暴露调用接口(SCA)
图:暴露调用接口(SCA)

4.6 实现一个统一的调用接口

如图所示,财务系统需要从WPS工作流平台得到与这个任务相关的数据,有人工处理以后,要传回到WPS工作流平台,并complete 这个任务。这里我们实现一个web service, 并对外提供两个接口供所有第三方系统进行调用,如Deilhpi, MQ WorkFlow, J2EE等。

该webservice的WSDL描述如下:


												
														      
  <wsdl:operation name="getHTInput">
         <wsdlsoap:operation soapAction=""/>
         <wsdl:input name="getHTInputRequest">
            <wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/"
			namespace="http://ForMIS.ibm.com" use="encoded"/>
         </wsdl:input>
         <wsdl:output name="getHTInputResponse">
            <wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/"
			namespace="http://ForMIS.ibm.com" use="encoded"/>
         </wsdl:output>
      </wsdl:operation>
      <wsdl:operation name="setHTOutput">
         <wsdlsoap:operation soapAction=""/>
         <wsdl:input name="setHTOutputRequest">
            <wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/"
			namespace="http://ForMIS.ibm.com" use="encoded"/>
         </wsdl:input>
         <wsdl:output name="setHTOutputResponse">
            <wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/"
			namespace="http://ForMIS.ibm.com" use="encoded"/>
         </wsdl:output>
      </wsdl:operation>
      
												
										

实现操作如下所述:

实现getHTInput operation

1) 得到HumanTaskManager实例


												
														RelationshipService  relService = (RelationshipService) ServiceManager.INSTANCE
			.locateService("com/ibm/wbiserver/rel/RelationshipService");
		InitialContext ctx = new InitialContext();
		Object myObj = ctx.lookup(HTM_MANAGER_NAME);
		HumanTaskManagerHome myHome = (HumanTaskManagerHome) PortableRemoteObject.narrow
		(myObj, com.ibm.task.api.HumanTaskManagerHome.class);
	HumanTaskManager	humanTaskManager = myHome.create();

												
										

2) 根据taskID得到第三方系统的需要得到的数据


												
														   ClientObjectWrapper input = null;
	input = humanTaskManager.getInputMessage(id);
   
												
										

实现setOutput operation

1) 得到HumanTaskManager实例


												
															
RelationshipService  relService = (RelationshipService) ServiceManager.INSTANCE
			.locateService("com/ibm/wbiserver/rel/RelationshipService");
		InitialContext ctx = new InitialContext();
		Object myObj = ctx.lookup(HTM_MANAGER_NAME);
		HumanTaskManagerHome myHome = (HumanTaskManagerHome) PortableRemoteObject.narrow(myObj,
		com.ibm.task.api.HumanTaskManagerHome.class);
	HumanTaskManager	humanTaskManager = myHome.create();
	
												
										

2) 根据taskID,把第三方上传的数据赋给WPS相应的Human Task


												
														ClientObjectWrapper outputWrapper = humanTaskManager.createOutputMessage(id);
					BusObjImpl busObjImpl = (BusObjImpl) outputWrapper
							.getObject();
					busObjImpl.set(0, output);

												
										

3) 完成这个任务complete


												
														humanTaskManager.complete(id,outputWrapper);

												
										

4. 7 试与部署

首先访问Http://localhost:9080/bpc 用bpc explorer进行测试,证明所有的节点都可以走通,就可以部署到WPS服务器上,与Portal及第三方系统(Deilphi, MQ WorkFlow, J2EE)进行互联测试。运行实例演示如下:

4.7.1 下图是获取任务列表的演示效果:

登陆系统后,用户将在系统中看到自己的任务列表,点中任务,就可以在下方的portlet中进行信息输入和审批。


图:任务列表和任务的人工处理
图:任务列表和任务的人工处理

4.7.2. 与Deiphi进行交互的页面


图:调用财务系统处理界面
图:调用财务系统处理界面

流程进入财务系统后,将调用财务系统,在OCX控件中进行相应的操作和处理,然后再把流程往下运行所需要的数据再传回给process。

4.7.3. 与MQ WorkFlow 的交互页面


图:调用项目管理操作界面
图:调用项目管理操作界面

与财务系统一样,当流程调用到项目管理系统时,也出现了项目管理所采用的MQ workflow的界面,进行相应处理和审批后,将数据传回给WPS,于是流程就可以继续往下运行。







五. 结束语

本篇文章主要讲述了一个解决方案,即如何利用Human Task把第三方系统连接到WPS 里,并实现人工参与及异步通信。这里着重介绍了解决方案的大致步骤,而没有关注于细节的描述。

posted @ 2006-06-01 17:02 wsdfsdf 阅读(720) | 评论 (0)编辑 收藏

6月1日-----IBM WebSphere 开发者技术期刊: 使用服务组件体系结构(SCA)构建 SOA 解决方案——第 1 部分

     摘要: 引言 您可能认为,这太棒了,又出现了一个编程模型,但事实并非如此。Web 服务怎么样了?Enterprise JavaBeans 发生了什么?服务组件体系结构 (SCA) 并非要替换任何现有的编程模型或者与其抗衡。相反,SCA 向您提供一个以与技术无关的方式定义接口、实现和引用的模型,从而使您能够将这些元素绑定到所选择的某一技术的特定实现。 例如,我...  阅读全文

posted @ 2006-06-01 17:00 wsdfsdf 阅读(384) | 评论 (0)编辑 收藏

6月1日-----IBM WebSphere 开发者技术期刊: 使用服务组件体系结构(SCA)构建 SOA 解决方案——第 3 部分

     摘要: 在本系列的第 1 部分,我们引入了服务组件体系结构作为编程模型来构建和组装集成解决方案,简要介绍了什么是 SCA,以及一些相关术语的定义。在第 2 部分,我们讨论了引用和限定符,并说明了如何将各种组件连接到一起以创建 SCA 模块。在第 3 部分,我们将深入了解构建 SCA 模块的主要好处之一,即能以各种组件为基础垂直构建集成解决方案。 随着系统不断发展而变得更为复杂,有必要将各种解决方案进...  阅读全文

posted @ 2006-06-01 16:56 wsdfsdf 阅读(263) | 评论 (0)编辑 收藏

6月1日-----SCA(Service Component Architecture)编程模型入门

概览

目前业界主要的软件厂商都在大力推广面向服务的架构(Service Oritented Architecture,SOA)的概念,但是对于很多客户来说,SOA的概念还是显得相对抽象的。为了使客户能够更加简单的实现向这种面向服务架构的转变,IBM在推出一系列WebSphere新产品的同时,提出了一种新的服务组件模型。这是一种全新的、跟语言无关的编程模型,它提供了一种统一的调用方式,从而使得客户可以把不同的组件类型,比如POJO, EJB, 流程组件,人工交互组件等都可以通过一种标准的接口来封装和调用。结合SDO的数据模型,这种服务组件的编程模型可以大大的简化客户的编程,提高应用的灵活性,这就是面向服务组件的架构(Service Component Architecture,SCA)。目前IBM 对SCA的支持是在最近推出的WebSphere Process Server(WPS)中,但是以后该服务组件模型将作为一个IBM软件重要的编程模型被应用到底层平台当中。本文将介绍SCA编程模型中的基本概念,并以一个简单的例子来说明它的一些基本用法,期待能够抛砖引玉,并为读者以后深入了解SCA打下基础。







1.1 SCA的起源

基于组件的编程一直是软件业简化编程和提高效率和质量的一个重要方法,但是往往对于不同语言我们有不同的组件模型,从而需要不同的调用方式。比如在J2EE技术领域,我们就有EJB,POJO,JDBC,JMS等,这对于开发人员来说是一个极大的挑战。为了给这些不同的接口提供一个统一的调用方式,IBM提出了WSIF (Web Service Invocation Framework,具体请参考http://ws.apache.org/wsif/ ),并将它贡献给Apache组织。WSIF作为Web Service领域的一个规范,提供了一种基于Java API统一调用各种服务的能力。但是WSIF没有形成一个基于组件的架构模型,因此IBM在此基础上推出了一个面向服务的组件模型(Service Oritented Architecture, SCA)。这个模型不但解决了统一调用的问题,还提出了一个基于组件的构建模型,并提供了许多面向企业计算的QoS能力。因此,从技术的角度来说,SCA是WSIF的延续和扩展。SCA的目的是使用户在构建企业应用时有一个不再直接面对具体的技术细节的层次,而是通过服务组件的方式来构建应用。这种方式也使得客户的企业应用具有良好的分层架构,能够很好的分离应用的业务逻辑和IT逻辑,不但易于应用的构建,也易于应用的更改和部署。







1.2 SCA中的基本概念

服务组件模型(SCA)中提出了一些新的概念,比如服务组件,模块,共享库,导入和导出等。下面将分别解释这些服务组件中的基本概念。

1.2.1 服务组件

服务组件是SCA中的基本组成元素和基本构建单位,也是我们具体实现业务逻辑的地方。我们可以把它看成是构建我们应用的积木。我们可以非常容易地把传统的POJO,无状态会话BEAN等包装成SCA中的服务组件。 SCA服务组件的主要接口规范是基于WSDL(Web Service Description Language)的,另外为了给Java编程人员提供一个比较直接的接口,SCA的部分服务组件也提供了Java接口。因此,使用服务组件的客户端可以选择使用WSDL接口或Java接口。

服务组件提供给别的服务调用的入口叫Interface(接口)。而服务组件本身可能也需要调用别的服务,这个调用出口叫Reference(引用)。无论是接口还是引用,其调用规范都是WSDL或Java接口。SCA服务组件的接口模型请参考图 1:


图 1: SCA 服务组件接口模型
图 1: SCA 服务组件接口模型

WebSphere Process Server 充分利用了SCA的这种组件架构,并在产品中提供了一些与业务联系比较紧密的组件,比如业务流程,人工任务,业务状态机,业务规则等。这样用户就可以直接利用这些服务组件,构建自己的业务流程或其它业务集成的应用。在WebSphere Process Server V6.0.1中,服务组件及SCA在架构中的作用如图 2所示:


图 2: WebSphere Process Server V6.0.1的架构环境
图 2: WebSphere Process Server V6.0.1的架构环境

我们可以从图 2 中看到服务组件架构在WebSphere Process Server中的基础地位,也可以看到各种与业务相关的服务组件或技术相关的辅助服务组件的关系。关于WebSphere Process Server的体系架构这里不展开论述,具体请参考developerWorks专刊,2005年第三期的文章――WebSphere Process Srever V6体系结构概述。

SCA服务组件与传统组件的主要区别在于:

1. 服务组件往往是粗粒度的,而传统组件以细粒度居多。

2. 服务组件的接口是标准的,主要是WSDL接口,而传统组件常以具体API形式出现。

3. 服务组件的实现与语言是无关的,而传统组件常绑定某种特定的语言。

4. 服务组件可以通过组件容器提供QoS的服务,而传统组件完全由程序代码直接控制。

1.2.2 服务模块(Module)

服务模块(简称模块)由一个或多个具有内在业务联系的服务组件构成。把多少服务组件放在一个模块中,或者把哪些服务组件放在一起主要取决于业务需求和部署上灵活性的要求。模块是SCA中的运行单位,因为一个SCA模块背后对应的是一个J2EE的企业应用项目。这里之所以说是"背后",原因是我们在开发工具WID(WebSphere Integration Developer V6.0)中,通过业务集成透视图看到都是SCA级别的元素。但是当你切换到J2EE透视图你就会发现这些SCA元素与实际J2EE元素之间的对应关系。因此,在WID中构建一个模块就相当于构建一个项目。另外,由于模块是一个独立部署的单元,这给应用的部署带来很大的灵活性。比如,只要保持模块接口不变,我们很容易通过重新部署新的模块而替换原有的业务逻辑,而不影响应用的其它部分。

由于一个模块中往往会包含多个服务组件,那我们如何来构建这些服务组件之间的相互调用关系呢?在WID工具中,我们只要简单地通过接口与引用之间的连线,就可以指定它们之间的调用关系而不需要写一行代码。另外,我们可以在这些连线上面设定需要的QoS要求,比如事务,安全等。

1.2.3 导入(Import)和导出(Export)

用户实际的应用经常是比较复杂的,因此实际的应用通常需要多个模块才能满足要求,而且这些模块之间又往往存在相互调用的关系。

另外模块中服务组件除了调用别的服务组件之外,也需要调用已有的一些应用,或者是让一些已有的应用来调用模块的服务,而这些应用可能不是基于SCA架构的。为了解决上述问题,在模块中我们引入了两个特殊的"端点",一个是导入(Import),它的作用是使得模块中的服务组件可以调用模块外部的服务。另一个是导出(Export),它的作用是使得模块外部的应用可以调用模块中的服务组件。

由于涉及到模块内外的调用,因此需要指定专门的绑定信息。这些绑定信息包括了目标服务或源服务的调用方式,位置信息,调用的方法等。目前,在WebSphere Process Server V6.0中,导入端点提供了四种绑定方式,包括:JMS绑定,Web Service绑定,SCA绑定和无状态会话BEAN的绑定。导出端点提供了三种绑定方式,包括:JMS绑定,Web Service绑定和SCA绑定。对于SCA模块之间的调用,我们可以非常方便的把绑定方式设置为SCA绑定,但是对于非SCA模块与SCA模块之间的调用我们只能选择其它绑定方式。

1.2.4 共享库(Library)

当我们在构建了多个模块的时候,如果有一些资源可以在不同模块之间共享,那么我们可以选择创建一份可以在不同模块之间进行共享的资源,而不是在不同模块中重复创建。共享库就是存放这些共享资源的地方。共享库可以通过与模块类似的方式在WID中创建,但是共享库包含的内容只有:数据定义,接口定义,数据映射和关系。与模块最大的区别使共享库不包含服务组件,因此也就不包含业务逻辑。从包含的功能来看,我们可以把共享库看作是模块的一个子集。当一个模块需要用到共享库中的资源的时候,我们只需要使模块依赖于共享库即可。从部署的角度,一个共享库会对应一个JAR包。在部署的时候,模块所对应的J2EE企业应用会会自动包含所依赖的共享库JAR包。这里特别要注意的是,这里的共享库概念与WebSphere应用服务器中的共享库不是一个概念,它们之间没有任何联系,因此不要混淆。

1.2.5 Standalone Reference

模块中的服务组件是不能直接被外部Java代码使用的,为了外部的Java代码,比如JSP/Servlet使用模块中的服务组件,WID工具在模块中提供了一个特殊的端点,叫做Standalone Reference。这个端点只有引用(Reference),而没有接口(Interface)。只要把这个端点的引用连接到需要调用的服务组件的接口,外部的Java代码通过这个引用的名称来调用相应的服务组件了。具体如何调用请参考后面例子的实际代码。

至此,与服务模块相关的主要概念已大概介绍完了,它们之间的关系如图 3 所示:


图 3:服务模块总览图
图 3:服务模块总览图






1.3 同步调用和异步调用

我们知道,常见的方法调用都是同步调用,这种调用方式是一种阻塞式的调用方式,即客户端(主调用方)代码一直阻塞等待直到被服务端(被调用方)返回为止。这种调用方式相对比较直观,也是大部分编程语言直接支持的一种调用方式。但是,如果我们面对是基于粗粒度的服务组件,面对的是一些需要比较长时间才能有响应的应用场景,那么我们就需要一种非阻塞式调用方式,即异步调用方式。

SCA编程模式提供了三种方式的异步调用,它们分别是:

1. 单向调用方式。

2. 延迟响应方式。

3. 请求回调方式。

单向调用

单向调用方式是最为简单的异步调用方式,在这种调用方式中,客户端发出请求之后就不再关心服务端的情况,包括是否执行成功,返回值是什么等等。我们可以用下面的图 4示来描述这种单向调用方式:


图 4: 单向调用
图 4: 单向调用

单向调用方式是一种不管调用结果的方式,但是在很多情况下我们是需要知道调用结果的。我们需要知道调用是否成功,需要知道调用的结果,就算调用失败我们也希望知道错误代码等信息。在这种情况下,延迟响应和请求回调就是两种能够让我们知道调用结果的方式。

延迟响应方式

延迟响应方式是指客户端在发出调用请求之后继续执行,但是经过一段时间之后,客户端再调用相应的方法去检索返回结果,并通过参数指定如何根据调用的结果而执行进一步动作。由于是异步调用方式,因此,在第一次发出调用请求的时候,服务端需要返回一个称为票据(Ticket)的对象。这个对象会作为第二次发出检索结果请求时的一个参数。显然,这个Ticket对象的作用与WEB编程的SessionID非常类似。我们可以用图 5 来表示延迟相应调用方式:


图 5:延迟响应调用方式
图 5:延迟响应调用方式

请求回调

与延迟响应方式类似,请求回调方式也能得到服务端的响应,但是不同的是这个响应是由服务端通过回调方式来触发的,而不像延迟响应方式由客户端来主动检索的。请求回调方式的原理与许多编程语言中的回调机制类似,不同的是这里实现的层次比较高一点。我们可以用图6来表示请求调用方式:


图 6:请求回调方式
图 6:请求回调方式






1.4 SCA客户端的两种调用方式

从接口的角度,SCA的客户端编程模型有两种方式:

1. 静态调用方式

2. 动态调用方式

静态调用方式

静态调用方式是一种类型安全的方式,也是在一般Java编程中最为常见的方式。所谓类型安全指的就是在编译的时候就做类型的检查,而不是等到运行的时候发现类型错误问题。说明示例如下:



在SCA客户端编程中,静态方式就是直接拿到实际实现的接口类型,也即直接拿到Java接口。

动态调用方式

与静态调用方式相对,动态调用方式是一种非安全的方式。它的优点是调用非常灵活,但同时带来的不利之处是部分问题在编译的时候是发现不了的,只有等到运行的时候才能发现。说明示例如下:



像上面例子所示,在动态调用方式中,客户端通过invoke方法的字符串参数的方式来指定具体要调用的方法名称。很显然,在这种方式下,如果方法名有误是不能在编译时发现的。

关于动态调用方式另外要注意的一点是,在这种调用方式下,所有参数传递都是通过DataObject的方式,即SDO的方式。哪怕实际参数只是一个字符串,也需要包装成一个DataObject的方式。

接口类型与调用方式

实际上客户端采用哪种调用方式是与接口类型有密切的关系。当提供的接口类型是WSDL类型的,那么客户端的调用方式只能是动态调用方式。由于WSDL是SCA模型中主要的接口方式,这样就导致动态调用方式在SCA编程模型中非常普遍。但是如果提供的接口类型时Java类型的,那么客户端的调用方式可以是动态调用方式,也可以是静态调用方式。







1.5 SCA的第一个例子――HelloWorld

与学习一种语言一样,在初步了解一些基本概念之后,您是不是迫不及待的想自己动手写点东西了?让我们一起来写一个"SCA版"的HelloWorld。我们需要的开发环境就是一个WebSphere Integration Developer V6.0(WID),与IBM的许多其它的开发工具类似,这也是一个基于Eclipse 3.0的开发工具。下面简单描述一下WID与IBM其它开发工具如Rational Application Developer(RAD),Rational Software Architecture(RSA),WebSphere Business Modeler等工具的区别。如果采用基于角色的开发方式,我们一般可以把集成项目的主要开发人员分为下面四大类:业务分析人员,集成开发人员,软件架构师,J2EE/JAVA应用开发人员。他们的主要职责、技术要求和推荐使用的工具可以参见下表:



由上表可知,WID是一个主要针对集成开发人员的工具。除了专门的集成功能之外,WID工具也包含了RAD中的大部分功能。为了便于集成应用的测试,这个开发工具集成了一个测试环境,即WebSphere Process Server V6.0的运行环境。

这个例子的主要目的是帮助大家进一步理解前面描述的那些SCA基本概念。在HelloWorld应用模块中,我们会构建一个用Java实现的SCA组件,其接口为HelloWorldInterface.wsdl,其实现代码为HelloWorldImpl.java。为了使SCA模块外部的JSP文件可以调用这个SCA组件,需要一个Standalone Reference。在模块外部,我们构建一个index.jsp文件通过Standalone Reference来调用HelloWorld服务组件,并在页面上把调用结果显式出来。整个HelloWorld应用的基本图示如下:


图 7: HelloWorld 应用
图 7: HelloWorld 应用

1.5.1 构建的基本步骤

下面给出创建HelloWorld例子的基本步骤:

1. 创建模块。打开WID,切换到Business Integration透视图,新建一个模块,名称为HelloWorld。

2. 创建接口。通过点击HelloWorld模块左边的"+"号展开,选择"Interface",然后通过右键创建一个接口,名称为HelloWorldInterface。图示如下:



HelloWorld接口包含一个sengMessage操作,输入为一个名为message的字符串,输出一个名为status的字符串。可以通过点击接口编辑器上方的按钮来添加一个操作。通过分别来添加输入和输出参数。图示如下:



3. 创建服务组件。双击打开HelloWorld模块的图形化编辑器,然后在控制面板上把Java组件图标 拖拉到编辑器中即生成一个Java服务组件,并把名称改为HelloWorld。如下图所示:



通过点击 按钮为HelloWorld组件选择一个接口,即我们前面定义的HelloWorldInterface。

通过双击上图中的HelloWorld组件,WID会自动生成HelloWorld组件实现类的基本框架HelloWorldImpl.java。如下图所示:



上图中高亮处显示的代码行就是我们可以给sendMessage方法添加业务代码的地方。比如,我们可以输入:return message + ". It's our first SCA example!";

4. 创建standalone reference。在工具栏中把 图标拖拉到编辑器中即生成一个standalone reference。如下图所示:



然后把Standalone Reference端点与HelloWorld组件连接起来。工具自动会为Standalone Reference创建一个匹配HelloWorld组件接口的引用。这里要注意的是,向导在自动创建Standalone Reference的引用时会弹出一个窗口询问需要创建一个Java接口类型的引用还是WSDL接口类型的引用。不同类型的接口会使得我们的客户端代码(在本例中是一个名为index.jsp的JSP文件)需要采用不同的调用方式。下面会分析两种不同类型的实现。

5. 生成JSP代码。如果我们在前面的引用接口类型中选择的是WSDL接口。那么Standalone Reference的属性如下图所示:



我们可以看到,引用的名称为HelloWorldInterfacePartner,接口为名称为HelloWorldInterface这个WSDL类型的接口。

如果我们在前面的引用接口类型中选择的是Java接口。那么Standalone Reference的属性如下图所示:



我们可以看到,引用的名称为HelloWorldInterfacePartner,接口为名称为world.hello.hello.world.interface_.HelloWorldInterface这个Java类型的接口。具体JSP代码参考下面的客户端代码分析部分。

6. 检查生成的项目。如果把WID切换到J2EE透视图的导航视图中,我们可以看到与HelloWorld模块对应的J2EE项目。J2EE企业项目为HelloWorldApp,其包含EJB项目HelloWorldEJB,Web项目HelloWorldWeb,J2EE客户端项目HelloWorldEJBClient。另外一个是名为HelloWorld的Java项目,这个项目的内容最终会以一个JAR文件的形式被HelloWorldApp应用使用。上一步中所提到的JSP文件需要在HelloWorldWeb项目中生成。具体如下图所示:



1.5.2 JSP客户端代码片断分析

那么如何在JSP页面中来调用我们的HelloWorld服务组件呢?按照前面的介绍,我们需要通过Standalone Reference来调用。那么我们如何才能得到这个Standalone Reference的引用呢?这里涉及到SCA编程模式中很重要的一个概念,那就是ServiceManager。ServiceManager是一个SCA环境的核心类,全名为com.ibm.websphere.sca.ServiceManager。这个类的作用主要就是能够让客户端去定位一个服务提供方。一般调用的方式是通过ServiceManager的locateService(String serviceRefName)方法。拿到服务之后,客户端就可以调用服务中所提供的方法了。(熟悉J2EE编程的人员可以联系对比JNDI的Lookup方法。)下面分别根据Standalone Reference引用的接口类型来分析主要JSP代码片断。

当接口类型是WSDL接口的情况

1.首先需要在JSP中导入相关的类,主要如下:


												
														<%@ page import="com.ibm.websphere.sca.ServiceManager" %>
<%@ page import="com.ibm.websphere.sca.Service" %>
<%@ page import="commonj.sdo.DataObject" %>

												
										

2.生成ServiceManager对象,并拿到相应的服务。


												
														ServiceManager serviceManager = new ServiceManager();
Service service = (Service) serviceManager.locateService("HelloWorldInterfacePartner");

												
										

这里locateService()方法中的参数是standalone reference的实际名称。从某种程度上我们可以把外部的JSP/Servlet的Java代码看成是Standalone reference的实现,这样来理解服务组件之间的相互调用。

3.调用服务的方法。


												
														String msg = request.getParameter("message");
DataObject resp = (DataObject) service.invoke("sendMessage",msg);

												
										

由于我们这里使用的是WSDL接口类型,因此返回结果是以DataObject的形式存在。

4. 显式得到的结果。


												
														<%=resp.getString("status")%>

												
										

通过调用DataObject的getString方法,我们拿到实际的返回结果,名为status的字符串。

当接口类型是Java接口的情况

1.首先需要在JSP中导入相关的类,主要如下:


												
														<%@ page import="com.ibm.websphere.sca.ServiceManager" %>
<%@ page import="com.ibm.websphere.sca.Service" %>
<%@ page import="world.hello.hello.world.interface_.HelloWorldInterface" %>

												
										

2.生成ServiceManager对象,并拿到相应的服务。


												
														ServiceManager serviceManager = new ServiceManager();
HelloWorldInterface service = 
(HelloWorldInterface) serviceManager.locateService("HelloWorldInterfacePartner");

												
										

由于Standalone Reference的接口变成了Java接口,因此这里返回的服务可以直接造型成HelloWorldInterface类型。

3.调用服务的方法。


												
														String msg = request.getParameter("message");
String resp = service.sendMessage(msg);

												
										

由于我们这里使用的是Java接口类型,因此调用的方式就是正常的Java接口调用。

4. 显式得到的结果。


												
														<%=resp%>

												
										

由于静态调用方式得到的就是实际定义的类型,因此这里字符串的显式比较简单。

具体实际项目的代码请参考本文附的项目交换文件包。






1.6 结束语

本文介绍了SCA的主要目的和一些基本的概念,并展示了一个最为简单的服务组件例子。从上面的讨论我们可以看到,SCA不但解决了统一调用的问题,而且提供了一个服务组件架构。这个服务组件架构将在构建面向服务的架构中起到举足轻重的作用,并在IBM的许多产品中会有所体现。

后记,在这篇文章完成之后,传来了一个关于SCA的好消息。SCA得到了业界几个主要软件厂商的支持。IBM、Oracle、BEA、SAP、Siebel、Sybase、IONA等厂商联合发布了SCA规范的0.9版本。具体规范可参见IBM DW的网址:http://www.ibm.com/developerworks/library/specification/ws-sca/

posted @ 2006-06-01 16:52 wsdfsdf 阅读(284) | 评论 (0)编辑 收藏

5月31日-----最近五天的任务安排

周三到周五任务:每人都规划并设计出整个网站平台界面
大家分开去发挥自己的想象,都去规划整个网站平台界面,要深入到每个页面的功能,样式,布局等。没有灵感的时候就再看看SOA的知识。

周六和周日的任务:定出网站平台,并讨论之后的文档编写计划
把前几天的想法汇集一下,讨论出结果,并制定文档编写计划。


好久没说了:MAT,加油!

posted @ 2006-05-31 13:35 wsdfsdf 阅读(150) | 评论 (0)编辑 收藏

5月30日-----关于项目过程的新理解(工具的用处)

前几天总结了一下,不过通过最近的学习又有新的想法,发现之前的存在问题。现把最新理解的过程列出来:
1、用WebSphere Business Modeler进行业务流程建模。
2、将模型导入 Rational Software Architect 进行UML建模,导出BPEL。(这里还没理解到位,尤其没看懂UML这里,希望大家共同讨论)
3、将结果导入WebSphere Integration Developer 进行SCA组件开发和建模。(SCA这步具体做法见今天发的另一贴)
4、将模块放入WebSphere Process Server进行测试。
5、在咱们开发的Web Application上调用SCA。



以上只是我的个人理解,这里说的很粗,而且还会有问题。希望以后大家能够再把它完善。

posted @ 2006-05-30 17:13 wsdfsdf 阅读(103) | 评论 (0)编辑 收藏

5月30日-----构建SCA模块和步骤

  1. 创建 SCA 模块。
  2. 创建业务对象。
  3. 定义服务接口。
  4. 生成组件并提供实现。
  5. 对 SCA 组件进行单元测试。
  6. 提供独立引用。
  7. 使用简单的 JSP 客户机测试服务。

posted @ 2006-05-30 16:59 wsdfsdf 阅读(73) | 评论 (0)编辑 收藏

5月29日-----一个CRM的管理模块,但不是大赛推荐的那个CRM

1、客户管理模块
2、联系人管理模块
3、线索管理模块
4、商机管理模块
5、营销活动管理
6、日程管理
7、活动管理
8、拜访管理
9、问题跟踪
10、文档管理
11、邮件管理
12、项目管理
13、仪表盘
14、RSS新闻


这些模块只是参考,为了了解CRM到底是有什么。

posted @ 2006-05-29 15:23 wsdfsdf 阅读(114) | 评论 (0)编辑 收藏

5月29日-----用开源软件还是IBM产品?

问题又出现了,到底是用开源软件还是IBM产品。这决定着下一步的方向问题。
如果用IBM产品:
优点:整个业务整合过程都有IBM产品的支持,省去了大部分的代码,直接操作工具就可以实现很多功能,真正开发期会把多数精力花在学习工具的使用中。而目前的初赛阶段文档的编写又和工具关系不大,我们的精力可以多花了创新和建模中。
缺点:大部分团队开发出的界面都差不多(也许说的不对,暂时的理解而已)。没有新意,学到的东西只有SOA,以及工具的使用,深入不到具体实现的代码细节。

如果用开源软件:
优点:自己的发挥空间很是宽裕,可以在界面和功能上有很多创新,可以学到很多底层的实现细节。开发出来的东西,与众不同。
缺点:整个的业务整合过程不会有很强的支持,大部分的代码需要手动编写。尤其是企业服务总线的消息传递,还有前台的Ajax。初赛期间要花一部分精力在系统平台的设计。总而言之,难度加大。

所以,今晚我们要集体讨论一下,到底如何发展。

posted @ 2006-05-29 15:07 wsdfsdf 阅读(259) | 评论 (2)编辑 收藏

仅列出标题
共19页: 1 2 3 4 5 6 7 8 9 Last