CN114827078A

CN114827078A - Node access method and data transmission system

Info

Publication number: CN114827078A
Application number: CN202210339380.6A
Authority: CN
Inventors: 梁腾飞
Original assignee: Alibaba Cloud Computing Ltd
Current assignee: Alibaba Cloud Computing Ltd
Priority date: 2022-04-01
Filing date: 2022-04-01
Publication date: 2022-07-29
Also published as: WO2023186109A1

Abstract

An embodiment of the present specification provides a node access method and a data transmission system, where the node access method includes: receiving request message data, generating response message data according to the request message data, and sending the response message data to a request node according to the first address corresponding relation, wherein the first address corresponding relation is established through the message data sent by a transfer node, and the first address corresponding relation comprises the corresponding relation between the address of the request node and the address carried by the response message. Response message data are generated according to the received request message data, and are directly sent back to the request node according to the first address corresponding relation, so that the transfer equipment is bypassed, the load of the transfer equipment is reduced, and the load balance is realized.

Description

Node access method and data transmission system

Technical Field

The embodiment of the specification relates to the technical field of data processing, in particular to a node access method.

Background

The IPV6 network is being expanded, however, many backend services still only support IPV4 access and do not have IPV6 access capability, so the front end provides IPV6 access, and the backend still uses IPV4 as a load balancing technology for entity services, which becomes a suitable transition technology. This technique is referred to as 6to4 load balancing.

However, the 6to4 load balancing technology, like other load balancing technologies, has the risks of traffic centralization and pressure explosion load balancing, and also has the problems of single flow pps being too large, unbalanced cpu of the load balancer, and the like. The conventional 6to4 load balancing technology is already mature, but because of the conventional 6to4 load balancing, traffic is concentrated on the LVS for processing, and each packet of the back-and-forth traffic needs the LVS to participate in scheduling distribution, which causes problems of excessive pressure and performance bottleneck of the LVS.

Disclosure of Invention

In view of this, the embodiments of the present specification provide two node access methods. One or more embodiments of the present disclosure also relate to a data transmission system, two node access devices, two node access apparatuses, a computing device, a computer-readable storage medium, and a computer program, so as to solve the technical drawbacks of the prior art.

According to a first aspect of embodiments of the present specification, there is provided a node access method, including:

receiving request message data;

generating response message data according to the request message data;

and sending the response message data to a request node according to the first address corresponding relation, wherein the first address corresponding relation is established through the message data sent by a transit node, and the first address corresponding relation comprises the corresponding relation between the address of the request node and the address carried by the response message.

According to a second aspect of embodiments of the present specification, there is provided a node access method including:

forwarding the first request message data to a service node through a transfer node to acquire response message data;

establishing a second address corresponding relation between the address of the service node and the address of the transit node according to the address of the service node carried by the response message data;

and when second request message data needs to be sent, sending the second request message data to the service node according to the service node address corresponding to the address of the transfer node aimed at by the second request message data in the second address corresponding relation.

According to a third aspect of embodiments herein, there is provided a data transmission system including:

a request node, a transfer node and a service node;

the request node converts the request message data of the initial type into the request message data of the target type and sends the request message data of the target type to the transfer node;

the transfer node sends the request message data of the target type to the service node according to a scheduling rule;

the service node generates response message data of the target type according to the request message data of the target type, establishes a first address corresponding relation, and

converting the response message data of the target type into response message data of an initial type according to the first address corresponding relation, and sending the response message data of the initial type to the request node;

and the request node establishes a second address corresponding relation according to the response message data of the initial type and accesses the service node according to the second address corresponding relation.

According to a fourth aspect of embodiments herein, there is provided a node access apparatus including:

a receiving module configured to receive request message data;

the generating module is configured to generate response message data according to the request message data;

and the access module is configured to send the response message data to a request node according to the first address corresponding relationship, wherein the first address corresponding relationship is established through the request message data sent by the transit node, and the first address corresponding relationship comprises a corresponding relationship between an address of the request node and an address carried by the response message.

According to a fifth aspect of embodiments herein, there is provided a node access apparatus including:

the sending module is configured to forward the first request message data to the service node through the transit node so as to obtain response message data;

the relation establishing module is configured to establish a second address corresponding relation between the address of the service node and the address of the transit node according to the address of the service node carried by the response message data;

and the access module is configured to send second request message data to the service node according to a service node address corresponding to the address of the transfer node for the second request message data in the second address corresponding relation when the second request message data needs to be sent.

According to a sixth aspect of embodiments herein, there is provided a node access apparatus, including:

a receiving module configured to receive request message data;

and the access module is configured to send the response message data to a request node according to the first address corresponding relationship, wherein the first address corresponding relationship is established through the request message data sent by the transfer node, and the first address corresponding relationship comprises a corresponding relationship between the address of the request node and the address carried by the response message.

According to a seventh aspect of the embodiments of the present specification, there is provided a node access apparatus, including:

According to an eighth aspect of embodiments herein, there is provided a computing device comprising:

a memory and a processor;

the memory is configured to store computer-executable instructions and the processor is configured to execute the computer-executable instructions, which when executed by the processor, implement the steps of the above-described node access method.

According to a ninth aspect of embodiments herein, there is provided a computer-readable storage medium storing computer-executable instructions that, when executed by a processor, implement the steps of the above-described node access method.

According to a tenth aspect of embodiments herein, there is provided a computer program, wherein the computer program, when executed in a computer, causes the computer to perform the steps of the above-described node access method.

Drawings

FIG. 1 is a flow chart of a node access method provided by one embodiment of the present description;

FIG. 2 is a flow diagram of another node access method provided by one embodiment of the present description;

FIG. 3a is a schematic diagram of a data transmission system provided in one embodiment of the present specification;

FIG. 3b is a timing diagram of a data transmission system provided in one embodiment of the present specification;

FIG. 4 is a flowchart illustrating a processing procedure of a node access method according to an embodiment of the present disclosure;

fig. 5 is a schematic structural diagram of a node access apparatus according to an embodiment of the present specification;

fig. 6 is a schematic structural diagram of another node access device provided in an embodiment of the present specification;

fig. 7 is a block diagram of a computing device according to an embodiment of the present disclosure.

Detailed Description

In the following description, numerous specific details are set forth in order to provide a thorough understanding of the present specification. This description may be embodied in many different forms and should not be construed as limited to the embodiments set forth herein, as those skilled in the art will be able to make and use the present disclosure without departing from the spirit and scope of the present disclosure.

The terminology used in the description of the one or more embodiments is for the purpose of describing the particular embodiments only and is not intended to be limiting of the description of the one or more embodiments. As used in one or more embodiments of the present specification and the appended claims, the singular forms "a," "an," and "the" are intended to include the plural forms as well, unless the context clearly indicates otherwise. It should also be understood that the term "and/or" as used in one or more embodiments of the present specification refers to and encompasses any and all possible combinations of one or more of the associated listed items.

It will be understood that, although the terms first, second, etc. may be used herein in one or more embodiments to describe various information, these information should not be limited by these terms. These terms are only used to distinguish one type of information from another. For example, a first can also be referred to as a second and, similarly, a second can also be referred to as a first without departing from the scope of one or more embodiments of the present description. The word "if" as used herein may be interpreted as "at … …" or "when … …" or "in response to a determination", depending on the context.

First, the noun terms to which one or more embodiments of the present specification relate are explained.

Virtual Private Cloud (VPC) is a dynamically configured pool of public cloud computing resources that requires the use of encryption protocols, tunneling protocols, and other security procedures to transfer data between a private enterprise and a cloud service provider.

VXLAN is an overlay network technology, encapsulation is performed by using an MAC in UDP method, a virtual 2-layer subnet spanning multiple physical IP subnets can be created, a fully virtualized infrastructure cloud service is created, communication between a layer 2 and any endpoint is allowed, a VXLAN adds a VXLAN Header with 8 bytes on the basis of an inner-layer original Ethernet frame, and then an outer layer is a UDP Header, an outer-layer IP Header and an outer-layer Mac Header respectively, and 50-byte encapsulation message headers are used in total.

A learning source: the address of the overlay can be transmitted in the physical network only by corresponding to an underlay address, the actual representation is on a virtual host, and a real physical machine is required to be corresponding to the overlay address, so that the learning of the corresponding relation between the virtual machine and the physical machine is the learning source capability.

And (4) LVS: refers to a load balancing soft and hard integrated device.

Load balancing, which is built on the existing network structure, provides a cheap, effective and transparent method to expand the bandwidth of network devices and servers, increase the throughput, strengthen the network data processing capacity and improve the flexibility and availability of the network.

Five elements of information, source IP address, source port, destination IP address, destination port, and transport layer protocol.

Internet Protocol version 4 (English: Internet Protocol version 4, IPV 4): the fourth version of the internet communication protocol is the fourth revision in the development process of the internet protocol, and is the first widely deployed version of the protocol.

IPV 6: is an abbreviation of "Internet Protocol Version 6" (Internet Protocol Version 6) in english, and is the next-generation IP Protocol designed by the Internet Engineering Task Force (IETF) to replace IPV 4.

PPS, also known as Pulse Per Second (PPS Per Second), is a common abbreviation for Pulse Per Second (PPS Per Second), and is interpreted in chinese.

The IPV6 network is being expanded, however, many backend services still only support IPV4 access and do not have IPV6 access capability, so the front end provides IPV6 access, and the backend still uses IPV4 as a load balancing technology for entity services, which becomes a suitable transition technology. This technique is referred to as 6to4 load balancing. However, the 6to4 load balancing technology, like other load balancing technologies, has the risks of traffic centralization and pressure explosion load balancing, and also has the problems of single flow pps being too large, unbalanced cpu of the load balancer, and the like. Based on this, a load balancing technique is proposed to offload traffic from the load balancer, decentralize it, and provide a direct access mode from the source to the destination.

In the present specification, two node access methods are provided, and the present specification relates to a data transmission system, two node access devices, two node access apparatuses, a computing device, and a computer-readable storage medium, which are described in detail in the following embodiments one by one.

Referring to fig. 1, fig. 1 is a flowchart illustrating a node access method applied to a service node according to an embodiment of the present specification, which includes the following steps.

Step 102: and receiving request message data.

The request message data may be message data sent by a client, and may be understood as message data for communicating a certain service of a server.

In practical application, in a VPC scenario, the VPC scenario includes a request node, a service node, and a load balancing node, where the service node includes multiple service terminals of a service provider, the request node includes multiple clients of tenants, and the service terminal can receive request packet data from the clients and provide services according to the request packet data. The request message data may be sent by a client of any tenant, each tenant has its own address, and accordingly, each service provider also has its own address. During the first communication, the server needs to receive the message data of a certain client from the load balancing node, so as to obtain the address information of the client.

For example, request message data sent by the client is received from the LVS device.

The embodiment of the specification receives the message data from the load balancing ground for the first time, so that the address of the device where the matched client is located can be obtained, and the message data can be conveniently and directly sent to the client subsequently.

Step 104: generating response message data according to the request message data;

the response message data can be understood as the message data returned to the client.

In practical applications, after receiving a request from a client, a server needs to send a response message.

For example, response message data is generated according to request message data sent by a client received from the LVS device.

In one implementation, the generating response message data according to the request message data includes:

determining initial type request message data according to the target type request message data, and establishing an incoming address corresponding relation according to the initial type request message data;

and generating response message data of the target type according to the request message data of the initial type.

Wherein the target type may be an IPV4 type; the initial type may be an IPV6 type; the incoming address correspondence may be understood as the five-tuple information and the correspondence to the address to be changed.

For example, the IPV6 type request message data is determined according to the IPV4 type request message data, and an ingress address corresponding relationship is established according to quintuple information in the IPV6 type request message data, specifically, the ingress address corresponding relationship includes an ingress index and a cache, and the ingress index information is: IPV6+ (client ip) cip + (client port) cport + (transit node ip) vip + (transit node port) vport, and the incoming cache information is as follows: the converted source IP is virtual IP (fip); the converted target IP is a service end IP (rip); the translated source port is a virtual port (fport); the destination port of the conversion is a service port (rport). And then generates a response message according to the IPV6 type request message data.

In an implementation manner, the generating response packet data of the target type according to the request packet data of the initial type includes:

generating virtual request message data according to the corresponding relation of the incoming address of the request message data of the initial type, and establishing the corresponding relation of the outgoing address according to the virtual request message data;

and generating response message data of the target type according to the virtual request message data.

For example, the IPV6 type request message data is generated into IPV4 type virtual request message data according to the inbound address correspondence, and the outbound address correspondence is established, specifically, the outbound address correspondence includes outbound indexes and caches, and the outbound index information is: IPV4+ (service IP) rip + (service Port) rport + (virtual IP) fip + (virtual Port) fport; the outgoing cache information is: the converted source IP is an access service IP (vip); the converted destination IP is the IP address (cip) of the client; the converted source port is an access service port (vport); the destination port of the conversion is a request port (cport) of the access client; the network card address of a host (request node) where the access client is located is nc _ ip; and accessing the VPC tunnel id (VPC tunnel identification) of the client. The IPV6 type request message data is modified into IPV4 type virtual request message data, the IPV4 type virtual request message data is submitted to a kernel protocol stack and finally processed by a service process, the service process receives an IPV4 network request from a virtual IP, and the service process sends a response message to the network request.

In the embodiment of the present description, the virtual IPV4 address corresponding to the IPV6 type message data is established, so that the IPV6 type message data of the client can communicate with the IPV4 type server, and the universality is improved.

Step 106: and sending the response message data to a request node according to the first address corresponding relation, wherein the first address corresponding relation is established through the message data sent by a transit node, and the first address corresponding relation comprises the corresponding relation between the address of the request node and the address carried by the response message.

In practical application, the server may directly access the client by bypassing the transit node according to the established first address correspondence.

In an implementation manner, the sending the response packet data to the requesting node according to the first address mapping relationship includes:

generating the response message data of the initial type according to the corresponding relation of the outgoing address of the response message data of the target type;

and sending the response message data of the initial type to a corresponding request node according to address information carried in the response message data of the initial type.

The first address corresponding relationship may be understood as including the ingress address corresponding relationship and the egress address corresponding relationship.

For example, the response message is IPV4 type response message data, and the quintuple information is IPV4+ rip + rport + fip + fport. The response message sent by the service process reaches the kernel protocol stack, and is sent by the kernel protocol stack, before sending, the five-tuple information IPV4+ rip + rport + fip + fport of the protocol and the message are matched to the outgoing index, and the corresponding cache information is found. And carrying out IPV 4-to-IPV 6 processing on the message depending on the cache information, namely, changing the response message data of the IPV4 type into the response message data of the IPV6 type, wherein the response message data of the IPV6 type carries the network card address of the request node where the client is located and the VPC tunnel identifier where the access client is located, and sending the response message data of the IPV6 type to the corresponding request node through the VPC tunnel.

Referring to fig. 2, fig. 2 is a flowchart illustrating another node access method provided according to an embodiment of the present disclosure, which specifically includes the following steps.

Step 202: and forwarding the first request message data to the service node through the transit node to acquire response message data.

In practical application, the first message of the client needs to be forwarded to the LVS device to be matched with the service node.

In one implementation, the forwarding, by the transit node, the first request packet data to the service node includes:

under the condition that the first request message data of the initial type does not have the second address corresponding relation, analyzing the first request message data of the initial type to obtain the address of the transit node;

and establishing an address cache record according to the address of the transit node, and forwarding the initial type of first request message data to the transit node.

For example, a client accesses an LVS device (vip + vport), that is, sends message data with a message protocol of IPV6 protocol, and a quintuple information is IPV6+ cip + cport + vip + vport, establishes an index and a cache (second address correspondence) according to IPV6+ cip + cport + vip + vport, confirms that the network stream does not have a corresponding source record, and queries, based on vpctunelid + vip, that vip to be accessed is on the LVS device, and forwards the network message to the LVS device, in combination with the VPC information of the client.

In the embodiment of the description, the address cache record is established when the client sends the message to the server for the first time, so that the address cache record can be perfected to form the second address corresponding relation when the message returned by the server is received later, the server is directly accessed according to the second address corresponding relation, and the communication efficiency is improved.

In an implementation manner, the forwarding the first request packet data of the initial type to the transit node includes:

and converting the first request message data of the initial type into request message data of a target type, and sending the request message data of the target type to the transfer node.

For example: the IPV6 network message is further packaged into a vxlan message of IPV 4; the outer layer source address of the vxlan message is the network card address of the host where the client is located, the destination address of the vxlan message is the network card address of the LVS device, and the vxlan message can be forwarded to the LVS device in the network through a route.

Step 204: and establishing a second address corresponding relation between the address of the service node and the address of the transit node according to the address of the service node carried by the response message data.

In practical application, the client can determine the address of the server according to the message directly returned by the server.

In an implementation manner, the establishing a second address corresponding relationship between the address of the service node and the address of the transit node according to the address of the service node carried in the response packet data includes:

analyzing the initial type response message data to obtain the address of the service node;

and matching the address of the service node with the address of the transfer node in the address cache record, and generating the second address corresponding relation.

For example: and analyzing the received vxlan message directly returned by the server, wherein the quintuple information of the inner layer message is IPV6+ vip + vport + cip + cport at the moment, and matching the index and the cache established in the corresponding relation of the second address. And at the moment, the vxlan message source address is the network card address of the service node, so that the cached study source record is generated. I.e. the IP address of the serving node is stored in the cache. The client peels off the vxlan message and exposes the IPV6 message of the inner layer, namely the client receives the response message of the IPV6 type.

According to the address of the server carried in the response message, the embodiment of the specification can directly access the service node where the server is located according to the address, so that the load balancing pressure is reduced, and the communication efficiency is improved.

Step 206: and when second request message data needs to be sent, sending the second request message data to the service node according to the service node address corresponding to the address of the transfer node aimed at by the second request message data in the second address corresponding relation.

In practical application, after sending the first message, the client may directly send a message to the server according to the second address correspondence.

In an implementation manner, the sending, to the service node, the second request packet data according to the service node address corresponding to the address of the transit node to which the second request packet data is directed in the second address correspondence includes:

matching the address of the transfer node carried in the second request message data with the corresponding relation of the second address to obtain a corresponding service node address;

converting the second request message data into second request message data of a target type according to the service node address;

and sending the second request message data of the target type to the service node.

For example: the client continues to access the LVS device (vip + vport), and the quintuple information is still IPV6+ cip + cport + vip + vport. And the client accesses the index and the cache of the corresponding relationship of the second address according to the matching of the message of vip + vport and the IPV6+ cip + cport + vip + vport, confirms that the cache has a corresponding chemical source record, and forwards the request message data of the IPV6 type to the service node according to the chemical source record. The forwarding method is to encapsulate the IPV6 type request message data into an IPV4 type vxlan message, where an outer source address of the vxlan message is a network card address of a host (request node) where a client is located, and a destination address of the vxlan message is a network card address of a physical machine server (service node), and then the vxlan message can be forwarded to the physical machine server through a route in a network.

An embodiment of the present specification provides a node access method and a data transmission system, where the node access method includes: forwarding first request message data to a service node through a transit node to obtain response message data, establishing a second address corresponding relation between the address of the service node and the address of the transit node according to the address of the service node carried by the response message data, and sending second request message data to the service node according to the address of the service node corresponding to the address of the transit node targeted by the second request message data in the second address corresponding relation when the second request message data needs to be sent. The method comprises the steps that a transfer node forwards first request message data to a service node to obtain response message data, and the corresponding relation between the address of the service node and the second address of the transfer node is established according to the address of the service node carried by the response message data, so that transfer equipment is bypassed when the message is sent again, the load of the transfer equipment is reduced, and load balance is realized.

Referring to fig. 3a, fig. 3a is a schematic diagram illustrating a data transmission system provided according to an embodiment of the present specification, where the data transmission system includes a requesting node, a transit node, and a serving node.

The request node is configured to convert the initial type of request message data into target type of request message data and send the target type of request message data to the transit node;

the transit node is configured to send the request message data of the target type to the service node according to a scheduling rule;

the service node is configured to generate response message data of the target type according to the request message data of the target type, establish a first address corresponding relation, and

the request node is configured to establish a second address corresponding relationship according to the initial type response message data, and access the service node according to the second address corresponding relationship.

In an implementation manner, the request node includes a request message hijack module and a client, the transit node is an LVS device, and the service node includes a response message hijack module and a kernel protocol stack, where the request message hijack module has a learning source capability and is responsible for determining to which LVS device or service node a message of the client should be sent. That is, in this embodiment, the request packet hijacking module determines whether the network packet accessed by the client is sent to the LVS device or the service node. The LVS equipment is responsible for receiving network messages accessed by the client, forwarding the messages to the service node, and informing the service node of information of the client of the access source and information of the access target. The response message hijacking module is arranged in a kernel module in the service node, registers hook (hijacking) points on a path for receiving and sending messages by a kernel protocol stack, hijacks each data packet, and processes the data packets: the network message hijacking module is responsible for analyzing the network message forwarded by the LVS, analyzing the information of the access source, converting the IPV6 message into an IPV4 message, submitting the IPV4 message to a kernel protocol stack and further transferring the service process, and converting the IPV4 message responded by the service process into an IPV6 message, and further, the response message hijacking module is responsible for directly sending the message responded by the service process to the request node of the access source.

Further, referring to fig. 3b, fig. 3b shows a timing diagram of a data transmission system provided according to an embodiment of the present specification. When connection is performed for the first time, a request message hijacking module in a request node packages an IPV6 request message into an IPV4 request message (such as a vxlan protocol) in a VPC tunnel format, the network card address of the request node is carried in the IPV4 request message in the VPC tunnel format, and then the IPV4 request message is sent to a corresponding transit node.

The transit node selects a proper service node (such as a service node with low communication delay) according to the scheduling rule, adds information such as VPC tunnel identification in the IPV4 request message, and sends the IPV4 request message to the corresponding service node.

The method comprises the steps that firstly, an IPV4 request message is unpacked to obtain an internal IPV6 request message, virtual IPV4 quintuple information is generated according to the quintuple information of the IPV6 request message, the corresponding relation between the quintuple information in the IPV6 request message and the virtual IPV4 quintuple information is recorded, namely the incoming address corresponding relation is obtained, the IPV6 request message is converted into a virtual IPV4 request message according to the incoming address corresponding relation, the outgoing address corresponding relation is established, the outgoing address corresponding relation comprises the virtual IPV4 quintuple information and the quintuple information in the IPV6 request message, the address of a request node where a client is located and a VPC tunnel identifier used by a visit request node, namely a network card can determine which VPC tunnel is passed through by the outgoing address corresponding relation, and the message data are sent to which request node. Then, the virtual IPV4 request message is sent to the kernel protocol stack, the kernel protocol stack further transfers the virtual IPV4 request message to the service process, the service process generates an IPV4 response message for the virtual IPV4 request message, the response message hijacking module hijacks the IPV4 response message, and converts the IPV4 response message into an IPV6 response message through an outbound address correspondence, and the IPV6 response message needs to be encapsulated as a VPC tunnel format message (such as a vxlan protocol), so that the VPC tunnel can be selected through a corresponding VPC tunnel identifier to send the IPV6 response message to the request node. It should be noted that the first address corresponding relationship includes an outbound address corresponding relationship and an outbound address corresponding relationship.

Under the condition that the request message hijacking module in the request node receives the IPV6 response message in the VPC tunnel format, the address information of the service node can be obtained from the IPV6 response message in the VPC tunnel format, so that a second address corresponding relation is generated, and the second knowledge corresponding relation comprises quintuple information of the IPV6 request message of the client and the network card address of the service node in the communication process.

When the client sends a new IPV6 request message again, the request message hijacking module determines whether the quintuple information of the new IPV6 request message has a corresponding service node address in the second address correspondence, and if the corresponding service node address exists, directly encapsulates the new IPV6 request message into an IPV4 request message and forwards the IPV4 request message to the corresponding service node.

Further, the service node is configured to monitor the number of addresses in the first address correspondence, and send alarm information to a management and control end when the number of addresses exceeds a preset number threshold.

The number of addresses may be understood as the number of quintuple information.

In practical application, after a service node is connected for a period of time, the number of caches of five-tuple information in the first address corresponding relationship of the service node increases, so the computational pressure of the service node increases, and after a certain number of connections is reached, the corresponding relationship between the service node and some request nodes needs to be redistributed.

In a possible implementation manner, the preset number threshold may be 100, and if the number of the five-tuple information buffers in the preset first address correspondence exceeds 100, sending alarm information to the control end, so that the worker adjusts the first address correspondence.

In addition, it may be determined which caches are to be cleared according to the usage time, and when the number of caches of the quintuple information in the preset first address correspondence exceeds 100, it is determined whether the last usage time of the quintuple information in the first address correspondence is last, and if the number of caches of the quintuple information in the preset first address correspondence exceeds the set time threshold, the cache of the quintuple information is cleared, and further, it may be determined whether the number of caches of the quintuple information is fixed under the condition of the time threshold, for example, when the number of caches of the quintuple information in the preset first address correspondence exceeds 100, the caches of the quintuple information which is not used exceeding the set time threshold are arranged according to the last usage time, and 20 caches of the quintuple information which is not used exceeding the set time threshold are cleared.

An embodiment of the present specification provides a data transmission system, including: the system comprises a request node, a transfer node and a service node, wherein the request node converts request message data of an initial type into request message data of a target type and sends the request message data of the target type to the transfer node; the transfer node of the data transmission system sends the request message data of the target type to the service node according to a scheduling rule; the service node generates response message data of a target type according to the request message data of the target type, establishes a first address corresponding relation, converts the response message data of the target type into response message data of an initial type according to the first address corresponding relation, and sends the response message data of the initial type to the request node; and the request node establishes a second address corresponding relation according to the response message data of the initial type and accesses the service node according to the second address corresponding relation. The communication between the request node and the service node can be realized to bypass the transfer equipment, so that the load of the transfer equipment is reduced, and the load balance is realized.

The following will further describe the node access method provided in this specification by taking an application of the node access method in a distributed system as an example, with reference to fig. 4. Fig. 4 is a flowchart illustrating a processing procedure of a node access method according to an embodiment of the present specification, and specifically includes the following steps.

Step 402: the request node forwards the first request message data to the service node through the transfer node.

Step 404: the service node receives the first request message data.

Step 406: and the service node generates response message data according to the first request message data.

Step 408: and the service node sends the response message data to the request node according to the first address corresponding relation.

Step 410: and the request node establishes a second address corresponding relation between the address of the service node and the address of the transfer node according to the address of the service node carried by the response message data.

Step 412: when the request node needs to send second request message data, the request node sends the second request message data to the service node according to the service node address corresponding to the address of the transfer node corresponding to the second request message data in the second address corresponding relation.

The embodiments of the present description implement that communication between a request node and a service node bypasses a relay device, thereby reducing load of the relay device and implementing load balancing.

Corresponding to the above method embodiments, the present specification further provides an embodiment of a node access device, where the device includes:

a receiving module configured to receive request message data;

In one possible implementation, the generating module is further configured to:

In one possible implementation, the access module is further configured to:

An embodiment of the present specification provides a node access apparatus, where the node access apparatus includes: receiving request message data, generating response message data according to the request message data, and sending the response message data to a request node according to the first address corresponding relation, wherein the first address corresponding relation is established through the message data sent by a transfer node, and the first address corresponding relation comprises the corresponding relation between the address of the request node and the address carried by the response message. Response message data are generated according to the received request message data, and are directly sent back to the request node according to the first address corresponding relation, so that the transfer equipment is bypassed, the load of the transfer equipment is reduced, and the load balance is realized.

Corresponding to the above method embodiment, the present specification further provides another embodiment of a node access device, where the device includes:

In one possible implementation, the sending module is further configured to:

In one possible implementation, the relationship establishing module is further configured to:

analyzing the response message data of the initial type to obtain the address of the service node;

In one possible implementation, the access module is further configured to:

An embodiment of the present specification provides a node access device, including: forwarding first request message data to a service node through a transit node to obtain response message data, establishing a second address corresponding relation between the address of the service node and the address of the transit node according to the address of the service node carried by the response message data, and sending second request message data to the service node according to the address of the service node corresponding to the address of the transit node targeted by the second request message data in the second address corresponding relation when the second request message data needs to be sent. The method comprises the steps that a transfer node forwards first request message data to a service node to obtain response message data, and the corresponding relation between the address of the service node and the second address of the transfer node is established according to the address of the service node carried by the response message data, so that transfer equipment is bypassed when the message is sent again, the load of the transfer equipment is reduced, and load balance is realized.

Corresponding to the above method embodiment, the present specification further provides an embodiment of a node access apparatus, and fig. 5 illustrates a schematic structural diagram of a node access apparatus provided in an embodiment of the present specification. As shown in fig. 5, the apparatus includes:

a receiving module 502 configured to receive request message data;

a generating module 504 configured to generate response message data according to the request message data;

the access module 506 is configured to send the response packet data to the request node according to the first address corresponding relationship, where the first address corresponding relationship is established by the request packet data sent by the transit node, and the first address corresponding relationship includes a corresponding relationship between an address of the request node and an address carried in the response packet.

In one possible implementation, the generating module 504 is further configured to:

In one possible implementation, the accessing module 506 is further configured to:

Corresponding to the above method embodiment, the present specification further provides another node access apparatus embodiment, and fig. 6 shows a schematic structural diagram of another node access apparatus provided in an embodiment of the present specification. As shown in fig. 6, the apparatus includes:

a sending module 602, configured to forward the first request packet data to the service node through the transit node to obtain response packet data;

a relationship establishing module 604, configured to establish a second address corresponding relationship between the address of the service node and the address of the transit node according to the address of the service node carried in the response packet data;

the access module 606 is configured to, when second request packet data needs to be sent, send the second request packet data to the service node according to a service node address corresponding to the address of the relay node to which the second request packet data is directed in the second address correspondence.

In one possible implementation, the sending module 602 is further configured to:

In one possible implementation, the relationship establishing module 604 is further configured to:

In one possible implementation, the accessing module 606 is further configured to:

An embodiment of the present specification provides a node access apparatus, including: forwarding first request message data to a service node through a transit node to obtain response message data, establishing a second address corresponding relation between the address of the service node and the address of the transit node according to the address of the service node carried by the response message data, and sending second request message data to the service node according to the address of the service node corresponding to the address of the transit node aimed at by the second request message data in the second address corresponding relation when the second request message data needs to be sent. The method comprises the steps that a transfer node forwards first request message data to a service node to obtain response message data, and the corresponding relation between the address of the service node and the second address of the transfer node is established according to the address of the service node carried by the response message data, so that transfer equipment is bypassed when the message is sent again, the load of the transfer equipment is reduced, and load balance is realized.

The foregoing is an exemplary scheme of a node access apparatus according to this embodiment. It should be noted that the technical solution of the node access apparatus and the technical solution of the node access method belong to the same concept, and details that are not described in detail in the technical solution of the node access apparatus can be referred to the description of the technical solution of the node access method.

FIG. 7 illustrates a block diagram of a computing device 700 provided in accordance with one embodiment of the present description. The components of the computing device 700 include, but are not limited to, memory 710 and a processor 720. Processor 720 is coupled to memory 710 via bus 730, and database 750 is used to store data.

Computing device 700 also includes access device 740, access device 740 enabling computing device 700 to communicate via one or more networks 760. Examples of such networks include the Public Switched Telephone Network (PSTN), a Local Area Network (LAN), a Wide Area Network (WAN), a Personal Area Network (PAN), or a combination of communication networks such as the internet. Access device 740 may include one or more of any type of network interface, e.g., a Network Interface Card (NIC), wired or wireless, such as an IEEE802.11 Wireless Local Area Network (WLAN) wireless interface, a worldwide interoperability for microwave access (Wi-MAX) interface, an ethernet interface, a Universal Serial Bus (USB) interface, a cellular network interface, a bluetooth interface, a Near Field Communication (NFC) interface, and so forth.

In one embodiment of the present description, the above-described components of computing device 700, as well as other components not shown in FIG. 7, may also be connected to each other, such as by a bus. It should be understood that the block diagram of the computing device architecture shown in FIG. 7 is for purposes of example only and is not limiting as to the scope of the present description. Those skilled in the art may add or replace other components as desired.

Computing device 700 may be any type of stationary or mobile computing device, including a mobile computer or mobile computing device (e.g., tablet, personal digital assistant, laptop, notebook, netbook, etc.), mobile phone (e.g., smartphone), wearable computing device (e.g., smartwatch, smartglasses, etc.), or other type of mobile device, or a stationary computing device such as a desktop computer or PC. Computing device 700 may also be a mobile or stationary server.

Wherein the processor 720 is configured to execute computer-executable instructions that, when executed by the processor, implement the steps of the node access method described above.

The above is an illustrative scheme of a computing device of the present embodiment. It should be noted that the technical solution of the computing device and the technical solution of the node access method described above belong to the same concept, and details that are not described in detail in the technical solution of the computing device can be referred to the description of the technical solution of the node access method described above.

An embodiment of the present specification also provides a computer-readable storage medium storing computer-executable instructions that, when executed by a processor, implement the steps of the above-described node access method.

The above is an illustrative scheme of a computer-readable storage medium of the present embodiment. It should be noted that the technical solution of the storage medium belongs to the same concept as the technical solution of the above-mentioned node access method, and details that are not described in detail in the technical solution of the storage medium can be referred to the description of the technical solution of the above-mentioned node access method.

An embodiment of the present specification further provides a computer program, wherein when the computer program is executed in a computer, the computer is caused to execute the steps of the above node access method.

The above is an illustrative scheme of a computer program of the present embodiment. It should be noted that the technical solution of the computer program and the technical solution of the above-mentioned node access method belong to the same concept, and details that are not described in detail in the technical solution of the computer program can be referred to the description of the technical solution of the above-mentioned node access method.

The foregoing description has been directed to specific embodiments of this disclosure. Other embodiments are within the scope of the following claims. In some cases, the actions or steps recited in the claims can be performed in a different order than in the embodiments and still achieve desirable results. In addition, the processes depicted in the accompanying figures do not necessarily require the particular order shown, or sequential order, to achieve desirable results. In some embodiments, multitasking and parallel processing may also be possible or may be advantageous.

The computer instructions comprise computer program code which may be in the form of source code, object code, an executable file or some intermediate form, or the like. The computer-readable medium may include: any entity or device capable of carrying the computer program code, recording medium, usb disk, removable hard disk, magnetic disk, optical disk, computer Memory, Read-Only Memory (ROM), Random Access Memory (RAM), electrical carrier wave signals, telecommunications signals, software distribution medium, and the like. It should be noted that the computer readable medium may contain content that is subject to appropriate increase or decrease as required by legislation and patent practice in jurisdictions, for example, in some jurisdictions, computer readable media does not include electrical carrier signals and telecommunications signals as is required by legislation and patent practice.

It should be noted that, for the sake of simplicity, the foregoing method embodiments are described as a series of acts, but those skilled in the art should understand that the present embodiment is not limited by the described acts, because some steps may be performed in other sequences or simultaneously according to the present embodiment. Further, those skilled in the art should also appreciate that the embodiments described in this specification are preferred embodiments and that acts and modules referred to are not necessarily required for an embodiment of the specification.

In the above embodiments, the descriptions of the respective embodiments have respective emphasis, and for parts that are not described in detail in a certain embodiment, reference may be made to related descriptions of other embodiments.

The preferred embodiments of the present specification disclosed above are intended only to aid in the description of the specification. Alternative embodiments are not exhaustive and do not limit the invention to the precise embodiments described. Obviously, many modifications and variations are possible in light of the above teaching. The embodiments were chosen and described in order to best explain the principles of the embodiments and the practical application, to thereby enable others skilled in the art to best understand and utilize the embodiments. The specification is limited only by the claims and their full scope and equivalents.

Claims

1. A node access method is applied to a service node in a distributed system, and comprises the following steps:

receiving request message data;

generating response message data according to the request message data;

and sending the response message data to a request node according to a first address corresponding relation, wherein the first address corresponding relation is established through the message data sent by a transit node, and the first address corresponding relation comprises the corresponding relation between the address of the request node and the address carried by the response message.

2. The method of claim 1, wherein generating response message data from the request message data comprises:

3. The method of claim 2, wherein generating the response message data of the target type from the request message data of the initial type comprises:

4. The method of claim 3, wherein sending the response packet data to the requesting node according to the first address mapping relationship comprises:

5. A node access method is applied to a requesting node in a distributed system, and comprises the following steps:

6. The method of claim 5, wherein forwarding the first request packet data to the service node via the transit node comprises:

7. The method of claim 6, wherein forwarding the request message data of the initial type to the transit node comprises:

8. The method according to claim 6, wherein the establishing a second address mapping relationship between the address of the service node and the address of the transit node according to the address of the service node carried in the response packet data includes:

9. The method according to claim 5, wherein the sending the second request packet data to the service node according to the service node address corresponding to the address of the transit node to which the second request packet data is directed in the second address correspondence relationship, includes:

10. A data transmission system comprises a request node, a transfer node and a service node;

11. The system of claim 10, further comprising:

the service node is configured to monitor the number of addresses in the first address corresponding relation, and send alarm information to a management and control end when the number of addresses exceeds a preset number threshold.

12. A data transmission device comprising:

a receiving module configured to receive request message data;

and the access module is configured to send the response message data to a request node according to a first address corresponding relation, wherein the first address corresponding relation is established through the message data sent by the transit node, and the first address corresponding relation comprises a corresponding relation between the address of the request node and the address carried by the response message.

13. A data transmission device comprising:

14. A computing device, comprising:

a memory and a processor;

the memory is for storing computer-executable instructions, and the processor is for executing the computer-executable instructions, which when executed by the processor, perform the steps of the node access method of any of claims 1 to 9.

15. A computer readable storage medium storing computer executable instructions which, when executed by a processor, perform the steps of the node access method of any one of claims 1 to 9.