TWI756831B - Network service decentralized data transmission system and method thereof - Google Patents

Abstract

A network service decentralized data transmission system and a method thereof are provided. Profession service node establishes connection with profession lite agent. Consumption service node establishes connection with consumption lite agent. Profession lite agent establishes connection with consumption lite agent. Service node is registered and changed through lite agent. Request and response are transferred through lite agent for service node. Request and response can still be transferred through another lite agent for service node. Therefore, the efficiency of decentralized data transmission with network service may be achieved.

Description

Network service decentralized data transmission system and method

A data transmission system and method thereof, in particular, a data transmission system and method for decentralization of network services provided by lightweight agents and service nodes.

With the promotion of the microservice design method, the communication between services is becoming more and more frequent, and how to configure service nodes for services will be a problem that must be considered. In order to solve the above problems, the existing technology proposes to use the domain name system (Domain Name System, DNS) service, the service accesses the service node through the function variable name. When the service node changes the Internet protocol address, the administrator needs to change the domain name system resolution configuration in time, and the domain name exists in the process. The system cache flush interval has the potential to disrupt service.

When the architecture of the service node supports clustering, the usual practice is to use the API Gateway mode for load balancing and forward requests to the currently available service nodes, regardless of whether the API Gateway mode itself is a high-availability deployment. Still belonging to the central node, the abnormal operation of the domain name system will cause all related services to fail to work properly.

The existing solution to the above problems is to import the Service Mesh framework, which uses message queues and shared databases to realize service registration and discovery, and to carry out detailed management. However, such a scheme will still introduce central nodes, whether it is a message queue or a shared database. If these central nodes fail, all service nodes will be in a state of inoperability.

To sum up, it can be seen that there has been a long-standing problem in the prior art that existing network services still have the problem that when the central node fails, all service nodes will not work, so it is necessary to propose improved technical means to solve the problem. this question.

In view of the prior art that the existing network services still have the problem that all the service nodes will be unable to work when the centralized service node is disabled when the central node is disabled, the present invention discloses a network service decentralized data transmission system and method thereof, in:

The network service decentralization data transmission system disclosed in the present invention comprises: a business service node, a business service light agent (Lite Agent, LA), a consumption service node and a consumption service light agent.

The business service node provides management information of the business service node when it is started, the business service node receives the network parameters and generates a service response corresponding to the network parameter, and the business service node feeds back the service response.

The business service lightweight agent establishes a connection with the business service node to receive the management information of the business service node from the business service node. The business service lightweight agent registers the management information of the business service node to update the service list list. The volume agent synchronizes the service inventory list.

The consumer service node is used to transmit the node name and network parameters of the business service node, and the consumer service node receives the feedback service response.

The consumption service lightweight agent establishes a connection with the business service lightweight agent, the consumption service lightweight agent obtains the service list list synchronously from the business service lightweight agent, and the consumption service lightweight agent establishes a connection with the consumption service node to self-consumption service node. After receiving the node name and network parameters of the business service node, the consumer service lightweight agent queries the Internet Protocol Address (IP Address) of the corresponding business service node from the service list according to the node name of the business service node. , the consumer service lightweight agent transmits the network parameters to the corresponding business service node according to the Internet protocol address of the business service node, the consumer service lightweight agent receives the feedback service response from the business service node, and the consumer service lightweight agent transmits The feedback service responds to the consuming service node.

The data transmission method for network service decentralization disclosed in the present invention comprises the following steps:

First, the business service node establishes a connection with the business service lightweight agent; then, the consumer service node establishes a connection with the consumer service lightweight agent; then, the business service lightweight agent establishes a connection with the consumer service lightweight agent; then, the business When the service node is started, the management information of the business service node is provided to the business service lightweight agent; then, the business service lightweight agent registers the management information of the business service node to update the service list list; then, the business service lightweight agent will serve The list list is synchronized to the consumer service lightweight proxy; then, the consumer service node receives the node name and network parameters of the business service node; then, the consumer service node transmits the business service node's node name and network parameters to the consumer service lightweight proxy; Next, the consumer service lightweight agent queries the Internet protocol address of the corresponding business service node from the service list list according to the node name of the business service node; Then, the business service node generates a service response corresponding to the network parameters; then, the business service node feeds back the service response to the consumer service lightweight proxy; finally, the consumer service lightweight proxy The feedback service responds to the consuming service node.

The system and method disclosed in the present invention are as above, and the difference between the system and the prior art is that the business service node establishes a connection with the business service lightweight agent, the consumer service node establishes a connection with the consumer service lightweight agent, and the business service lightweight agent establishes a connection with the business service lightweight agent. The consumer service lightweight proxy establishes a connection, realizes the registration and change of the service node through the lightweight proxy, and the service node realizes the request and response data transmission through the lightweight proxy. Request and response data transfer through other lightweight proxies.

Through the above technical means, the present invention can achieve the technical effect of data transmission with network service decentralization.

The embodiments of the present invention will be described in detail below with the drawings and examples, so as to fully understand and implement the implementation process of how the present invention applies technical means to solve technical problems and achieve technical effects.

The following first describes the decentralized data transmission system of the network service disclosed in the present invention, and please refer to "Fig. 1" and "Fig. 2". "Fig. 1" shows the network service of the present invention. System block diagram of the decentralized data transmission system; "Figure 2" shows the data flow diagram of the decentralized data transmission for the network service of the present invention.

The network service decentralization data transmission system disclosed in the present invention includes: a business service node 11 , a business service light agent (Lite Agent, LA) 12 , a consumption service node 31 and a consumption service light agent 32 .

In the description of the present invention, a single business service node 11, a single business service lightweight proxy 12, a single consumer service node 31 and a single consumer service lightweight proxy 32 are used as examples. In fact, the network service architecture has multiple A business service node 11, a plurality of business service light-weight agents 12, a plurality of consumption service nodes 31, and a plurality of consumption service light-weight agents 32, each of the business service light-weight agents 12 and each of the consumption service light-weight agents 32 are among each other Connections are created to construct a mesh-connected architecture.

The business service node 11 establishes a connection with the business service lightweight agent 12 , the consumption service node 31 establishes a connection with the consumption service lightweight agent 32 , and the business service lightweight agent 12 establishes a connection with the consumption service lightweight agent 32 .

It is worth noting that the business service lightweight proxy 12 establishes a persistent connection (HTTP persistent connection) with the consumer service lightweight proxy 32 through a pre-established connection configuration or a User Datagram Protocol (UDP) connect.

The business service node 11 provides the management information 51 of the business service node 11 to the business service lightweight agent 12 at startup. The aforementioned management information 51 of the business service node 11 includes the node name of the business service node 11, for example: ServiceA, business service node 11, the latest access frequency of the business service node 11, the node status of the business service node 11, and the response time of the business service node 11 are only examples here, and are not intended to limit the invention. application area.

The business service lightweight agent 12 can receive the management information 51 of the business service node 11 from the business service node 11 , and then the business service lightweight agent 12 registers the management information 51 of the business service node 11 to update the service list list 52 .

Next, the business service lightweight proxy 12 performs a synchronization operation on the service list list 52, that is, the business service lightweight proxy 12 synchronizes the service list list 52 to the consuming service lightweight proxy 32. When the consuming service node 31 transmits the node of the business service node 11 The name 53 is "ServiceA" and the network parameter 54 is "status", the consumer service lightweight agent 32 can receive the node name 53 of the business service node 11 from the consumer service node 31 as "ServiceA" and the network parameter 54 is "status" ".

The consumer service lightweight agent 32 queries the Internet Protocol Address (IP Address) of the corresponding service service node 11 from the service list 52 according to the node name 53 of the service service node 11 as "ServiceA".

The consumer service lightweight agent 32 transmits the network parameter 54 as "status" to the corresponding business service node 11 according to the Internet Protocol address of the business service node 11, and the business service node 11 receives the network from the consumer service lightweight agent 32. After the network parameter 54 is "status", the service service node 11 can generate a service response 55 corresponding to the network parameter 54 being "status".

When the business service node 11 generates a service response 55 corresponding to the network parameter 54 being "status", the business service node 11 can feed back the service response 55 to the consumer service lightweight agent 32, and the consumer service lightweight agent 32 can The service node 11 receives the feedback service response 55 .

When the consumer service lightweight proxy 32 receives the service response 55 from the business service node 11, the consumer service lightweight proxy 32 can feed back the service response 55 to the consumer service node 31, and the consumer service node 31 can receive the service response from the consumer service lightweight proxy 32. The service responds with 55.

The consumer service lightweight agent 32 further records that the consumer service lightweight agent 32 transmits the network parameter 54 as "status" to the corresponding business service node 11 according to the Internet protocol address of the business service node 11, and then the business service node 11. 11. Feedback service response 55 to the response duration of the consuming service lightweight proxy 32.

The consumption service lightweight agent 32 updates the response time of the business service node 11 with the response time of the business service node in the service list list 52, and performs a synchronization operation on the updated service list list 52, that is, the consumption service lightweight agent 32 The updated service manifest list 52 is synchronized to the business service lightweight agent 12 .

Please refer to "Fig. 3", "Fig. 3" shows the data flow diagram of the decentralized data transmission of the network service of the present invention. If the consumer service lightweight agent 32 is based on the node name 53 of the business service node 11 For "ServiceA", the Internet protocol address of the corresponding business service node 11 is queried from the service list list 52, and the consumer service lightweight agent 32 sets the network parameter 54 to "" according to the Internet protocol address of the business service node 11 status” is transmitted to the corresponding service service node 11.

When the consumer service lightweight agent 32 fails to receive the feedback service response 55 from the business service node 11 within a predetermined time, the consumer service lightweight agent 32 will remove the management information of the business service node 11 from the service list list 52, And the consuming service lightweight agent 32 performs a synchronization operation on the service list list 52, that is, the consuming service lightweight agent 32 synchronizes the service list list 52 to the lightweight agent 22, and the lightweight agent 22 establishes a connection with the service node 21, so that other The lightweight agent 22 can synchronously remove the management information of the business service node 11 from the service list list 52, so as to avoid selecting a service node that cannot be connected when the lightweight agent is selected.

Next, the operation method of the present invention will be described below, and please refer to "Fig. 4A" to "Fig. 4C" at the same time. The method flow chart of the data transmission method of the transformation.

First, the business service node establishes a connection with the business service lightweight proxy (step 101); then, the consumer service node establishes a connection with the consumer service lightweight proxy (step 102); then, the business service lightweight proxy and the consumer service lightweight proxy The agent establishes a connection (step 103); then, when the business service node starts, it provides the management information of the business service node to the business service lightweight agent (step 104); then, the business service lightweight agent registers the management information of the business service node The procedure is to update the service list list (step 105); then, the business service lightweight proxy synchronizes the service list list to the consumer service lightweight proxy (step 106); then, the consumer service node receives the node name and network parameters of the business service node (step 107 ); then, the consumer service node transmits the node name and network parameters of the business service node to the consumer service lightweight agent (step 108 ); then, the consumer service lightweight agent lists the service list from the service list according to the node name of the business service node Query the Internet protocol address of the corresponding business service node (step 109); then, the consumer service lightweight agent transmits the network parameters to the corresponding business service node according to the Internet protocol address of the business service node ( Step 110); then, the business service node generates a service response corresponding to the network parameters (step 111); then, the business service node feeds back the service response to the consumer service lightweight proxy (step 112) Finally, the consumer service lightweight proxy feeds back the service Response to the consuming service node (step 113).

To sum up, it can be seen that the difference between the present invention and the prior art is that the business service node establishes a connection with the business service lightweight agent, the consumer service node establishes a connection with the consumer service lightweight agent, and the business service lightweight agent and the consumer service establish a connection. The lightweight proxy establishes a connection, realizes the registration and change of the service node through the lightweight proxy, and the service node realizes the request and response data transmission through the lightweight proxy. The lightweight proxy implements request and response data transfer.

This technical means can solve the problem that the existing network services in the prior art still have the problem that all the service nodes will not work when the central node fails, so as to achieve the decentralized data of the network service. Technical efficacy of transmission.

Although the embodiments disclosed in the present invention are as above, the above-mentioned contents are not used to directly limit the scope of the patent protection of the present invention. Anyone with ordinary knowledge in the technical field to which the present invention pertains can make some changes in the form and details of the implementation without departing from the spirit and scope of the present invention. The scope of patent protection of the present invention shall still be defined by the scope of the appended patent application.

11: Business service node 12: Business Service Lightweight Proxy 21: Service Node 22: Lightweight Proxies 31: Consumer service node 32: Lightweight proxy for consumer services 51: Management Information 52: List of Service Checklists 53: Node name 54: Network parameters 55: Service Response Step 101: Establish a connection between the business service node and the business service lightweight agent Step 102: The consumer service node establishes a connection with the consumer service lightweight agent Step 103: Establish a connection between the business service lightweight proxy and the consumer service lightweight proxy Step 104: When the business service node is started, the management information of the business service node is provided to the business service lightweight agent Step 105: The business service lightweight agent registers the management information of the business service node to update the service list list Step 106: The business service lightweight proxy synchronizes the service list list to the consumer service lightweight proxy Step 107: The consumer service node receives the node name and network parameters of the business service node Step 108: The consumer service node transmits the node name and network parameters of the business service node to the consumer service lightweight proxy Step 109: The consumer service lightweight agent queries the Internet Protocol address of the corresponding business service node from the service list list according to the node name of the business service node Step 110: The consumer service lightweight agent transmits the network parameters to the corresponding business service node according to the Internet Protocol address of the business service node Step 111: The service service node generates a service response corresponding to the network parameters Step 112: The business service node feeds back the service response to the consumer service lightweight proxy Step 113: The consumer service lightweight proxy feeds back the service response to the consumer service node

FIG. 1 is a system block diagram of the data transmission system for the decentralization of network services according to the present invention. FIG. 2 and FIG. 3 are the data flow diagrams of the decentralized data transmission of the network service of the present invention. FIGS. 4A to 4B are method flowcharts of the data transmission method for the decentralization of network services according to the present invention.

11: Business service node

12: Business Service Lightweight Proxy

31: Consumer service node

32: Lightweight proxy for consumer services

Claims (10)

A decentralized data transmission system for network services, which includes: A business service node, the business service node provides management information of the business service node when it is started, the business service node receives a network parameter and generates a service response corresponding to the network parameter, the business service node The node feeds back the service response; A business service light agent (Lite Agent, LA), the business service light agent establishes a connection with the business service node, so as to receive the management information of the business service node from the business service node, the business service The service lightweight agent performs a registration procedure on the management information of the business service node to update a service list list, and the business service lightweight agent performs a synchronization operation on the service list list; a consuming service node for transmitting the node name and network parameter of the business service node, and the consuming service node receives the feedback of the service response; and A consumption service lightweight agent, the consumption service lightweight agent establishes a connection with the business service lightweight agent, the consumption service lightweight agent obtains the service list list synchronously from the business service lightweight agent, and the The consumption service lightweight agent establishes a connection with the consumption service node to receive the node name and network parameters of the business service node from the consumption service node, and the consumption service lightweight agent is based on the business service node. Query the corresponding Internet Protocol Address (Internet Protocol Address, IP Address) of the business service node from the service list list, and the consumption service lightweight agent is based on the Internet The consuming service lightweight proxy receives the feedback service response from the service service node, and the consuming service lightweight proxy transmits the feedback The service responds to the consuming service node. The data transmission system for network service decentralization according to claim 1, wherein the business service light-weight agent communicates with all services through a pre-established connection configuration or a User Datagram Protocol (UDP). The consumer service lightweight proxy establishes a connection with a persistent connection (HTTP persistent connection). The network service decentralized data transmission system according to claim 1, wherein the management information of the business service node includes the node name of the business service node, the Internet Protocol address of the business service node, The latest access frequency of the business service node, the node status of the business service node, and the response time of the business service node. The data transmission system for network service decentralization according to claim 1, wherein the consumption service light-weight agent further comprises a record that the consumption service light-weight agent transmits the network parameters to the corresponding business The service node then feeds back the response duration of the service response to the consuming service lightweight proxy from the business service node. The network service decentralized data transmission system according to claim 4, wherein the consumer service lightweight agent updates the response duration of the business service node to the business service node in the service list list the response time, and synchronize the updated service list list. A data transmission method for network service decentralization, comprising: A business service node establishes a connection with a business service Lite Agent (LA); A consumer service node establishes a connection with a consumer service lightweight agent; establishing a connection between the business service lightweight agent and the consumer service lightweight agent; When the business service node is started, the management information of the business service node is provided to the business service lightweight agent; The business service lightweight agent performs a registration procedure on the management information of the business service node to update a service list list; The business service lightweight proxy synchronizes the service list list to the consumer service lightweight proxy; The consumer service node receives the node name and network parameters of the business service node; The consumer service node transmits the node name of the business service node and the network parameter to the consumer service lightweight proxy; The consumer service lightweight agent queries the corresponding Internet Protocol Address (IP Address) of the business service node from the service list list according to the node name of the business service node; The consumer service lightweight agent transmits the network parameter to the corresponding business service node according to the Internet Protocol address of the business service node; generating, by the business service node, a service response corresponding to the network parameter; the business service node feeds back the service response to the consuming service lightweight proxy; and The consuming service lightweight proxy feeds back the service response to the consuming service node. The data transmission method for network service decentralization according to claim 6, wherein the business service light-weight proxy communicates with all the services through a pre-established connection configuration or a User Datagram Protocol (UDP). The consumer service lightweight proxy establishes a connection with a persistent connection (HTTP persistent connection). The data transmission method for network service decentralization according to claim 6, wherein the management information of the business service node includes the node name of the business service node, the Internet Protocol address of the business service node, The latest access frequency of the business service node, the node status of the business service node, and the response time of the business service node. The data transmission method for network service decentralization according to claim 6, wherein the consuming service lightweight agent further comprises a record of transmitting the network parameters to the corresponding service by the consuming service lightweight agent The service node then feeds back the response duration from the service response to the consuming service lightweight proxy from the business service lightweight proxy. The data transmission method for network service decentralization according to claim 9, wherein the consumer service lightweight agent updates the response duration of the business service node to the business service node in the service list list the response time, and synchronize the updated service list list.

Images