CN115277745B - Service bus arrangement system and method supporting asynchronous scheduling - Google Patents

Abstract

The invention discloses a service bus arrangement system supporting asynchronous dispatch, comprising: the visual arrangement platform is used for providing a client interface for a developer to arrange services; the service calling layer is used for calling each service in the arrangement; the message callback layer is used for receiving callback messages; and the message analysis layer is used for analyzing the call return message after the service call. The invention also provides a service bus arrangement method supporting asynchronous scheduling. The beneficial effects of the invention are as follows: simultaneously supporting synchronous requests and asynchronous requests, and further expanding the arrangement capacity of the service bus; the scenes which can be subjected to service arrangement are enriched, and more scenes can be arranged by using the service; the secondary development in the programming of the industrial robot is reduced, the workload of developers is further reduced, and the working efficiency is improved.

Description

A service bus orchestration system and method supporting asynchronous scheduling

[Technical field]

The present invention relates to the technical field of computer software development, and in particular to a service bus orchestration system and method supporting asynchronous scheduling.

【Background technique】

With the rapid development of industrial manufacturing, "intelligent manufacturing" has penetrated deeply into enterprise production, and industrial robots have been able to replace manual production in many scenarios. Service orchestration technology can arrange and combine existing encapsulated single services into larger services without manual programming, thereby reducing the workload of service development. However, the current service orchestration is aimed at the orchestration of synchronous calls, and does not provide support for asynchronous calls of some industrial robots. (Synchronous calls, that is, the client waits for the call to be completed and the result is returned. Asynchronous calls, that is, the client does not wait for the call to be completed and the result is returned, and receives notification of the return result through callback functions, etc.) How to integrate asynchronous calls into the service bus orchestration system is an urgent problem to be solved.

[Summary of the invention]

The present invention discloses a service bus orchestration system and method supporting asynchronous scheduling, which receives asynchronous callback messages in a message callback-based manner, supports asynchronous scheduling orchestration, thereby expanding the orchestration capability of the service bus, simplifying the programming development process of industrial robot development, and further reducing the development workload, thereby solving the technical problems involved in the background technology.

To achieve the above object, the technical solution of the present invention is:

A service bus orchestration system supporting asynchronous scheduling, characterized by comprising:

A visual orchestration platform that provides a client interface for developers to orchestrate services;

The service call layer is used to call each service in the orchestration;

Message callback layer, used to receive callback messages;

The message parsing layer is used to parse the call return message after the service call.

As a preferred improvement of the present invention, the visual orchestration platform includes two data structures, nodeList and routeList, representing orchestration logic information.

As a preferred improvement of the present invention, the nodeList stores node information, which includes node ID, node name, node parameter information and node type; the routeList stores node routing information to indicate the direct relationship between nodes, and the routing information includes the previous node ID, the next node ID and the service address of the node.

As a preferred improvement of the present invention, the node parameter information includes parameter name, parameter value, and parameter type.

As a preferred improvement of the present invention, the message callback layer registers a listener in Zookeeper for receiving Znode data changes.

The present invention also provides a service bus orchestration method supporting asynchronous scheduling based on the service bus orchestration system supporting asynchronous scheduling, the method comprising the following steps:

For synchronously invoked services:

Step 1: Select the node type on the visual orchestration platform, which includes synchronous call and asynchronous call, and enter the parameter information of the service;

Step 2: After selecting the nodes that need to be orchestrated, connect the nodes to form the sequential logic of the orchestration;

Step 3: Start the orchestration service;

Step 4: The service call layer calls the service according to the orchestration logic;

Step 5: The message parsing layer parses the data of the message callback layer and decides the next service call based on the callback message;

For asynchronously called services:

Step 1: Select the node type on the visual orchestration platform, which includes synchronous call and asynchronous call, and enter the parameter information of the service;

Step 2: After selecting the nodes that need to be orchestrated, connect the nodes to form the sequential logic of the orchestration;

Step 3: Start the orchestration service;

Step 4: The service call layer calls the service according to the orchestration logic;

Step 5: The message callback layer waits for receiving the callback message;

Step 6: The message parsing layer parses the data in the message callback layer and decides the next service call based on the callback message.

The beneficial effects of the present invention are as follows:

1. Supports both synchronous and asynchronous requests, further expanding the service bus orchestration capabilities;

2. It enriches the scenarios for service orchestration, and more scenarios can use service orchestration;

3. Reduce the secondary development in industrial robot programming, further reduce the workload of developers and improve work efficiency.

【Brief Description of the Drawings】

In order to more clearly illustrate the technical solutions in the embodiments of the present invention, the following briefly introduces the drawings required for describing the embodiments. Obviously, the drawings described below are only some embodiments of the present invention. For those skilled in the art, other drawings can be obtained based on these drawings without creative work, among which:

FIG1 is a structural framework diagram of a service bus orchestration system supporting asynchronous scheduling according to the present invention;

FIG. 2 is a diagram showing the operation interface of the visual arrangement platform of the present invention.

【Detailed ways】

The following will be combined with the drawings in the embodiments of the present invention to clearly and completely describe the technical solutions in the embodiments of the present invention. Obviously, the described embodiments are only part of the embodiments of the present invention, not all of the embodiments. Based on the embodiments of the present invention, all other embodiments obtained by ordinary technicians in this field without creative work are within the scope of protection of the present invention.

In addition, the technical solutions between the various embodiments of the present invention can be combined with each other, but it must be based on the fact that ordinary technicians in the field can implement it. When the combination of technical solutions is contradictory or cannot be implemented, it should be deemed that such combination of technical solutions does not exist and is not within the scope of protection required by the present invention.

Please refer to Figures 1 and 2 , the present invention provides a service bus orchestration system supporting asynchronous scheduling, including a visual orchestration platform, a service call layer 1 , a message callback layer 2 and a message parsing layer 3 .

The visual orchestration platform is used to provide a client interface for developers to orchestrate services. For details, please refer to Figure 2. On the left side are service components (i.e., nodes), which are basic nodes for orchestration. Each node represents a service. On the right side is a blank space for users to orchestrate. Users can select nodes on the left and then connect nodes on the right side and input parameter information to form the logic of orchestration.

Furthermore, the visual orchestration platform includes two data structures, nodeList and routeList, which represent the orchestration logic information. The nodeList stores the node information, which includes the node ID, node name, node parameter information and node type; the routeList stores the routing information of the node, which is used to represent the direct relationship between the nodes, and the routing information includes the previous node ID, the next node ID and the service address of the node.

As a preferred improvement of the present invention, the node parameter information includes parameter name, parameter value, parameter type

The service calling layer 1 is used to call each service in the orchestration.

The message callback layer 2 is used to receive callback messages. Specifically, the main function of the message callback layer 2 is to be able to wait for callback messages. At the same time, services belonging to the same process should wait for the callback message of the previous service, and services that do not belong to the same process can continue to execute the orchestration logic without waiting. This system chooses to use Zookeeper as a component for receiving and storing callback messages. ZooKeeper is a distributed, open source distributed application coordination service that can be used for unified configuration management, unified naming services, distributed locks, and cluster management. At the same time, Zookeeper can monitor the data changes and increase and decrease changes of Znode in Zookeeper with its listener. Therefore, for asynchronously called services, after this system calls the asynchronous call service, the message callback layer registers a listener with Zookeeper to wait for the callback message of the asynchronous call. At the same time, the message callback layer provides an external callback interface to receive the callback message of the asynchronous call service. When the callback receiving interface receives the callback message, it will write the callback message into the Znode of Zookeeper. At this time, the listener registered by the message callback layer will receive the Znode data change (that is, receive the callback message), and the next service call can be promoted.

The message parsing layer 3 is used to parse the call return message after the service call.

The present invention also provides a service bus orchestration method supporting asynchronous scheduling based on the service bus orchestration system supporting asynchronous scheduling, the method comprising the following steps:

For synchronously invoked services:

Step 1: Select the node type on the visual orchestration platform, which includes synchronous call and asynchronous call, and enter the parameter information of the service;

Step 2: After selecting the nodes that need to be orchestrated, connect the nodes to form the sequential logic of the orchestration;

Step 3: Start the orchestration service;

Step 4: The service call layer calls the service according to the orchestration logic;

Step 5: The message parsing layer parses the data of the message callback layer and decides the next service call based on the callback message;

For asynchronously called services:

Step 1: Select the node type on the visual orchestration platform, which includes synchronous call and asynchronous call, and enter the parameter information of the service;

Step 2: After selecting the nodes that need to be orchestrated, connect the nodes to form the sequential logic of the orchestration;

Step 3: Start the orchestration service;

Step 4: The service call layer calls the service according to the orchestration logic;

Step 5: The message callback layer waits for receiving the callback message;

Step 6: The message parsing layer parses the data in the message callback layer and decides the next service call based on the callback message.

The beneficial effects of the service bus orchestration system supporting asynchronous scheduling provided by the present invention are as follows:

1. Supports both synchronous and asynchronous requests, further expanding the service bus orchestration capabilities;

2. It enriches the scenarios for service orchestration, and more scenarios can use service orchestration;

3. Reduce the secondary development in industrial robot programming, further reduce the workload of developers and improve work efficiency.

Although the embodiments of the present invention have been disclosed as above, they are not limited to the applications listed in the specification and the embodiments. They can be fully applied to various fields suitable for the present invention. For those familiar with the art, additional modifications can be easily implemented. Therefore, without departing from the general concept defined by the claims and the scope of equivalents, the present invention is not limited to the specific details and the illustrations shown and described herein.

Claims (5)

1. A service bus orchestration method supporting asynchronous scheduling, the method comprising the steps of:

For synchronous invoked services:

step one, selecting node types in a visual arrangement platform, wherein the node types comprise synchronous call and asynchronous call, and inputting parameter information of service;

Step two, connecting the nodes after selecting the nodes needing arranging service to form arranging sequential logic;

Step three, starting the arrangement service;

step four, the service calling layer calls the service according to the arrangement logic;

The message analysis layer analyzes the data of the message callback layer and decides the next call service according to the callback message, the function of the message callback layer is to wait for receiving the callback message, meanwhile, the service belonging to the same flow should wait for receiving the callback message of the previous service, and the service not belonging to the same flow can continuously execute the arrangement logic without waiting;

for asynchronously invoked services:

step one, selecting node types in a visual arrangement platform, wherein the node types comprise synchronous call and asynchronous call, and inputting parameter information of service;

Step two, connecting the nodes after selecting the nodes needing arranging service to form arranging sequential logic;

Step three, starting the arrangement service;

step four, the service calling layer calls the service according to the arrangement logic;

step five, the message callback layer waits for receiving callback messages;

and step six, the message analysis layer analyzes the data of the message callback layer and decides the next call service according to the callback message.

2. The service bus orchestration method supporting asynchronous scheduling according to claim 1, wherein the visualization orchestration platform comprises two data structures that represent orchestration logic information, nodeList and routeList.

3. The service bus orchestration method supporting asynchronous scheduling according to claim 2, wherein node information is stored in the nodeList, the node information including node ID, node name, node parameter information, and node type; and routeList stores routing information of the nodes, which is used for representing the direct relation of the nodes, wherein the routing information comprises a last node ID, a next node ID and a service address of the nodes.

4. A service bus orchestration method supporting asynchronous scheduling according to claim 3, wherein the node parameter information comprises parameter names, parameter values, parameter types.

5. The service bus orchestration method that supports asynchronous scheduling according to claim 1, wherein the message callback layer registers a listener in the Zookeeper that receives Znode data changes.