CN110310034A - 一种应用于SaaS的服务编排、业务流程处理方法和装置 - Google Patents

Abstract

本发明公开了一种应用于SaaS的服务编排、业务流程处理方法和装置，涉及计算机技术领域。该方法的一具体实施方式包括：接收服务调用请求，解析服务调用请求，获取待调用的目标服务标识；若在预定服务列表中查询不存在与目标服务标识相应的目标服务，则获取与目标服务标识相应的微服务和/或组合服务；对所获取的微服务和/或组合服务进行编排，以生成目标服务。该实施方式可以基于已有的微服务和/或组合服务进行服务编排，得到所需调用的目标服务，为服务拓展以及后续的客户化业务流程设计提供了服务化支撑；且对于标准服务和客户化服务，都可以通过服务界面进行集成，解决了现有技术集成规范难以统一的问题，具有良好的实施效果。

Description

一种应用于SaaS的服务编排、业务流程处理方法和装置

技术领域

本发明涉及计算机技术领域，尤其涉及一种应用于SaaS的服务编排、业务流程处理方法和装置。

背景技术

目前云计算技术和商业服务高速发展，越来越多的企业开始采购SaaS(Software-as-a-Service，软件即服务)企业服务。基于业务需求的不同，不同企业对互联网信息技术提出业务可定制化的需求，即通过技术手段对页面、流程、数据等按照不同企业的业务需求进行扩展和定制。

现有SaaS服务提供商的做法是针对标准服务做参数化处理，然后针对具体业务模式的用户配置参数值。但针对复杂业务，如果不能通过参数解决就需要实施客户化开发，然后部署到独立的业务系统中。

在实现本发明的过程中，发明人发现现有技术至少存在如下问题：

1、需开发标准服务的参数管理模块和预置参数处理逻辑，开发成本较高，难以通过参数满足用户的多样需求；

2、标准以外的服务只能通过定制开发，开发后需要和标准化服务进行集成，但由于两者开发人员习惯不同或者系统异构，存在集成规范难以统一的问题；

3、用户的业务流程变化频繁(例如，增加人脸识别环节)，标准SaaS服务难以通过参数进行流程编排；但是通过服务商的定制化又难以在短期内完成，导致不能快速响应用户的业务需求；

4、目前通常通过构建一个分布式服务总线获取服务，并且需要业务系统严格按照标准服务接口规范开发服务接口，然后注册到分布式服务总线中，该方式存在两个缺点：

①性能问题：在高并发请求处理大型文档时内存使用量过高，导致总线阻塞，这可能会造成分布式服务总线定位服务无法执行；

②扩展门槛高：用户化团队需要按照标准服务接口规范开发定制化的服务，并且该规范不是一种被公开的标准规范，导致服务扩展性受限。

发明内容

有鉴于此，本发明实施例提供一种应用于SaaS的服务编排、业务流程处理方法和装置，至少能够解决现有技术中SaaS服务参数化成本过高，无法快速实施客户化定制的问题。

为实现上述目的，根据本发明实施例的一个方面，提供了一种应用于SaaS的服务编排方法，包括：

接收服务调用请求，解析所述服务调用请求，获取待调用的目标服务标识；

若在预定服务列表中查询不存在与所述目标服务标识相应的目标服务，则获取与所述目标服务标识相应的微服务和/或组合服务；

对所获取的微服务和/或组合服务进行编排，以生成所述目标服务。

可选的，在生成所述调用服务之后，还包括：接收对各目标服务中订阅主题消息的输入；按照所输入订阅主题消息之间的排列顺序，对与各目标服务相应的流程环节进行排列组合，得到业务流程。

可选的，在所述得到业务流程之后，还包括：

接收对所述业务流程的业务流程标识和用户信息的输入，建立所述用户信息、所述业务流程标识和所述业务流程之间的对应关系；以及

建立与所述用户信息和所述业务流程标识相应的服务编排定义模型，存储所述对应关系和所述业务流程至所述服务编排定义模型中。

为实现上述目的，根据本发明实施例的一个方面，提供了一种应用于SaaS的业务流程处理方法，包括：

接收业务服务请求，获取所述业务服务请求中的用户信息和业务流程标识；

确定与所述用户信息和所述业务流程标识相应的业务流程和订阅主题消息，触发所述业务流程中与所述订阅主题消息相应的流程环节；

在所述业务流程中的所有流程环节执行完毕后，传输执行结果至与所述业务流程标识相应的业务流程信息中。

可选的，所述触发所述业务流程中与所述订阅主题消息相应的流程环节，包括：

根据各订阅主题消息的排列顺序，确定排序第一的第一订阅主题消息，发送主题为所述第一订阅主题消息的事件至队列中心；

通过所述第一订阅主题消息，第一服务监听到所述队列中心中的所述事件并解析，以获取所述事件中的业务流程标识；

若所获取的业务流程标识为所述业务流程的业务流程标识，所述第一服务获取与所述事件相应的任务并执行；

在第一流程环节执行完毕后，确定排序第二的第二订阅主题消息，触发与所述第二订阅主题消息相应的第二服务，重复上述事件传输、事件解析步骤，直至所述业务流程中的所有流程环节执行完毕。

可选的，所述发送主题为所述第一订阅主题消息的事件至队列中心，包括：

服务调度中心建立与所述事件相应的任务，并发送所述事件至所述队列中心；

所述第一服务获取与所述事件相应的任务并执行，包括：

所述第一服务通过所述用户信息、所述业务流程标识和所述订阅主题消息，从所述调度中心中获取所述任务并执行。

为实现上述目的，根据本发明实施例的另一方面，提供了一种应用于SaaS的服务编排装置，包括：

请求接收模块，用于接收服务调用请求，解析所述服务调用请求，获取待调用的目标服务标识；

服务查询模块，用于若在预定服务列表中查询不存在与所述目标服务标识相应的目标服务，则获取与所述目标服务标识相应的微服务和/或组合服务；

服务编排模块，用于对所获取的微服务和/或组合服务进行编排，以生成所述目标服务。

可选的，还包括流程生成模块，用于：接收对各目标服务中订阅主题消息的输入；按照所输入订阅主题消息之间的排列顺序，对与各目标服务相应的流程环节进行排列组合，得到业务流程。

可选的，还包括模型建立模块，用于：

接收对所述业务流程的业务流程标识和用户信息的输入，建立所述用户信息、所述业务流程标识和所述业务流程之间的对应关系；以及

建立与所述用户信息和所述业务流程标识相应的服务编排定义模型，存储所述对应关系和所述业务流程至所述服务编排定义模型中。

为实现上述目的，根据本发明实施例的另一方面，提供了一种应用于SaaS的服务编排装置，包括：

信息获取模块，用于接收业务服务请求，获取所述业务服务请求中的用户信息和业务流程标识；

流程触发模块，用于确定与所述用户信息和所述业务流程标识相应的业务流程和订阅主题消息，触发所述业务流程中与所述订阅主题消息相应的流程环节；

结果传输模块，用于在所述业务流程中的所有流程环节执行完毕后，传输执行结果至与所述业务流程标识相应的业务流程信息中。

可选的，所述流程触发模块，用于：

根据各订阅主题消息的排列顺序，确定排序第一的第一订阅主题消息，发送主题为所述第一订阅主题消息的事件至队列中心；

通过所述第一订阅主题消息，第一服务监听到所述队列中心中的所述事件并解析，以获取所述事件中的业务流程标识；

若所获取的业务流程标识为所述业务流程的业务流程标识，所述第一服务获取与所述事件相应的任务并执行；

在第一流程环节执行完毕后，确定排序第二的第二订阅主题消息，触发与所述第二订阅主题消息相应的第二服务，重复上述事件传输、事件解析步骤，直至所述业务流程中的所有流程环节执行完毕。

可选的，所述流程触发模块，用于：

服务调度中心建立与所述事件相应的任务，并发送所述事件至所述队列中心；以及

所述第一服务通过所述用户信息、所述业务流程标识和所述订阅主题消息，从所述调度中心中获取所述任务并执行。

为实现上述目的，根据本发明实施例的再一方面，提供了一种电子设备。

本发明实施例的电子设备包括：一个或多个处理器；存储装置，用于存储一个或多个程序，当所述一个或多个程序被所述一个或多个处理器执行，使得所述一个或多个处理器实现上述任一所述的应用于SaaS的服务编排、业务流程处理方法。

为实现上述目的，根据本发明实施例的再一方面，提供了一种计算机可读介质，其上存储有计算机程序，所述程序被处理器执行时实现上述任一所述的应用于SaaS的服务编排、业务流程处理方法。

根据本发明所述提供的方案，上述发明中的一个实施例具有如下优点或有益效果：可以基于已有的微服务和/或组合服务进行服务编排，得到所需调用的目标服务，为服务拓展以及后续的客户化业务流程设计提供了服务化支撑；且对于标准服务和客户化服务，都可以通过服务界面进行集成，解决了现有技术集成规范难以统一的问题，降低了开发成本，具有良好的实施效果。

上述的非惯用的可选方式所具有的进一步效果将在下文中结合具体实施方式加以说明。

附图说明

附图用于更好地理解本发明，不构成对本发明的不当限定。其中：

图1是根据本发明实施例的一种应用于SaaS的服务编排方法的主要流程示意图；

图2是根据本发明实施例的一种可选的应用于SaaS的服务编排方法的流程示意图；

图3是根据本发明实施例的一种应用于SaaS的业务流程处理方法的流程示意图；

图4是根据本发明实施例的一种可选的应用于SaaS的业务流程处理方法的流程示意图；

图5是根据本发明实施例的一种应用于SaaS服务的具体实施过程示意图；

图6是根据本发明实施例的一种应用于SaaS的服务编排装置的主要模块示意图；

图7是根据本发明实施例的一种应用于SaaS的业务流程处理装置的主要模块示意图；

图8是本发明实施例可以应用于其中的示例性系统架构图；

图9是适于用来实现本发明实施例的移动设备或服务器的计算机系统的结构示意图。

具体实施方式

以下结合附图对本发明的示范性实施例做出说明，其中包括本发明实施例的各种细节以助于理解，应当将它们认为仅仅是示范性的。因此，本领域普通技术人员应当认识到，可以对这里描述的实施例做出各种改变和修改，而不会背离本发明的范围和精神。同样，为了清楚和简明，以下的描述中省略了对公知功能和结构的描述。

需要说明的是，本发明实施例可适应于需要提供服务的领域，例如金融、销售、人事、企业管理、餐饮、交通等，本发明实施例以信息校验为例进行说明。

对于本发明涉及的词语，作解释如下：

客户化开发：把已经做的比较成熟的软件系统按照客户的需求，做相应的改动。

事件：是可以被JavaScript侦测到的行为。网页中的每个元素都可以产生某些可以触发JavaScript函数的事件。

微服务：一个新兴的软件架构，就是把一个大型的单个应用程序和服务拆分为数十个的支持微服务。一个微服务的策略可以让工作变得更为简便，它可扩展单个组件而不是整个的应用程序堆栈，从而满足服务等级协议。

服务编排：通过一种可视化的服务编排方式，将原子服务进行组合，形成通用业务场景的组合服务。

分布式服务总线：实现微服务的注册、发现机制。微服务发布后，就将自己的服务名称。地址等信息注册至分布式服务总线中(服务注册)，通过服务注册信息可以实现服务寻址。

参见图1，示出的是本发明实施例提供的一种应用于SaaS的服务编排方法的主要流程图，包括如下步骤：

S101：接收服务调用请求，解析所述服务调用请求，获取待调用的目标服务标识；

S102：若在预定服务列表中查询不存在与所述目标服务标识相应的目标服务，则获取与所述目标服务标识相应的微服务和/或组合服务；

S103：对所获取的微服务和/或组合服务进行编排，以生成所述目标服务。

上述实施方式中，对于步骤S101，SaaS服务提供用户(计算机专业叫做租户)可操作的服务界面，用户可以应用该服务界面创建属于自己的业务流程。

在业务流程生成过程中，可以设定有可视化的服务编排管理界面、流程设计界面等，本发明主要针对于这两者进行说明。

在服务编排管理界面可以显示有可编排的服务列表，便于企业开发人员可以在该列表上选择所需要的服务，或者计算机分析业务需求并进行服务选择。

所显示的服务列表，可以是各个服务的名称列表或是服务图元列表、排列等；针对这些服务还可以设定有相应的操作功能，例如拖拽、点击、属性设置等。例如，开发人员拖拽服务图元至与业务流程相应的调用位置；然后点击服务图元，实现向服务编排管理界面发出服务调用请求。

例如，用户X创建了一套信息校验流程Y，该流程Y先进行用户名校验，后进行人脸识别校验。

因此，对于所接收的服务调用请求，需要先确定所需调用的目标服务，例如，人脸识别服务，后续都是通过该人脸识别服务的标识进行查找的。

对于步骤S102和S103，对于服务编排管理界面中的服务，可以预先构建服务资源库，库中包含有微服务或者组合服务、或者两者都有；其中，组合服务为预先对多个微服务进行服务编排后所得到的服务。

服务列表中的服务数量可以小于等于服务资源库中的服务数量；例如，服务资源库中的服务数量较少，则可以在服务列表中展示所有服务；若服务资源库中的服务数量较多，则可以在服务列表中展示部分服务(例如，常用的服务，也可理解为标准服务)，本发明优选设定两者服务数量相等。

进一步的，可以设置服务搜索功能，便于开发人员能够基于服务信息，快速定位所需服务。

根据目标服务的标识，在服务列表中进行查询：

1)若服务列表中存在被调用的目标服务，例如用户名校验服务，可直接从服务资源库中提取该服务，并存储至与该服务调用请求相应的调用位置，以便实现业务流程设计在当前环节所需使用的服务调用。通常标准服务都存储于数据库中，都可以在服务列表中查询得到。

2)但若服务列表中不存在该目标服务，例如人脸识别服务，则表示该服务在现有服务资源库中不存在，需要新生成。这些服务，通常是用户自己所需，但是其他用户可能不需要的，即客户化服务：

①用户可以根据自身需要，定制客户化服务，并将该服务添加至服务资源库中，实现服务资源库中的服务更新。

因此，可以在服务资源库设置添加新服务的功能，或者服务更新、服务修改、服务删除、服务查找功能，以为开发人员提供灵活的管理服务资源库、拓展服务的功能，便于后续服务的直接调用。还可以设置服务列表更新功能，服务列表中的服务数量随着服务资源库中的服务数量变动。

②为满足业务流程设计过程中对目标服务的需求，可以基于根据该目标服务的名称、地址等标识信息，获取可编排为该目标服务的微服务和/或组合服务，进而对该微服务和/或组合服务进行服务编排，得到所需调用的目标服务。

因此，可预先设置可视化的图元编排组件，通过可视化的拖拽或配置等方式，对微服务和/或组合服务进行可视化的服务编排。

上述实施例所提供的方法，当有业务设计需求时，可以基于已有的微服务和/或组合服务进行服务编排，得到所需调用的目标服务，实现了服务拓展，为后续客户化业务流程设计提供了服务化支撑。且对于标准服务和客户化服务，都可以通过服务界面进行集成，解决了现有技术集成规范难以统一的问题，降低了服务开发成本，具有良好的实施效果。

参见图2，示出的是本发明实施例提供的一种可选的应用于SaaS的服务编排方法的主要流程图，包括如下步骤：

S201：接收服务调用请求，解析所述服务调用请求，获取待调用的目标服务标识；

S202：若在预定服务列表中查询不存在与所述目标服务标识相应的目标服务，则获取与所述目标服务标识相应的微服务和/或组合服务；

S203：对所获取的微服务和/或组合服务进行编排，以生成所述目标服务；

S204：接收对各目标服务中订阅主题消息的输入；

S205：按照所输入订阅主题消息之间的排列顺序，对与各目标服务相应的流程环节进行排列组合，得到业务流程。

上述实施方式中，对于步骤S201～S203可分别参见图1所示步骤S101～S103的描述，在此不再赘述。

服务编排为应用的开发和运维提供了一种新的方式，它覆盖了分布式应用的所有动态生命周期，当新的代码或者新的容器化服务改变时，应用可以在短时间内部署到生产环境中，他们独特的模块化结构决定了其可以被不同的人员使用，包括开发者、运维人员以及其合作伙伴。

上述实施方式中，对于步骤S204，主题是消息发布或客户端订阅(Subscription)通知的特定事件类型。它作为发送消息和订阅通知的信道，为发布者和订阅者提供一个可以相互交流的通道。

订阅者，即从主题接收消息的对象，若要接收发布至主题的消息，就必须向该主题添加订阅者，消息订阅者只有和主题建立了订阅关系才可以接收发布者往该主题发布的消息。

订阅主题消息，为服务从消息队列中心中查看事件必不可少的依据，且与目标服务相对应。例如，用户名校验服务通过订阅主题消息B，监听消息队列中心中的事件Event1。

对于步骤S205，服务和流程环节两者之间存在对应关系，例如，用户名校验服务对应于用户名校验环节、人脸识别服务对应于人脸识别环节。

业务流程中由流程环节组成，因此在业务流程设计过程中，在确定目标服务后，还需要确定流程环节。

业务流程中的流程环节执行具有先后顺序，可以根据开发人员在服务编排管理界面拖拽服务图标进行确定，也可以根据其所输入的订阅主题消息顺序进行确定。例如，对于信息校验Y中的用户名校验和人脸识别，订阅主题消息分别对应于B和C，则表示先进行用户名校验，后进行人脸识别。

通过业务流程设计生成所需的业务流程后，可向相应的业务系统发布该业务流程，此时发布的业务流程本质上为模型层面的业务流程，也可以称为是业务流程模型。

之后，当存在运行该业务流程的需要时，开发人员可以配合业务系统的实际应用场景，对所发布的业务流程模型进行相应配置，以得到可运行的实例化业务流程。

需要说明的是，对于订阅主题消息A，可以是开发人员在服务编排管理界面设定表示结束的标识。对于订阅主题消息的设定，本发明在此不做限制。

在生成业务流程后，进一步的，可以建立服务编排定义模型，该模型可以是数据库，也可以是文件夹等可以存储信息的容器。例如，SaaS服务界面整合用户信息X、信息校验流程Y、订阅主题消息B和C，并将整合后的信息存储至服务编排定义模型Z中，完成对设计界面的保存操作，业务人员可以在发布的流程模型中开展自己的业务流程。

需要说明的是，这里的服务编排定义模型仅仅是一个用树形结构组织的数据集合，具有业务含义和稳定的数据结构，可视为是服务调用的参数传递。所包含的信息只能被读取，不能被修改，即使要修改，也只能在服务编排管理界面中修改。

另外，一旦业务流程被调用运行，都会生成业务流程实例，因此服务编排定义模型与流程实例的数量关系可以为1：N。

更进一步的，对于不同用户，可以基于用户信息进行服务隔离、业务流程隔离以及模型隔离。例如，设置针对于用户1的服务编排定义模型1，该服务编排定义模型1中又可以包含多个小的服务编排定义模型，例如，针对于业务流程11的模型11、针对于业务流程12的模型12。

通过云平台的分布式服务总线获取服务的方式，对于所得服务、所得业务流程是不支持隔离的。本发明通过用户信息、业务流程标识以及所设置的服务编排定义模型，实现了用户信息的隔离，避免业务流程调用混淆的情况，且可面向多个租户提供服务，适用范围较广。

所生成的服务编排定义模型可以通过可扩展的XML文件存储，主要内容包括：服务环节信息、服务流转信息、超时回放信息、服务网关信息、消息队列主题信息、异常分支信息、用户信息、参数信息、扩展信息等。

上述实施例所提供的方法，提供了用户维护业务流程的功能，用户可以通过服务界面随时修改SaaS服务的业务流程，调整流程环节的执行顺序，达到低成本快速生成业务流程的目的。另外，针对不同的用户信息设置不同的服务编排定义模型，实现了用户信息的隔离；且无需针对各用户建立服务编排系统，只需通过本发明的服务编排机制，即可面向多用户提供服务。

参见图3，示出的是本发明实施例提供的一种应用于SaaS的业务流程处理方法的主要流程图，包括如下步骤：

S301：接收业务服务请求，获取所述业务服务请求中的用户信息和业务流程标识；

S302：确定与所述用户信息和所述业务流程标识相应的业务流程和订阅主题消息，触发所述业务流程中与所述订阅主题消息相应的流程环节；

S303：在所述业务流程中的所有流程环节执行完毕后，传输执行结果至与所述业务流程标识相应的业务流程信息中。

上述实施方式中，对于步骤S301，用户应用SaaS服务创建一个属于自己的业务流程，并在已经发布的流程模型中开展自己的业务流程。

例如，业务人员应用SaaS服务进行业务流程，SaaS服务的标准业务入口接收到业务服务请求，解析获得该请求中的用户信息和业务流程标识，例如用户信息X和信息校验标识Y。

其中，用户信息可以是身份证号、企业的纳税人识别号、在该SaaS服务中的注册号或者其他形式。

对于步骤S302，同一用户可以建立多个业务流程，不同用户可能建立的业务流程名称相同，例如信息校验流程。因此，可以根据用户信息和业务流程标识，确定企业的业务人员本次所请求服务的业务流程。

例如，标准业务入口将用户信息X和信息校验标识Y作为查询条件，通过服务编排查询模块，获取与该查询条件相应的服务编排定义模型Z，然后把该服务编排定义模型Z发送至服务调度中心；

服务调度中心接收服务编排定义模型Z，并解析服务编排信息(即用户信息X和信息校验标识Y)，确定该企业所创建的信息校验流程Y并启动。

业务流程可以基于标准业务入口接收到的服务请求触发，流程环节主要基于订阅主题消息触发。一个业务流程可以包括多个流程环节，这些流程环节的执行顺序可以依据订阅主题消息的顺序确定。

例如，在信息校验Y中，需要通过订阅主题B触发用户名校验环节、订阅主题C触发人脸识别环节，这两个订阅主题消息同样可以在服务编排定义模型Z中查找到。

每个流程环节在执行完毕后，都会传输执行结果至服务调度中心中的流程信息进行存储，例如用户名校验，对所输入的数据进行校验得到校验结果，并将结果存储至信息校验流程的信息中。对于流程环节的具体执行操作，具体参见后续图4描述，在此不再赘述。

对于步骤S303，在业务流程中的最后一个流程环节执行完毕之后，流程中心(整个这一套方案视为流程中心)会通知服务调度中心当前流程中的所有流程环节都已完成，之后结束流程。

用户可以通过查询服务申请界面，获取SaaS服务所返回的处理结果，完成业务流程。

这里的处理结果，可以是所有流程执行结果的并集，每当一个流程环节执行完毕，流程信息Y中都会增加相应的执行结果。

进一步的，服务调度中心会按照流程环节的执行顺序，对所返回的执行结果进行打包标记，例如，标记处理结果1为校验用户名的结果。

但需要说明的是，对于包含多个流程环节的业务流程，当一个流程环节执行完毕后，其处理结果通常不会直接返回给用户。但是当业务流程结束时，调度中心会向消息中心发送一个当前业务流程结束的消息，例如，流程处理服务监听到该信息，通过解析消息内容发现是信息校验流程Y结束了，就可以根据Y查询调度中心，得到整个信息校验流程Y的详细执行结果，具体地，用户信息X、所输入的数据、校验结果信息、采集的人脸信息等。

上述实施例所提供的方法，通过用户信息和业务流程标识确定业务流程，提高了确定业务流程的准确性；相比现有针对不同业务流程依赖不同服务传输事件的方式，本发明通过服务调度中心传输事件，提高了整个流程中心的运转能力，可面向所有业务流程的运转及监听。

参见图4，示出的是本发明实施例提供的一种可选的应用于SaaS的业务流程处理方法的主要流程图，包括如下步骤：

S401：接收业务服务请求，获取所述业务服务请求中的用户信息和业务流程标识；

S402：确定与所述用户信息和所述业务流程标识相应的业务流程和订阅主题消息；

S403：根据各订阅主题消息的排列顺序，确定排序第一的第一订阅主题消息，发送主题为所述第一订阅主题消息的事件至队列中心；

S404：通过所述第一订阅主题消息，第一服务监听到所述队列中心中的所述事件并解析，以获取所述事件中的业务流程标识；

S405：若所获取的业务流程标识为所述业务流程的业务流程标识，所述第一服务获取与所述事件相应的任务并执行；

S406：在第一流程环节执行完毕后，确定排序第二的第二订阅主题消息，触发与所述第二订阅主题消息相应的第二服务，重复上述事件传输、事件解析步骤，直至所述业务流程中的所有流程环节执行完毕；

S407：在所述业务流程中的所有流程环节执行完毕后，传输执行结果至与所述业务流程标识相应的业务流程信息中。

上述实施方式中，对于步骤S401、S402以及S407可分别参见图3所示步骤S301～S303的描述，在此不再赘述。

上述实施方式中，对于步骤S403～S406，业务流程中的流程环节数量可能较多，由于各个流程环节之间的数据有着处理关联，因此需要按序执行流程环节。

具体地，依据订阅主题消息判断；例如，先触发与订阅主题消息B相应的用户名校验环节。

在执行第一个流程环节--用户名校验过程中，即服务调度中心向消息队列中心发送事件Event。事件内容可以包括业务流程的详细信息，例如用户信息、流程标识、业务单据等。

进一步的，服务调度中心先生成与该用户信息、业务流程标识以及流程环节相应的任务，之后再发送相应事件至消息队列中心。

但一个流程环节可能被多个业务流程复用，一个业务流程也可能被多个用户调用，因此对于单一流程环节，服务调度中心所发送的事件数量可能较多(分发或复发)，例如，针对流程Y、流程Y’。

当流程环节收到执行指令后，需知道是哪个业务流程在调用它，因此本发明中需要对事件进行信息解析，且该解析步骤不可少。

例如，对于信息校验Y中的第一个用户名校验环节，用户名校验服务通过订阅主题B监到消息队列中的事件Event1，并通过解析事件Event1得到业务流程Y的信息(或流程实例的参数)，由此确定自身服务是被信息校验Y调用的。

在流程环节确定所调用业务流程之后，可以确定与该事件相应的任务为待处理任务；进一步的，可以根据用户信息、业务流程标识以及订阅主题消息，从服务调度中心中认领任务并执行。

由于服务调度中心可能针对于多个SaaS服务，因此对于事件的分发，服务调度中心可能会在多个SaaS服务中发送事件，也可以重复发送事件。为了防止任务被重复处理，可以增加排他机制，一旦任务被认领，即表示任务认领成功，以此提高整体流程的生命周期。

例如，用户名校验服务确定与事件Event1相应的任务为待处理任务，并在服务调度中心认领，一旦任务被认领，即表示认领成功。

第一个流程环节处理任务(该过程可能需要一定的时间)，当任务处理完成后会通知服务调度中心，同时提交相应的处理结果至服务调度中心，例如，对所输入的用户名进行校验，传输结果至服务调度中心流程Y的信息中。

综上所述，流程环节所执行的操作包括：监听事件以确定待处理任务、向服务调度中心发送认领任务请求、在任务处理完毕后向服务调度中心提交任务处理结果。

服务调度中心在接收到第一个流程环节返回的任务已完成信息之后，会确定第二个流程环节，并向队列中心发送与第二个订阅主题消息相应的事件。例如，对于信息校验Y中的人脸识别环节，服务调度中心向消息队列中心发送主题为C的事件Event2。

第二个流程环节仍通过相应的订阅主题消息，监听消息队列中心中的事件，例如，通过订阅主题消息C监听到事件Event2。后续操作步骤和上述第一个流程环节一致，在此不再赘述。

上述实施例所提供的方法，调度中心负责向消息队列中心发送事件，替代了需针对不同业务流程分别设置用于分发事件服务的方式，提高了整个流程分发事件的运转能力，减少了代码生成及测试的需求；通过订阅主题消息确定流程环节的执行顺序，也有利于业务流程的有效执行。

参见图5，示出了本发明实施例的一个具体应用于SaaS服务的实施过程示意图，主要包括两部分：服务编排管理中心和服务编排运行中心。

1、服务编排管理中心——主要用于编排服务、生成业务流程。主要包括服务编排管理界面、服务编排管理模块、服务编排定义模型；其中：

1)服务编排管理界面：根据所接收的服务调用请求，可视化展示可编排的服务列表；例如用户名校验；

2)服务编排管理模块：当不存在服务时，可以基于现有的微服务和/或组合服务，编排生成相应客户化服务，并更新服务资源库以及服务列表；例如人脸识别；以及

根据对各服务订阅主题消息的输入，相应调整服务顺序；确定与各服务相应的流程环节，生成业务流程。

3)服务编排定义模型：负责描述整个业务流程的服务编排信息。

对业务流程设定/生成业务流程标识，结合用户信息，存储至服务编排定义模型中，实现用户信息之间的隔离，降低业务流程误调的情况。

2、服务编排运行中心——主要用于业务流程的运行。主要包括客户服务编排查询、服务调度中心、消息队列中心、标准服务列表、客户定制服务列表。其中：

1)客户服务编排查询：通过标准业务入口解析获取的用户信息和业务流程标识，查询相应的服务编排定义模型；

2)服务调度中心：负责向消息队列中心发送事件；例如，发送主题为订阅主题消息B的事件至消息队列中心；

3)消息队列中心：负责消息的持久化和通知到指定的服务；例如，额度校验服务通过订阅主题消息B，监听消息队列中心中的事件Event1；

4)微服务平台(可理解为底层服务)：负责对标准服务和客户化服务的管理；

①标准服务列表，用于展示可直接调用的服务，包括SaaS服务提供商所提供的服务；

②客户化服务列表：通常为SaaS服务提供商提供不到的服务，需要用户自己定制或者依据已有服务进行编排的服务，也可以为用户在SaaS服务中历史生成的所有非标准服务。

上述模块集合在一起配合使用组成了本发明的技术核心，整体实施过程可以概括为：对于标准服务和客户化服务，通过服务编排管理中心编排后，再通过SaaS服务的服务编排运行中心执行。

参见图6，示出了本发明实施例提供的一种应用于SaaS的服务编排装置600的主要模块示意图，包括：

请求接收模块601，用于接收服务调用请求，解析所述服务调用请求，获取待调用的目标服务标识；

服务查询模块602，用于若在预定服务列表中查询不存在与所述目标服务标识相应的目标服务，则获取与所述目标服务标识相应的微服务和/或组合服务；

服务编排模块603，用于对所获取的微服务和/或组合服务进行编排，以生成所述目标服务。

本发明实施装置还包括流程生成模块604(图中未标出)，用于：

接收对各目标服务中订阅主题消息的输入；按照所输入订阅主题消息之间的排列顺序，对与各目标服务相应的流程环节进行排列组合，得到业务流程。

本发明实施装置还包括模型建立模块605(图中未标出)，用于：

接收对所述业务流程的业务流程标识和用户信息的输入，建立所述用户信息、所述业务流程标识和所述业务流程之间的对应关系；以及

建立与所述用户信息和所述业务流程标识相应的服务编排定义模型，存储所述对应关系和所述业务流程至所述服务编排定义模型中。

参见图7，示出了本发明实施例提供的一种应用于SaaS的业务流程处理装置700的主要模块示意图，包括：

信息获取模块701，用于接收业务服务请求，获取所述业务服务请求中的用户信息和业务流程标识；

流程触发模块702，用于确定与所述用户信息和所述业务流程标识相应的业务流程和订阅主题消息，触发所述业务流程中与所述订阅主题消息相应的流程环节；

结果传输模块703，用于在所述业务流程中的所有流程环节执行完毕后，传输执行结果至与所述业务流程标识相应的业务流程信息中。

本发明实施装置中，所述流程触发模块702，用于：

根据各订阅主题消息的排列顺序，确定排序第一的第一订阅主题消息，发送主题为所述第一订阅主题消息的事件至队列中心；

通过所述第一订阅主题消息，第一服务监听到所述队列中心中的所述事件并解析，以获取所述事件中的业务流程标识；

若所获取的业务流程标识为所述业务流程的业务流程标识，所述第一服务获取与所述事件相应的任务并执行；

在第一流程环节执行完毕后，确定排序第二的第二订阅主题消息，触发与所述第二订阅主题消息相应的第二服务，重复上述事件传输、事件解析步骤，直至所述业务流程中的所有流程环节执行完毕。

本发明实施装置中，所述流程触发模块702，用于：

服务调度中心建立与所述事件相应的任务，并发送所述事件至所述队列中心；以及

所述第一服务通过所述用户信息、所述业务流程标识和所述订阅主题消息，从所述调度中心中获取所述任务并执行。

图8示出了可以应用本发明实施例的示例性系统架构800。

如图8所示，系统架构800可以包括终端设备801、802、803，网络804和服务器805(仅仅是示例)。网络804用以在终端设备801、802、803和服务器805之间提供通信链路的介质。网络804可以包括各种连接类型，例如有线、无线通信链路或者光纤电缆等等。

用户可以使用终端设备801、802、803通过网络804与服务器805交互，以接收或发送消息等。终端设备801、802、803上可以安装有各种通讯客户端应用。

终端设备801、802、803可以是具有显示屏并且支持网页浏览的各种电子设备，包括但不限于智能手机、平板电脑、膝上型便携计算机和台式计算机等等。

服务器805可以是提供各种服务的服务器。后台管理服务器可以对接收到的产品信息查询请求等数据进行分析等处理，并将处理结果反馈给终端设备。

需要说明的是，本发明实施例所提供的方法一般由服务器805执行，相应地，装置一般设置于服务器805中。

应该理解，图8中的终端设备、网络和服务器的数目仅仅是示意性的。根据实现需要，可以具有任意数目的终端设备、网络和服务器。

下面参考图9，其示出了适于用来实现本发明实施例的终端设备的计算机系统900的结构示意图。图9示出的终端设备仅仅是一个示例，不应对本发明实施例的功能和使用范围带来任何限制。

如图9所示，计算机系统900包括中央处理单元(CPU)901，其可以根据存储在只读存储器(ROM)902中的程序或者从存储部分908加载到随机访问存储器(RAM)903中的程序而执行各种适当的动作和处理。在RAM 903中，还存储有系统900操作所需的各种程序和数据。CPU 901、ROM 902以及RAM 903通过总线904彼此相连。输入/输出(I/O)接口905也连接至总线904。

以下部件连接至I/O接口905：包括键盘、鼠标等的输入部分906；包括诸如阴极射线管(CRT)、液晶显示器(LCD)等以及扬声器等的输出部分907；包括硬盘等的存储部分908；以及包括诸如LAN卡、调制解调器等的网络接口卡的通信部分909。通信部分909经由诸如因特网的网络执行通信处理。驱动器910也根据需要连接至I/O接口905。可拆卸介质911，诸如磁盘、光盘、磁光盘、半导体存储器等等，根据需要安装在驱动器910上，以便于从其上读出的计算机程序根据需要被安装入存储部分908。

特别地，根据本发明公开的实施例，上文参考流程图描述的过程可以被实现为计算机软件程序。例如，本发明公开的实施例包括一种计算机程序产品，其包括承载在计算机可读介质上的计算机程序，该计算机程序包含用于执行流程图所示的方法的程序代码。在这样的实施例中，该计算机程序可以通过通信部分909从网络上被下载和安装，和/或从可拆卸介质911被安装。在该计算机程序被中央处理单元(CPU)901执行时，执行本发明的系统中限定的上述功能。

需要说明的是，本发明所示的计算机可读介质可以是计算机可读信号介质或者计算机可读存储介质或者是上述两者的任意组合。计算机可读存储介质例如可以是——但不限于——电、磁、光、电磁、红外线、或半导体的系统、装置或器件，或者任意以上的组合。计算机可读存储介质的更具体的例子可以包括但不限于：具有一个或多个导线的电连接、便携式计算机磁盘、硬盘、随机访问存储器(RAM)、只读存储器(ROM)、可擦式可编程只读存储器(EPROM或闪存)、光纤、便携式紧凑磁盘只读存储器(CD-ROM)、光存储器件、磁存储器件、或者上述的任意合适的组合。在本发明中，计算机可读存储介质可以是任何包含或存储程序的有形介质，该程序可以被指令执行系统、装置或者器件使用或者与其结合使用。而在本发明中，计算机可读的信号介质可以包括在基带中或者作为载波一部分传播的数据信号，其中承载了计算机可读的程序代码。这种传播的数据信号可以采用多种形式，包括但不限于电磁信号、光信号或上述的任意合适的组合。计算机可读的信号介质还可以是计算机可读存储介质以外的任何计算机可读介质，该计算机可读介质可以发送、传播或者传输用于由指令执行系统、装置或者器件使用或者与其结合使用的程序。计算机可读介质上包含的程序代码可以用任何适当的介质传输，包括但不限于：无线、电线、光缆、RF等等，或者上述的任意合适的组合。

附图中的流程图和框图，图示了按照本发明各种实施例的系统、方法和计算机程序产品的可能实现的体系架构、功能和操作。在这点上，流程图或框图中的每个方框可以代表一个模块、程序段、或代码的一部分，上述模块、程序段、或代码的一部分包含一个或多个用于实现规定的逻辑功能的可执行指令。也应当注意，在有些作为替换的实现中，方框中所标注的功能也可以以不同于附图中所标注的顺序发生。例如，两个接连地表示的方框实际上可以基本并行地执行，它们有时也可以按相反的顺序执行，这依所涉及的功能而定。也要注意的是，框图或流程图中的每个方框、以及框图或流程图中的方框的组合，可以用执行规定的功能或操作的专用的基于硬件的系统来实现，或者可以用专用硬件与计算机指令的组合来实现。

描述于本发明实施例中所涉及到的模块可以通过软件的方式实现，也可以通过硬件的方式来实现。所描述的模块也可以设置在处理器中，例如，可以描述为：一种处理器包括请求接收模块、服务查询模块、服务编排模块。其中，这些模块的名称在某种情况下并不构成对该模块本身的限定，例如，服务编排模块还可以被描述为“对微服务和/或组合服务进行编排的模块”。

作为另一方面，本发明还提供了一种计算机可读介质，该计算机可读介质可以是上述实施例中描述的设备中所包含的；也可以是单独存在，而未装配入该设备中。上述计算机可读介质承载有一个或者多个程序，当上述一个或者多个程序被一个该设备执行时，使得该设备包括：

接收服务调用请求，解析所述服务调用请求，获取待调用的目标服务标识；

若在预定服务列表中查询不存在与所述目标服务标识相应的目标服务，则获取与所述目标服务标识相应的微服务和/或组合服务；

对所获取的微服务和/或组合服务进行编排，以生成所述目标服务。

以及

接收业务服务请求，获取所述业务服务请求中的用户信息和业务流程标识；

确定与所述用户信息和所述业务流程标识相应的业务流程和订阅主题消息，触发所述业务流程中与所述订阅主题消息相应的流程环节；

在所述业务流程中的所有流程环节执行完毕后，传输执行结果至与所述业务流程标识相应的业务流程信息中。

本发明实施例的技术方案相比现有技术，具有以下优势：

1)当有业务设计需求时，可以基于已有的微服务和/或组合服务进行服务编排，得到所需调用的目标服务，实现了服务拓展，为后续客户化业务流程设计提供了服务化支撑；

2)对于标准服务和客户化服务，都可以通过服务界面进行集成，解决了现有技术集成规范难以统一的问题，降低了服务开发成本，具有良好的实施效果；

3)在业务流程设计环节过程中，提供了用户维护业务流程的功能，用户可以通过服务界面随时修改SaaS服务的业务流程，调整流程环节的执行顺序，达到低成本快速生成客户化业务流程的目的；

4)针对不同的用户信息设置不同的服务编排定义模型，实现了用户信息的隔离；且无需针对各用户建立服务编排系统，只需通过本发明的服务编排机制，即可面向多用户提供服务；

5)通过用户信息和业务流程标识确定业务流程，提高了确定业务流程的准确性；

6)相比现有针对不同业务流程依赖不同服务传输事件的方式，本发明通过服务调度中心传输事件，提高了整个流程中心的运转能力，可面向所有业务流程的运转及监听；

7)和传统SaaS实施服务比较，本发明减少了标准服务参数化处理、客户实施参数配置、客户服务集成过程，因此，解决了实施周期长的问题，提高了SaaS服务实施的效率。

上述具体实施方式，并不构成对本发明保护范围的限制。本领域技术人员应该明白的是，取决于设计要求和其他因素，可以发生各种各样的修改、组合、子组合和替代。任何在本发明的精神和原则之内所作的修改、等同替换和改进等，均应包含在本发明保护范围之内。

Claims (14)

1.一种应用于SaaS的服务编排方法，其特征在于，包括：

接收服务调用请求，解析所述服务调用请求，获取待调用的目标服务标识；

若在预定服务列表中查询不存在与所述目标服务标识相应的目标服务，则获取与所述目标服务标识相应的微服务和/或组合服务；

对所获取的微服务和/或组合服务进行编排，以生成所述目标服务。

2.根据权利要求1所述的方法，其特征在于，在生成所述目标服务之后，还包括：

接收对各目标服务中订阅主题消息的输入；

按照所输入订阅主题消息之间的排列顺序，对与各目标服务相应的流程环节进行排列组合，得到业务流程。

3.根据权利要求2所述的方法，其特征在于，在所述得到业务流程之后，还包括：

接收对所述业务流程的业务流程标识和用户信息的输入，建立所述用户信息、所述业务流程标识和所述业务流程之间的对应关系；以及

建立与所述用户信息和所述业务流程标识相应的服务编排定义模型，存储所述对应关系和所述业务流程至所述服务编排定义模型中。

4.一种应用于SaaS的业务流程处理方法，其特征在于，包括：

接收业务服务请求，获取所述业务服务请求中的用户信息和业务流程标识；

确定与所述用户信息和所述业务流程标识相应的业务流程和订阅主题消息，触发所述业务流程中与所述订阅主题消息相应的流程环节；

在所述业务流程中的所有流程环节执行完毕后，传输执行结果至与所述业务流程标识相应的业务流程信息中。

5.根据权利要求4所述的方法，其特征在于，所述触发所述业务流程中与所述订阅主题消息相应的流程环节，包括：

根据各订阅主题消息的排列顺序，确定排序第一的第一订阅主题消息，发送主题为所述第一订阅主题消息的事件至队列中心；

通过所述第一订阅主题消息，第一服务监听到所述队列中心中的所述事件并解析，以获取所述事件中的业务流程标识；

若所获取的业务流程标识为所述业务流程的业务流程标识，所述第一服务获取与所述事件相应的任务并执行；

在第一流程环节执行完毕后，确定排序第二的第二订阅主题消息，触发与所述第二订阅主题消息相应的第二服务，重复上述事件传输、事件解析步骤，直至所述业务流程中的所有流程环节执行完毕。

6.根据权利要求5所述的方法，其特征在于，所述发送主题为所述第一订阅主题消息的事件至队列中心，包括：

服务调度中心建立与所述事件相应的任务，并发送所述事件至所述队列中心；

所述第一服务获取与所述事件相应的任务并执行，包括：

所述第一服务通过所述用户信息、所述业务流程标识和所述订阅主题消息，从所述调度中心中获取所述任务并执行。

7.一种应用于SaaS的服务编排装置，其特征在于，包括：

请求接收模块，用于接收服务调用请求，解析所述服务调用请求，获取待调用的目标服务标识；

服务查询模块，用于若在预定服务列表中查询不存在与所述目标服务标识相应的目标服务，则获取与所述目标服务标识相应的微服务和/或组合服务；

服务编排模块，用于对所获取的微服务和/或组合服务进行编排，以生成所述目标服务。

8.根据权利要求7所述的装置，其特征在于，还包括流程生成模块，用于：

接收对各目标服务中订阅主题消息的输入；

按照所输入订阅主题消息之间的排列顺序，对与各目标服务相应的流程环节进行排列组合，得到业务流程。

9.根据权利要求8所述的装置，其特征在于，还包括模型建立模块，用于：

接收对所述业务流程的业务流程标识和用户信息的输入，建立所述用户信息、所述业务流程标识和所述业务流程之间的对应关系；以及

建立与所述用户信息和所述业务流程标识相应的服务编排定义模型，存储所述对应关系和所述业务流程至所述服务编排定义模型中。

10.一种应用于SaaS的业务流程处理装置，其特征在于，包括：

信息获取模块，用于接收业务服务请求，获取所述业务服务请求中的用户信息和业务流程标识；

流程触发模块，用于确定与所述用户信息和所述业务流程标识相应的业务流程和订阅主题消息，触发所述业务流程中与所述订阅主题消息相应的流程环节；

结果传输模块，用于在所述业务流程中的所有流程环节执行完毕后，传输执行结果至与所述业务流程标识相应的业务流程信息中。

11.根据权利要求10所述的装置，其特征在于，所述流程触发模块，用于：

根据各订阅主题消息的排列顺序，确定排序第一的第一订阅主题消息，发送主题为所述第一订阅主题消息的事件至队列中心；

通过所述第一订阅主题消息，第一服务监听到所述队列中心中的所述事件并解析，以获取所述事件中的业务流程标识；

若所获取的业务流程标识为所述业务流程的业务流程标识，所述第一服务获取与所述事件相应的任务并执行；

在第一流程环节执行完毕后，确定排序第二的第二订阅主题消息，触发与所述第二订阅主题消息相应的第二服务，重复上述事件传输、事件解析步骤，直至所述业务流程中的所有流程环节执行完毕。

12.根据权利要求11所述的装置，其特征在于，所述流程触发模块，用于：

服务调度中心建立与所述事件相应的任务，并发送所述事件至所述队列中心；以及

所述第一服务通过所述用户信息、所述业务流程标识和所述订阅主题消息，从所述调度中心中获取所述任务并执行。

13.一种电子设备，其特征在于，包括：

一个或多个处理器；

存储装置，用于存储一个或多个程序，

当所述一个或多个程序被所述一个或多个处理器执行，使得所述一个或多个处理器实现如权利要求1-6中任一所述的方法。

14.一种计算机可读介质，其上存储有计算机程序，其特征在于，所述程序被处理器执行时实现如权利要求1-6中任一所述的方法。