一种支持异步调度的服务总线编排系统及方法
1.【技术领域】 本发明涉及计算机软件开发技术领域，尤其涉及一种支持异步调度的服务总线编排系统及方法。
2.
背景技术：随着工业制造的迅猛发展，“智能智造”已经渗透深入到企业生产中，工业机器人在诸多场景中已经能够代替手工生产。服务编排技术能够将现有封装的单个服务排列组合成更大的服务，而不需要人工编程，从而减少服务开发的工作量。然而，当前的服务编排针对的是同步调用的编排，对于部分工业机器人异步调用方式没有提供支持。（同调用，即客户端等待调用执行完成并返回结果。异步调用，即客户端不等待调用执行完成返回结果，通过回调函数等接收到返回结果的通知。）如何将异步调用方式集成到服务总线编排系统中是急需解决的问题。
3.
技术实现要素：本发明公开了一种支持异步调度的服务总线编排系统及方法，其通过基于消息回调的方式接收异步回调消息，支持异步调度编排，从而拓展服务总线的编排能力，简化工业机器人开发的编程开发过程，进一步降低开发工作量，从而可以解决背景技术中涉及的技术问题。
4.为实现上述目的，本发明的技术方案为：一种支持异步调度的服务总线编排系统，其特征在于，包括：可视化编排平台，用于提供客户端界面以供开发人员编排服务；服务调用层，用于调用编排中各个服务；消息回调层，用于接收回调消息；消息解析层，用于解析服务调用后的调用返回消息。
5.作为本发明的一种优选改进，所述可视化编排平台包括nodelist和routelist两个表示编排逻辑信息的数据结构。
6.作为本发明的一种优选改进，所述nodelist中存放节点信息，所述节点信息包括节点id，节点名称、节点参数信息以及节点类型；所述routelist中存放节点的路由信息，用来表示节点直接的关系，路由信息包括上一个节点id、下一个节点id以及节点的服务地址。
7.作为本发明的一种优选改进，所述节点参数信息包括参数名称、参数值、参数类型。
8.作为本发明的一种优选改进，所述消息回调层在zookeeper中注册一个用于接收znode数据变化的监听器。
9.本发明还提供了一种基于所述的支持异步调度的服务总线编排系统的支持异步调度的服务总线编排方法，该方法包括如下步骤：对于同步调用的服务：步骤一、在可视化编排平台选择节点类型，所述节点类型包括同步调用和异步调用，输入服务的参数信息；
步骤二、选择完需要编排服务的节点后将节点连线，形成编排的顺序逻辑；步骤三、启动编排服务；步骤四、服务调用层根据编排逻辑调用服务；步骤五、消息解析层解析消息回调层的数据，根据回调消息决定下一步调用服务；对于异步调用的服务：步骤一、在可视化编排平台选择节点类型，所述节点类型包括同步调用和异步调用，输入服务的参数信息；步骤二、选择完需要编排服务的节点后将节点连线，形成编排的顺序逻辑；步骤三、启动编排服务；步骤四、服务调用层根据编排逻辑调用服务；步骤五、消息回调层等待接收回调消息；步骤六、消息解析层解析消息回调层的数据，根据回调消息决定下一步调用服务。
10.本发明的有益效果如下：1、同时支持同步请求和异步请求的支持，进一步拓展了服务总线编排能力；2、丰富了可以进行服务编排场景，有更多的场景可以使用服务编排；3、减少了工业机器人编程中的二次开发，进一步降低了开发人员的工作量，提升工作效率。
11.【附图说明】为了更清楚地说明本发明实施例中的技术方案，下面将对实施例描述中所需要使用的附图作简单地介绍，显而易见地，下面描述中的附图仅仅是本发明的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动的前提下，还可以根据这些附图获得其它的附图，其中：图1为本发明支持异步调度的服务总线编排系统的结构框架图；图2为本发明可视化编排平台的操作界面图。
12.【具体实施方式】下面将结合本发明实施例中的附图，对本发明实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅是本发明的一部分实施例，而不是全部的实施例。基于本发明中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其它实施例，都属于本发明保护的范围。
13.另外，本发明各个实施例之间的技术方案可以相互结合，但是必须是以本领域普通技术人员能够实现为基础，当技术方案的结合出现相互矛盾或无法实现时应当认为这种技术方案的结合不存在，也不在本发明要求的保护范围之内。
14.请参阅图1和2所示，本发明提供一种支持异步调度的服务总线编排系统，包括可视化编排平台、服务调用层1、消息回调层2以及消息解析层3。
15.所述可视化编排平台用于提供客户端界面以供开发人员编排服务，具体可以参见图2所示，在左侧是服务组件（即节点），用于编排的基础节点，每一个节点都代表一个服务；右侧是用户用于编排的空白处，用户可以在左侧选择节点后在右侧连接节点、输入参数信息，形成编排的逻辑。
16.进一步的，所述可视化编排平台包括nodelist和routelist两个表示编排逻辑信
息的数据结构，所述nodelist中存放节点信息，所述节点信息包括节点id，节点名称、节点参数信息以及节点类型；所述routelist中存放节点的路由信息，用来表示节点直接的关系，路由信息包括上一个节点id、下一个节点id以及节点的服务地址。
17.作为本发明的一种优选改进，所述节点参数信息包括参数名称、参数值、参数类型所述服务调用层1用于调用编排中各个服务。
18.所述消息回调层2用于接收回调消息，具体的，所述消息回调层2的主要功能是能够等待接收回调消息，同时，属于同一流程的服务应该等待收到前一个服务的回调消息，不属于同一流程的服务无需等待可继续执行编排逻辑。本系统选择使用zookeeper作为接收存储回调消息的组件，zookeeper是一个分布式的，开放源码的分布式应用程序协调服务，可用于统一配置管理、统一命名服务、分布式锁、集群管理。同时zookeeper配合它的监听器能够监听zookeeper中znode的数据变化和增减变化。因此，对于异步调用的服务，本系统调用该异步调用服务后，消息回调层则向zookeeper注册一个监听器，等待异步调用的回调消息。同时，消息回调层提供一个对外的回调接口接收异步调用服务的回调消息。当回调接收接口收到回调消息后，会将回调消息写入zookeeper的znode中。此时消息回调层注册的监听器将收到znode数据变化（即收到回调消息），即可推进下一步的服务调用。
19.所述消息解析层3用于解析服务调用后的调用返回消息。
20.本发明还提供了一种基于所述的支持异步调度的服务总线编排系统的支持异步调度的服务总线编排方法，该方法包括如下步骤：对于同步调用的服务：步骤一、在可视化编排平台选择节点类型，所述节点类型包括同步调用和异步调用，输入服务的参数信息；步骤二、选择完需要编排服务的节点后将节点连线，形成编排的顺序逻辑；步骤三、启动编排服务；步骤四、服务调用层根据编排逻辑调用服务；步骤五、消息解析层解析消息回调层的数据，根据回调消息决定下一步调用服务；对于异步调用的服务：步骤一、在可视化编排平台选择节点类型，所述节点类型包括同步调用和异步调用，输入服务的参数信息；步骤二、选择完需要编排服务的节点后将节点连线，形成编排的顺序逻辑；步骤三、启动编排服务；步骤四、服务调用层根据编排逻辑调用服务；步骤五、消息回调层等待接收回调消息；步骤六、消息解析层解析消息回调层的数据，根据回调消息决定下一步调用服务。
21.本发明提供的一种支持异步调度的服务总线编排系统的有益效果：1、同时支持同步请求和异步请求的支持，进一步拓展了服务总线编排能力；2、丰富了可以进行服务编排场景，有更多的场景可以使用服务编排；3、减少了工业机器人编程中的二次开发，进一步降低了开发人员的工作量，提升工作效率。
22.尽管本发明的实施方案已公开如上，但并不仅仅限于说明书和实施方案中所列运
用，它完全可以被适用于各种适合本发明的领域，对于熟悉本领域的人员而言，可容易地实现另外的修改，因此在不背离权利要求及等同范围所限定的一般概念下，本发明并不限于特定的细节和这里所示出与描述的图例。
技术特征：1.一种支持异步调度的服务总线编排系统，其特征在于，包括：可视化编排平台，用于提供客户端界面以供开发人员编排服务；服务调用层，用于调用编排中各个服务；消息回调层，用于接收回调消息；消息解析层，用于解析服务调用后的调用返回消息。2.如权利要求1所述的一种支持异步调度的服务总线编排系统，其特征在于，所述可视化编排平台包括nodelist和routelist两个表示编排逻辑信息的数据结构。3.如权利要求2所述的一种支持异步调度的服务总线编排系统，其特征在于，所述nodelist中存放节点信息，所述节点信息包括节点id，节点名称、节点参数信息以及节点类型；所述routelist中存放节点的路由信息，用来表示节点直接的关系，路由信息包括上一个节点id、下一个节点id以及节点的服务地址。4.如权利要求3所述的一种支持异步调度的服务总线编排系统，其特征在于，所述节点参数信息包括参数名称、参数值、参数类型。5.如权利要求1所述的一种支持异步调度的服务总线编排系统，其特征在于，所述消息回调层在zookeeper中注册一个用于接收znode数据变化的监听器。6.一种基于权利要求1-5任意一项所述的支持异步调度的服务总线编排系统的支持异步调度的服务总线编排方法，其特征在于，该方法包括如下步骤：对于同步调用的服务：步骤一、在可视化编排平台选择节点类型，所述节点类型包括同步调用和异步调用，输入服务的参数信息；步骤二、选择完需要编排服务的节点后将节点连线，形成编排的顺序逻辑；步骤三、启动编排服务；步骤四、服务调用层根据编排逻辑调用服务；步骤五、消息解析层解析消息回调层的数据，根据回调消息决定下一步调用服务；对于异步调用的服务：步骤一、在可视化编排平台选择节点类型，所述节点类型包括同步调用和异步调用，输入服务的参数信息；步骤二、选择完需要编排服务的节点后将节点连线，形成编排的顺序逻辑；步骤三、启动编排服务；步骤四、服务调用层根据编排逻辑调用服务；步骤五、消息回调层等待接收回调消息；步骤六、消息解析层解析消息回调层的数据，根据回调消息决定下一步调用服务。
技术总结本发明公开了一种支持异步调度的服务总线编排系统，包括：可视化编排平台，用于提供客户端界面以供开发人员编排服务；服务调用层，用于调用编排中各个服务；消息回调层，用于接收回调消息；以及消息解析层，用于解析服务调用后的调用返回消息。本发明还提供了一种支持异步调度的服务总线编排方法。本发明的有益效果如下：同时支持同步请求和异步请求的支持，进一步拓展了服务总线编排能力；丰富了可以进行服务编排场景，有更多的场景可以使用服务编排；减少了工业机器人编程中的二次开发，进一步降低了开发人员的工作量，提升工作效率。提升工作效率。提升工作效率。
技术研发人员：边耐政 刘旺 尹晋文 张小刚 王绍源
受保护的技术使用者：湖南大学
技术研发日：2022.06.24
技术公布日：2022/11/1
