CN115622938A - Computing power service processing method, device and system - Google Patents

Abstract

Embodiments of the present invention provide a computing power service processing method, device, and system, which relate to the field of communication technology. The system includes at least one computing power service node, at least one computing power edge node, and at least one routing node; each computing power edge node, used to receive the computing power service request message sent by the terminal device, and send a multicast query message to the computing power service node in the multicast group that serves as the multicast source; each computing power service node is used to respond Based on the target multicast query message from the target computing power edge node, send a query response message to the target computing power edge node, and the query response message includes the computing power resource information of the computing power server connected to the computing power service node; A computing power edge node is also used to select a target computing power server based on the received computing power resource information of each computing power server, and forward the computing power service request message to the target computing power server. It can simplify the deployment process and reduce the deployment cost.

Description

Computing power service processing method, device and system

technical field

The present invention relates to the field of communication technologies, in particular to a computing power service processing method, device and system.

Background technique

At present, the main requirement for deploying a computing power network is to dispatch the user's business to the most suitable computing power node based on the computing power resource information of each computing power node in the computing power network that can provide computing power services. Therefore, the control plane of the computing power network needs to dynamically perceive the computing power resource information in the computing power network, so as to determine the forwarding path of each computing power service request message.

According to the collection of computing resource information, the arrangement of forwarding paths, and the distribution mechanisms of forwarding paths, the deployment methods of the control plane of the computing power network can be divided into three types: centralized, distributed, and hybrid. In a centralized computing power network, the controller can arrange the forwarding path according to the application requirements, combining the computing power resource information and network status of the entire network. In the distributed computing power network, each node needs to flood the local computing power resources, network status and routing through the distributed routing protocol, and then the routing devices in the distributed computing power network can Computing resources calculate the forwarding path. The implementation of the hybrid computing power network is a combination of the centralized computing power network and the distributed computing power network.

The centralized deployment method has higher requirements on the controller, and the development workload and cost are higher. If the distributed deployment method is adopted, all the devices in the entire network need to be adjusted to devices capable of flooding and notifying computing power resources, and the existing devices in the network need to be greatly adjusted. The hybrid deployment method can alleviate the above problems to a certain extent, but there are still problems of complex deployment.

Contents of the invention

The purpose of the embodiments of the present invention is to provide a computing power service processing method, device, and system to solve the problem of complex deployment of computing power service processing systems. The specific technical scheme is as follows:

In the first aspect, an embodiment of the present application provides a computing power service processing system, the system includes at least one computing power service node, at least one computing power edge node, and at least one routing node, and each computing power service node is connected to at least one Computing server;

Each computing power edge node is used to receive the computing power service request message sent by the terminal device, and send a multicast query message to the computing power service node in the multicast group that serves as the multicast source. Each multicast group The leaf nodes in the corresponding multicast tree are computing service nodes, the non-leaf nodes are routing nodes, and the root nodes are computing power edge nodes;

Each computing power service node is configured to send a query response message to the target computing power edge node in response to a target multicast query message from the target computing power edge node, and the query response message includes the computing power The computing resource information of the computing server connected to the service node;

Each computing power edge node is further configured to select a target computing power server based on the received computing power resource information of each computing power server, and forward the computing power service request message to the target computing power server.

Optionally, the computing power service request message is used to request a computing power service of a specified service type;

Each computing power edge node is specifically used to search for a specified multicast group that supports the specified service type from multiple multicast groups that it serves as a multicast source after receiving a computing power service request message, and send The computing power service node in the specified multicast group sends a multicast query message.

Optionally, the target multicast query message is used to request to query computing power resource information of a specified service type;

Each computing power service node is specifically used to respond to the received target multicast query message, select the designated computing power server that supports the specified service type from the connected computing power servers, and provide the target computing power The edge node sends the query response message, and the query response message includes the computing power resource information of the designated computing power server.

Optionally, the multicast query message is used to request to query computing power resource information of a specified service type;

Each computing power service node is specifically used to respond to the received target multicast query message, and select the designated computing power server that supports the specified service type and the remaining computing power resources meet the preset conditions from the connected computing power servers. The power server sends the query response message to the target computing power edge node, and the query response message includes the computing power resource information of the designated computing power server.

optional,

Each computing power service node is also used to periodically obtain the computing power resource information of each computing power server connected to itself.

Optionally, the system also includes a sink node;

Each computing power service node is further configured to send registration information to the aggregation node when accessing the computing power service processing system, and the registration information includes the service of the computing power server connected to the computing power service node type;

The converging node is configured to add the target computing power service node to the service carried in the target computing power service node based on the service type carried in the target computing power service node in response to the target registration information from the target computing power service node. type matching target multicast group, and update the multicast tree corresponding to the target multicast group.

In the second aspect, the embodiment of the present application provides a computing power service processing method, which is applied to any computing power edge node in the computing power service processing system, and the computing power service processing system further includes at least one computing power service node and At least one routing node, each computing power service node is connected to at least one computing power server; the method includes:

Receive the computing power service request message sent by the terminal device;

Send a multicast query message to the computing power service node in the multicast group that serves as the multicast source. The leaf nodes in the multicast tree corresponding to the multicast group are all computing power service nodes, and the non-leaf nodes are routing nodes. , the root node is the computing power edge node;

receiving a query response message sent by a computing power service node in the multicast group, where the query response message includes computing power resource information of a computing power server connected to the computing power service node;

Based on the received computing power resource information of each computing power server, a target computing power server is selected, and the computing power service request message is forwarded to the target computing power server.

Optionally, the sending the multicast query message to the computing power service node in the multicast group includes:

Finding a specified multicast group that supports the specified service type from multiple multicast groups;

Sending the multicast query message to the computing service nodes in the specified multicast group.

In the third aspect, the embodiment of the present application provides a computing power service processing method, which is applied to any computing power service node in the computing power service processing system, and the computing power service processing system further includes at least one computing power edge node and At least one routing node, each computing power service node is connected to at least one computing power server; the computing power service node is a leaf node of the multicast tree corresponding to the multicast group, and the non-leaf nodes of the multicast tree are routing nodes , the root node is a computing power edge node; the method includes:

receiving a multicast query message sent by the target computing power edge node, where the multicast query message is sent by the target computing power edge node after receiving the computing power service request message of the terminal device;

In response to the multicast query message, send a query response message to the target computing power edge node, the query response message includes computing power resource information of the computing power server connected to the computing power service node, to The target computing power edge node selects a target computing power server based on the received computing power resource information of each computing power server, and forwards the computing power service request message to the target computing power server.

Optionally, the multicast query message is used to request to query computing power resource information of a specified service type, and the query response message includes computing power resource information of a specified computing power server supporting the specified service type;

Before sending the query response message to the target computing power edge node, the method further includes:

From the connected computing power servers, select a designated computing power server that supports the specified service type, and obtain computing power resource information of the designated computing power server.

Optionally, the multicast query message is used to request to query computing power resource information of a specified service type, and the query response message includes specifying that the specified service type is supported and the remaining computing power resources meet preset conditions. Resource information of computing power server;

Before sending the query response message to the target computing power edge node, the method further includes:

From the servers connected to itself, select a designated computing power server that supports the specified service type and whose remaining computing power resources meet the preset conditions, and obtain computing power resource information of the designated computing power server.

In the fourth aspect, the embodiment of the present application provides a computing power service processing device, which is applied to any computing power edge node in the computing power service processing system, and the computing power service processing system further includes at least one computing power service node and At least one routing node, each computing power service node is connected to at least one computing power server; the device includes:

The receiving module is used to receive the computing power service request message sent by the terminal device;

A sending module, configured to send a multicast query message to a computing power service node in a multicast group with the computing power edge node as a multicast source, and the leaf nodes in the multicast tree corresponding to the multicast group are computing Power service nodes, non-leaf nodes are routing nodes, and the root node is the computing power edge node;

The receiving module is further configured to receive a query response message sent by a computing power service node in the multicast group, where the query response message includes computing power resource information of a computing power server connected to the computing power service node;

A selection module, configured to select a target computing power server based on the computing power resource information of each computing power server received by the receiving module;

The sending module is further configured to forward the computing power service request message to the target computing power server selected by the selecting module.

Optionally, the sending module is specifically used for:

Finding a specified multicast group that supports the specified service type from multiple multicast groups;

Sending the multicast query message to the computing service nodes in the specified multicast group.

In the fifth aspect, the embodiment of the present application provides a computing power service processing device, which is applied to any computing power service node in the computing power service processing system, and the computing power service processing system further includes at least one computing power edge node and At least one routing node, each computing power service node is connected to at least one computing power server; the computing power service node is a leaf node of the multicast tree corresponding to the multicast group, and the non-leaf nodes of the multicast tree are routing nodes , the root node is a computing power edge node; the device includes:

The receiving module is configured to receive a multicast query message sent by the target computing power edge node, the multicast query message is sent after the target computing power edge node receives the computing power service request message of the terminal device;

A sending module, configured to send a query response message to the target computing power edge node in response to the multicast query message, where the query response message includes the computing power of the computing power server connected to the computing power service node. Power resource information, so that the target computing power edge node selects a target computing power server based on the received computing power resource information of each computing power server, and forwards the computing power service request message to the target computing power server .

Optionally, the multicast query message is used to request to query computing power resource information of a specified service type, and the query response message includes computing power resource information of a specified computing power server supporting the specified service type;

The device also includes:

The acquisition module is configured to filter out a designated computing power server that supports the specified service type from the connected computing power servers, and obtain computing power resource information of the designated computing power server.

Optionally, the multicast query message is used to request to query computing power resource information of a specified service type, and the query response message includes specifying that the specified service type is supported and the remaining computing power resources meet preset conditions. Resource information of computing power server;

The device also includes:

The acquisition module is configured to select, from the servers connected to itself, a designated computing power server that supports the designated service type and whose remaining computing power resources meet preset conditions, and obtain computing power resource information of the designated computing power server.

In a sixth aspect, an embodiment of the present application provides an electronic device, including a processor, a communication interface, a memory, and a communication bus, wherein the processor, the communication interface, and the memory complete communication with each other through the communication bus;

memory for storing computer programs;

The processor is configured to implement the method steps described in any one of the second aspect or the third aspect when executing the program stored in the memory.

In the seventh aspect, the embodiment of the present application also provides a computer-readable storage medium, where a computer program is stored in the computer-readable storage medium, and when the computer program is executed by a processor, any one of the second aspect or the third aspect is implemented. The method steps described.

In an eighth aspect, an embodiment of the present application provides a computer program product, including a computer program, and when the computer program is executed by a processor, the method according to any one of the second aspect or the third aspect is implemented.

Using the embodiment of this application, after receiving the computing power service request message sent by the terminal device, the computing power edge node can send a multicast query message to the computing power service node in the multicast group that serves as the multicast source, so that The computing power resource information of the computing power server connected to each computing power service node is obtained, so that the controller does not need to uniformly receive the computing power resources of each computing power service node, which reduces the requirements for the controller. Moreover, each node in the computing power service processing system does not need to flood and notify each other of computing power resources. In this way, there is no need to require all nodes in the computing power service processing system to support computing power network services. In the embodiment of this application, only computing power edge nodes and computing power service nodes need to support computing power network services, and the rest of the routing nodes only perform ordinary message forwarding, so when deploying computing power service processing systems, there is no need to greatly adjust a large number of routes Nodes, you only need to deploy individual edge nodes as devices that support computing power network services, which can reduce the development workload, simplify the deployment process, and reduce deployment costs.

Of course, implementing any product or method of the present invention does not necessarily need to achieve all the above-mentioned advantages at the same time.

Description of drawings

In order to more clearly illustrate the technical solutions in the embodiments of the present invention or the prior art, the following will briefly introduce the drawings that need to be used in the description of the embodiments or the prior art. Obviously, the accompanying drawings in the following description are only These are some embodiments of the present invention, and those skilled in the art can also obtain other embodiments according to these drawings.

FIG. 1 is a schematic structural diagram of a centralized deployment computing power network provided in the related art;

FIG. 2 is a schematic structural diagram of a distributed computing power network provided in the related art;

FIG. 3 is a schematic structural diagram of a hybrid deployment computing power network provided in the related art;

FIG. 4 is a schematic structural diagram of a computing power service processing system provided by an embodiment of the present application;

Fig. 5 is an exemplary schematic diagram of a computing power service processing system provided by an embodiment of the present application;

Fig. 6 is a flow chart of a computing power service processing method provided by an embodiment of the present application;

Fig. 7 is a flow chart of another computing power service processing method provided by the embodiment of the present application;

FIG. 8 is a schematic structural diagram of a computing power service processing device provided by an embodiment of the present application;

Fig. 9 is a schematic structural diagram of another computing power service processing device provided by the embodiment of the present application;

FIG. 10 is a schematic structural diagram of a network device provided by an embodiment of the present application.

detailed description

The following will clearly and completely describe the technical solutions in the embodiments of the present invention with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are only some of the embodiments of the present invention, not all of them. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art based on the present application belong to the protection scope of the present invention.

For ease of understanding, firstly, related concepts involved in the embodiments of the present application are explained.

Computing power network means that the network infrastructure has the ability to perceive, schedule and orchestrate computing power resources, and can provide new information and communication technology (ICT) integrated services of network, computing and storage at the network layer. Network-based new generation technology architecture and business operation system.

In the 5G and post-5G era, in order to respond to business computing needs more quickly and quickly, computing power resources are gradually sinking to the edge close to users, forming a new situation of heterogeneous, diverse and distributed computing power deployment. With the help of network infrastructure, operators can conduct unified dynamic management, scheduling, and orchestration of multi-level distributed computing power resources to realize the advantages of virtual computing power pooling of network-wide resources.

As shown in Figure 1, Figure 1 is a computing power network deployed by a centralized control plane in the related art. Figure 1 schematically shows the network architecture of three regions. All include the computing power resource layer, the network resource layer and the IP layer (IP layer), and also include applications (Application, APP), computer resources (computer resources), and optionally, some specific service functions, such as graph Function 1 (function1) shown in 1.

In Figure 1, the computing power resource layer and the network resource layer need to report computing power resource information and network status information to the controller, and the IP layer needs to report routing information to the controller, and then the controller and orchestrator can combine the whole Network computing resource information, network status information and routing information, and arrange forwarding paths.

As shown in Figure 2, Figure 2 is a computing power network deployed in a distributed control plane in the related art. Figure 2 exemplarily shows the network structure of three regions. There is no need to deploy centralized orchestrators and controllers in the network. Computing resource layers can flood each other to release computing resources, network resource layers can flood each other to release network status information, and IP layers can flood each other to release routes information. Specifically, it can be advertised through an IGP protocol within a network domain or through a BGP protocol between network domains.

Furthermore, the routing device in the distributed computing power network can calculate the forwarding path based on the learned computing power resource information, network status information and routing information of the entire network.

As shown in Figure 3, Figure 3 is a computing power network deployed in a hybrid control plane in the related art. The third column on the side is another network domain, and each node can perform flood publishing in the network domain, and transmit information between network domains through the controller and orchestrator.

The above three computing power networks all have complex deployment problems. For example, in a centralized computing power network, a lot of development work needs to be done on the controller. In a distributed computing power network, all nodes need to support computing power network services. And it is necessary to configure an interactive protocol for flooding and publishing information for all nodes, and the development workload is huge. Distributed computing power network alleviates the above problems, but it is still not completely solved.

In order to solve the above problems, an embodiment of the present application provides a computing power service processing system, as shown in FIG. 4 , the system includes at least one computing power service node 41, at least one computing power edge node 42, and at least one routing node 43, Each computing power service node 41 is connected to at least one computing power server 44 . It should be noted that FIG. 4 is only an example, and the number of devices in actual implementation is not limited thereto.

Among them, the computing power service node 41 can be an edge routing device on the service side, and the computing power edge node 42 is an edge routing device on the terminal side, and both the computing power service node 41 and the computing power edge node 42 are routing devices that support computing power network services , the routing node 43 is an ordinary routing device, which may not support computing power network services. The computing power server 44 can be a physical server, or a distributed computing power service unit.

Each computing power edge node 42 is used to receive the computing power service request message sent by the terminal device, and send a multicast query message to the computing power service node 41 in the multicast group that serves as the multicast source, and the multicast group The leaf nodes in the corresponding multicast tree are computing power service nodes 41 , the non-leaf nodes are routing nodes 43 , and the root nodes are computing power edge nodes 42 .

The multicast tree can also be called a multicast forwarding tree, which is used to represent the topological relationship between the multicast source and the multicast group members in the multicast group. The multicast members in the multicast group are computing power service nodes 41, so The leaf nodes in the multicast tree are computing power service nodes 41 . It can be understood that the multicast query message sent by the computing power edge node 42 can be transmitted to the computing power service node 41 through the routing node 43 along the multicast tree.

Wherein, the computing power service request message is a message sent by the terminal device for requesting provision of computing power service. As an example, the computing power service may be a game service. The multicast query message is used to request to query the computing power resource information of the computing power server 44 connected to each computing power service node 41 in the multicast group.

Each computing power service node 41 is configured to send a query response message to the target computing power edge node in response to the target multicast query message from the target computing power edge node, and the query response message includes the computing power service node 41 The computing power resource information of the connected computing power server 44.

Wherein, the computing power resource information includes any one or more items of CPU computing capability information, CPU occupancy rate, and storage capacity of the computing power server, and may also include other information used to represent computing power capabilities. Not limited.

In the embodiment of the present application, the target computing power edge node is the computing power edge node 42 that sends the target multicast query message in the computing power service processing system. There may be multiple computing power service nodes 41 in the multicast group that receive the multicast query message, and each computing power service node 41 that receives the multicast query message can send the computing power service node 41 for the received multicast query message. The edge node 42 sends a query response message. The query response message is a unicast message.

Each computing power edge node 42 is further configured to select a target computing power server based on the received computing power resource information of each computing power server 44, and forward the computing power service request message to the target computing power server.

It can be understood that the computing power edge node 42 can forward the received computing power service request message along the forwarding path from the computing power edge node 42 to the computing power service node 41 connected to the target computing power server, and then the computing power The service node 41 may forward the computing power service request message to the target computing power server. The target computing power server can provide computing power service for the terminal device based on the computing power service request message.

Using the embodiment of the present application, in the computing power service processing system, after receiving the computing power service request message sent by the terminal device, the computing power edge node can send the computing power service node in the multicast group as the multicast source to itself Send a multicast query message to obtain the computing power resource information of the computing power server connected to each computing power service node, and then there is no need for the controller to uniformly receive the computing power resources of each computing power service node, reducing the requirements for the controller . Moreover, each node in the computing power service processing system does not need to flood and notify each other of computing power resources. In this way, there is no need to require all nodes in the computing power service processing system to support computing power network services. In the embodiment of this application, only computing power edge nodes and computing power service nodes need to support computing power network services, and the rest of the routing nodes only perform ordinary message forwarding, so when deploying computing power service processing systems, there is no need to greatly adjust a large number of routes Nodes, you only need to deploy individual edge nodes as devices that support computing power network services, which can reduce the development workload, simplify the deployment process, and reduce deployment costs.

Optionally, the computing power service request message sent by the terminal device is used to request computing power service of a specified service type.

Each computing power edge node 42 is specifically used to search for a designated multicast group that supports a designated service type from a plurality of multicast groups that it serves as a multicast source after receiving a computing power service request message, and send a message to the designated group The computing power service node 41 in the broadcast group sends a multicast query message.

Among them, the multicast source of the above-mentioned multiple multicast groups is the computing power edge node 42, and the computing power edge node 42 can pre-store the service types supported by each multicast group, and each multicast group supports a service type, and the group The multicast group members of the broadcast group are computing power service nodes 41 that support the service type. For example, the service type may be content delivery network (Content Delivery Network, CDN), artificial intelligence (Artificial Intelligence, AI), Internet of things (Internet of things, IoT) and so on.

Assume that a computing power edge node 42 is the multicast source of multicast group A, multicast group B, and multicast group C respectively, the service type supported by multicast group A is CDN, and the service type supported by multicast group B is AI. The service type supported by multicast group C is IoT. If the specified service type is AI, that is, the computing power service request message is used to request AI service, then the computing power edge node 42 can send a multicast query message to multicast group B. arts.

By adopting the embodiment of this application, the computing power edge node can send a multicast query message to the computing power service node in the multicast group that supports the specified service type, which can prevent the computing power service node that does not support the specified service type from receiving the multicast query message, which can reduce query overhead and improve query efficiency.

On the basis of any of the above embodiments, the target multicast query message is used to request to query the computing power resource information of the specified service type, and the specified service type is the computing power service requested by the computing power service request message sent by the client. type.

It can be understood that, after receiving the computing power service request message, the computing power edge node 42 can obtain the specified service type of the computing power service requested by the computing power service request message, and then send a query to the computing power service node 41 A multicast query message for computing resources of the specified service type.

Each computing power service node 41 is specifically used to respond to the received target multicast query message, select the designated computing power server that supports the specified service type from the connected computing power servers 44, and send the target computing power to the target computing power edge node. Send a query response message, and the query response message includes the computing power resource information of the specified computing power server.

Optionally, each computing power service node 41 is also configured to periodically obtain computing power resource information of each computing power server 44 connected to itself. For example, it can be obtained once every 5 seconds, so that the computing power service node 41 can know the computing power resource information of each computing power server in time, and cache it locally, and then can accurately and quickly feed back each computing power to the computing power edge node 42 Information about computing power resources of the server.

Among them, the target multicast query message received by the computing power service node 41 carries the identifier of the specified service type, different computing power servers connected to the computing power service node 41 can support different types of computing power services, and the computing power service node can filter out Support computing power servers of the specified service type, and obtain the computing power resource information of the computing power servers of the specified service type. In this way, the computing power resource information received by the computing power edge node 42 is the computing power resource information of the computing power server that supports the specified service type, which can avoid transmitting the computing power server that does not support the specified service type to the computing power edge node 42. It can save transmission overhead, thereby saving network resources and improving query efficiency.

In another embodiment, each computing power service node 41 is specifically used to respond to the received target multicast query message, and select from the connected computing power servers 44 that support the specified service type and the remaining computing power resources satisfy The designated computing power server with preset conditions sends a query response message to the target computing power edge node, and the query response message includes the computing power resource information of the designated computing power server.

That is, the computing power service node 41 not only needs to screen the computing power servers that support the specified service type, but also needs to further judge whether the remaining computing power resources of the selected computing power servers meet the preset conditions, and then send the target computing power edge node that satisfies the preset conditions. Computing power resource information of the computing power server of the condition.

Wherein, the preset condition can be set based on actual needs, for example, the preset condition can be that the CPU utilization rate in the remaining computing resources is less than a preset CPU utilization rate threshold, and the remaining memory space is greater than the memory space threshold value.

That is to say, the selected designated computing power server has sufficient computing power resources, which can avoid feeding back the resource information of computing power servers with insufficient remaining computing power resources to the target computing power edge node, can save transmission costs, and can increase computing power The efficiency of edge nodes in selecting target servers enables computing power edge nodes to process computing power service request messages more quickly and reduce the delay of computing power services.

In another embodiment of the present application, the system further includes a rendezvous point (Rendezvous Point, RP), and the rendezvous point is also a router, which is a key role in the multicast network. Wherein, in a multicast network, a router may be statically configured in advance as an RP, or an RP may be dynamically selected, and the method for determining an RP may refer to a standard multicast protocol.

In the computing power service processing system, the router running the multicast protocol can learn the RP through the multicast routing protocol.

Each computing power service node 41 is also configured to send registration information to the aggregation node when accessing the computing power service processing system, and the registration information includes the service type of the computing power server to which the computing power service node 41 is connected.

The converging node is configured to, in response to the target registration information from the target computing power service node, add the target computing power service node to the multicast group matching the service type carried in the registration information based on the service type carried in the target registration information, and Update the multicast tree corresponding to the multicast group.

It can be understood that, when accessing the computing power service processing system, each computing power service node 41 needs to register with the aggregation node first, and then can join the multicast group as a multicast member. The target computing power service node is the computing power service node 41 that sends registration information to the aggregation node.

In this embodiment of the application, each computing power service node 41 can be connected to multiple computing power servers 44, and the service types of each computing power server 44 can be different, and a single computing power server 44 can also provide multiple types of services at the same time . Correspondingly, the registration information sent by the computing power service node 41 to the convergence node may carry multiple service types, and the convergence node may add the computing power service node 41 to multiple multicast groups based on multiple service types.

With this method, when a computing power service node joins the computing power service processing system, the aggregation node can add the computing power service node to the multicast group and update the multicast group in real time, without the computing power service node sending the computing power service processing system The other nodes in the network are notified of information, which can realize the rapid deployment of the computing power network.

In addition, each computing power edge node 42 can also request the aggregation node to register as a multicast source according to the type of service required by the terminal it accesses. That is, the computing power edge node 42 may also send registration information to the aggregation node, and the registration information includes the type of service that the computing power edge node 42 can provide for the terminal device. Based on the service type carried in the registration information, the convergence node uses the computing power edge node 42 as the multicast source of the multicast group corresponding to the service type.

The following is an introduction to the computing power service processing system provided by the embodiment of the present application in conjunction with specific examples. As shown in Figure 5, the nodes A to H in Figure 5 are all network nodes in the computing power service processing system, and these network nodes can be routing device.

Among them, node A is connected to computing power server 1, and node B is connected to computing power server 2. Node A and Node B are computing power service nodes. Figure 5 exemplarily shows a computing power server 1 connected to node A and a computing power server 2 connected to node B. In actual deployment, node A and node B may also be connected to multiple computing power servers.

Nodes C, D, E, and H are traditional network routing nodes, supporting IPv6 and/or IPv4 multicast and unicast forwarding.

Nodes G and F are computing power edge nodes, which are new edge nodes that support computing power network services. If terminal devices need computing power network services, terminal devices can access computing power edge nodes.

Taking the terminal device as an example of a personal computer (Personal Computer, PC), FIG. 5 also shows two terminal devices, PC-A and PC-B. Among them, the node G connected to PC-A is a computing power edge node that supports computing power network services, so PC-A can use computing power network services. The node H connected to PC-B is a traditional router, so PC-B cannot use computing power network services.

Optionally, each node in FIG. 5 may also be connected to an SDN controller (not shown in FIG. 5 ).

During network deployment, if computing power network services need to be implemented, the edge nodes accessed by terminal devices with computing power network service requirements can be replaced with computing power edge nodes in the embodiment of this application, and computing power edge nodes can be configured Supported computing power network service types.

For example, when PC-A does not need to use computing power network services, the edge nodes accessed by PC-A can be ordinary routing nodes. When PC-A needs to use computing power network services, the routing nodes accessed by PC-A can be replaced by A computing power edge node that supports computing power services.

Both node G and node F can be used as the multicast source of the multicast group, and both node A and node B can be used as multicast members in the multicast group.

As an example, computing power server 1 provides computing power service for game a, and computing power server 2 provides computing power service for game a and game b.

The multicast group corresponding to game a is (*, game a), and the multicast group corresponding to game b is (*, game b).

When node A accesses the computing power service processing system, node A can send registration information to the sink node (not shown in Figure 5), the service type included in the registration information is game a, and then the sink node adds node A to In the multicast group (*, game a).

When Node B accesses the computing power service processing system, Node B sends registration information to the sink node. The service types included in the registration information are game a and game b, and then the sink node adds Node B to the multicast group (*, game a) and (*, game b).

Assuming that the PC-A connected to node G needs the computing power service of game a, node G can apply to the sink node for registration as the multicast source of the multicast group (*, game a).

When the multicast members in the multicast group are updated, the sink node can update the multicast tree according to the topology position relationship between the multicast source and the multicast members. Alternatively, after creating a new multicast group, the sink node can build a multicast tree according to the topological positional relationship between the multicast source and the multicast members.

For example, the multicast tree corresponding to the multicast group (*, game a) includes two branches, which are respectively node G-node D-node A, and node G-node D-node E-node B, specifically in Figure 5 The multicast tree①. It can be seen that the multicast source corresponding to the multicast tree ① is node G, and the multicast members are node A and node B.

The multicast tree corresponding to the multicast group (*, game b) includes a branch, node F-node E-node B, specifically the multicast tree ② in FIG. 5 . It can be seen that the multicast source corresponding to the multicast tree ② is node F, and the multicast member is node B.

When PC-A needs network services, it can send a computing power service request message to node G. After node G receives the computing power service request message, it can identify the service type requested by PC-A as game a based on the computing power service request message. Furthermore, node G sends a multicast request message with the destination multicast address as (*, game a) to the RP, and after receiving the multicast request message, the RP sends all multicast messages to the multicast group (*, game a) Members forward the multicast request message, that is, forward the multicast request message to node A and node B along the multicast tree ①.

After node A receives the multicast query message, it can reply a unicast service query response message to node G along the path: node A-node D-node G, and the service query response message includes computing power server 1 Computing resource information.

Similarly, after node B receives the multicast query message, it can reply a unicast service query response message to node G along the path: node B-node E-node D-node G, and the service query response message contains Including computing power resource information of computing power server 2.

Furthermore, node G can select an appropriate computing power server from computing power resource information of computing power server 1 and computing power server 2 . For example, if computing power server 1 has more sufficient computing resources and is closer to node G, computing power server 1 can be selected, and then node G can forward computing power service request messages to computing power server 1, and subsequent computing power server 1 Computing service can be provided for PC-A.

It can be seen that using this system, compared with the distributed deployment method, the embodiment of the present application does not require additional deployment of complex routing protocols, which can greatly reduce the complexity and development workload of computing power routing protocols. And by replacing the computing power edge nodes and computing power service nodes on the basis of the existing network, the rapid deployment of computing power network equipment can be realized, without the need to develop other devices in the existing network, through a simple multicast routing protocol The synchronization of computing power routing and computing power status can be realized, which greatly reduces the development workload and deployment complexity.

Corresponding to the above system embodiment, the embodiment of the present application also provides a computing power service processing method, which can be applied to any computing power edge node in the above computing power service processing system, as shown in Figure 6, the method includes :

S601. Receive a computing power service request message sent by a terminal device.

Among them, the computing power service request message is used to request the computing power service of the specified service type.

S602. Send a multicast query message to the computing service node in the multicast group that serves as the multicast source.

Among them, the leaf nodes in the multicast tree corresponding to the multicast group are computing power service nodes, the non-leaf nodes are routing nodes, and the root nodes are computing power edge nodes.

Optionally, the computing power edge node can send a multicast query message to all the multicast groups that it serves as the multicast source, and then the computing power service node that receives the multicast query message can determine whether to support the specified service type, if If supported, send a query response message to the computing power edge node. Alternatively, the computing power edge node may search for a specified multicast group supporting a specified service type from multiple multicast groups, and send a multicast query message to the computing power service nodes in the specified multicast group.

S603. Receive a query response message sent by the computing power service node in the multicast group, where the query response message includes computing power resource information of the computing power server connected to the computing power service node.

S604. Based on the received computing power resource information of each computing power server, select a target computing power server, and forward the computing power service request message to the target computing power server.

Among them, the computing power edge node can select the target computing power server according to the preset judgment conditions.

For example, the computing power server with the closest topological distance to the computing power edge node can be selected as the target computing power server, or the computing power server whose CPU usage is lower than the preset threshold can be selected as the target computing power server, or the distance between the topology, CPU Computing power resource information such as occupancy rate and storage capacity is comprehensively weighted, and a computing power server with the highest weighted value is selected as the target computing power server.

According to the embodiment of this application, after receiving the computing power service request message sent by the terminal device, the computing power edge node can send a multicast query message to the computing power service node in the multicast group, so as to obtain each computing power service node The computing power resource information of the connected computing power server does not require the controller to uniformly receive the computing power resources of each computing power service node, which reduces the requirements for the controller. Moreover, each node in the computing power service processing system does not need to flood and notify each other of computing power resources. In this way, there is no need to require all nodes in the computing power service processing system to support computing power network services. In the embodiment of this application, only computing power edge nodes and computing power service nodes need to support computing power network services, and the rest of the routing nodes only perform ordinary message forwarding, so when deploying computing power service processing systems, there is no need to greatly adjust a large number of routes Nodes, you only need to deploy individual edge nodes as devices that support computing power network services, which can reduce the development workload, simplify the deployment process, and reduce deployment costs.

Corresponding to the above system embodiment, the embodiment of the present application also provides a computing power service processing method, which is applied to any computing power service node in the computing power service processing system, as shown in Figure 7, the method includes:

S701. Receive a multicast query message sent by a target computing power edge node. The multicast query message is sent after the target computing power edge node receives a computing power service request message from a terminal device.

Among them, the target computing power edge node can be any computing power edge node in the computing power service processing system, the computing power service request message is used to request the computing power service of the specified service type, and the multicast query message can carry the specified service The identification of the type, the multicast query message is used to request to query the computing resource information of the specified service type.

S702. In response to the multicast query message, send a query response message to the target computing power edge node. The query response message includes the computing power resource information of the computing power server connected to the computing power service node, so that the target computing power edge node Based on the received computing power resource information of each computing power server, a target computing power server is selected, and the computing power service request message is forwarded to the target computing power server.

Using the embodiment of this application, the computing power service node can receive the multicast query message sent by the target computing power edge node, and obtain the computing power resource information of the computing power server connected to each computing power service node, and then there is no need for the controller to receive The computing power resources of each computing power service node reduce the requirements for the controller. Moreover, each node in the computing power service processing system does not need to flood and notify each other of computing power resources. In this way, there is no need to require all nodes in the computing power service processing system to support computing power network services. In the embodiment of this application, only computing power edge nodes and computing power service nodes need to support computing power network services, and the rest of the routing nodes only perform ordinary message forwarding, so when deploying computing power service processing systems, there is no need to greatly adjust a large number of routes Nodes, you only need to deploy individual edge nodes as devices that support computing power network services, which can reduce the development workload, simplify the deployment process, and reduce deployment costs.

Optionally, the computing power service node can periodically obtain the computing power resource information of each computing power server connected to itself, and cache the computing power resource information of the computing power server locally. After receiving the multicast query message, It can quickly feed back the computing power resource information of the computing power server connected to itself to the computing power edge node.

In one embodiment, the multicast query message is used to request to query computing power resource information of a specified service type, and accordingly, before sending the query response message to the target computing power edge node, the method further includes:

From the connected computing power servers, filter out the designated computing power servers that support the specified service type, and obtain the computing power resource information of the designated computing power server. Furthermore, the query response message sent by the computing power service node includes the resource information of the designated computing power server.

In another embodiment, before sending the query response message to the target computing power edge node, the computing power service node can filter out the specified computing power resources that support the specified service type and the remaining computing power resources meet the preset conditions from the connected servers. power server to obtain the computing power resource information of the specified computing power server. Furthermore, the query response message sent by the computing power service node includes the resource information of the designated computing power server that supports the specified service type and whose remaining computing power resources meet the preset conditions.

Since a computing power service node may be connected to multiple computing power servers, the computing power service node not only needs to select the computing power servers that support the specified service type from multiple computing power servers, but also needs to further judge the remaining power of the selected computing power servers. Whether the computing resources meet the preset conditions. The preset condition is set based on actual requirements. For example, the preset condition may be that the CPU utilization rate in the remaining computing resources is less than a preset CPU utilization rate threshold, and the remaining memory space is greater than the memory space threshold value.

Using the above method, the selected computing power servers have sufficient computing power resources, which can avoid feeding back resource information of computing power servers with insufficient remaining computing power resources to computing power edge nodes, can save transmission costs, and can improve computing power edge nodes. Selecting the efficiency of the target server enables computing power edge nodes to process computing power service request messages more quickly and reduce the latency of computing power services.

Based on the same inventive concept, the embodiment of the present application also provides a computing power service processing device, which is applied to any computing power edge node in the computing power service processing system, and the computing power service processing system also includes at least one computing power Service nodes and at least one routing node, each computing power service node is connected to at least one computing power server. As shown in Figure 8, the device includes:

A receiving module 801, configured to receive a computing power service request message sent by a terminal device;

The sending module 802 is configured to send a multicast query message to a computing power service node in a multicast group whose computing power edge node is the multicast source, and the leaf nodes in the multicast tree corresponding to the multicast group are all computing power service nodes , the non-leaf nodes are routing nodes, and the root node is a computing power edge node;

The receiving module 801 is also configured to receive a query response message sent by a computing power service node in the multicast group, and the query response message includes computing power resource information of a computing power server connected to the computing power service node;

The selection module 803 is further configured to select a target computing power server based on the computing power resource information of each computing power server received by the receiving module 801;

The sending module 802 is further configured to forward the computing power service request message to the target computing power server selected by the selecting module 803 .

Optionally, the sending module 802 is specifically used for:

Find a specified multicast group that supports a specified service type from multiple multicast groups;

Send a multicast query message to the computing service nodes in the specified multicast group.

Based on the same inventive concept, the embodiment of the present application also provides a computing power service processing device, which is applied to any computing power service node in the computing power service processing system, and the computing power service processing system also includes at least one computing power edge node and at least one routing node, each computing power service node is connected to at least one computing power server; the computing power service node is the leaf node of the multicast tree corresponding to the multicast group, the non-leaf node of the multicast tree is the routing node, and the root node It is the computing power edge node. As shown in Figure 9, the device includes:

The receiving module 901 is configured to receive a multicast query message sent by the target computing power edge node, and the multicast query message is sent after the target computing power edge node receives the computing power service request message of the terminal device;

The sending module 902 is configured to send a query response message to the target computing power edge node in response to the multicast query message, and the query response message includes the computing power resource information of the computing power server connected to the computing power service node, so that the target The computing power edge node selects a target computing power server based on the received computing power resource information of each computing power server, and forwards the computing power service request message to the target computing power server.

Optionally, the multicast query message is used to request to query the computing power resource information of the specified service type, and the query response message includes the computing power resource information of the specified computing power server supporting the specified service type;

The unit also includes:

The obtaining module is used to filter out the designated computing power server that supports the specified service type from the connected computing power servers, and obtain the computing power resource information of the designated computing power server.

Optionally, the multicast query message is used to request to query the computing power resource information of the specified service type, and the query response message includes the resource information of the specified computing power server that supports the specified service type and the remaining computing power resources meet the preset conditions ;

The unit also includes:

The acquisition module is used to filter out the specified computing power server that supports the specified service type and the remaining computing power resources meet the preset conditions from the servers connected to itself, and obtain the computing power resource information of the specified computing power server.

The embodiment of the present application also provides a network device, which can be the computing power edge node or computing power service node in the above embodiments, as shown in FIG. 10 , including a processor 1001, a communication interface 1002, a memory 1003 and A communication bus 1004, wherein, the processor 1001, the communication interface 1002, and the memory 1003 complete mutual communication through the communication bus 1004,

Memory 1003, for storing computer programs;

The processor 1001 is configured to implement the method steps performed by the computing power service node in the above method embodiments when executing the program stored in the memory 1003, or realize the method steps performed by the computing power edge node in the above method embodiments.

The communication bus mentioned in the above network device may be a Peripheral Component Interconnect (PCI) bus or an Extended Industry Standard Architecture (Extended Industry Standard Architecture, EISA) bus or the like. The communication bus can be divided into an address bus, a data bus, a control bus, and the like. For ease of representation, only one thick line is used in the figure, but it does not mean that there is only one bus or one type of bus.

The communication interface is used for communication between the electronic device and other devices.

The memory may include a random access memory (Random Access Memory, RAM), and may also include a non-volatile memory (Non-Volatile Memory, NVM), such as at least one disk memory. Optionally, the memory may also be at least one storage device located far away from the aforementioned processor.

Above-mentioned processor can be general-purpose processor, comprises central processing unit (Central Processing Unit, CPU), network processor (Network Processor, NP) etc.; It can also be Digital Signal Processor (Digital Signal Processor, DSP), ASIC (Application Specific Integrated Circuit, ASIC), Field-Programmable Gate Array (Field-Programmable Gate Array, FPGA) or other programmable logic devices, discrete gate or transistor logic devices, discrete hardware components.

In yet another embodiment provided by the present invention, a computer-readable storage medium is also provided. A computer program is stored in the computer-readable storage medium. When the computer program is executed by a processor, any of the above-mentioned computing power service processing methods is implemented. A step of.

In yet another embodiment provided by the present invention, a computer program product including instructions is also provided, which, when run on a computer, causes the computer to execute any computing power service processing method in the above embodiments.

In the above embodiments, all or part of them may be implemented by software, hardware, firmware or any combination thereof. When implemented using software, it may be implemented in whole or in part in the form of a computer program product. A computer program product includes one or more computer instructions. When the computer program instructions are loaded and executed on the computer, the processes or functions according to the embodiments of the present invention are produced in whole or in part. A computer can be a general purpose computer, special purpose computer, computer network, or other programmable device. Computer instructions may be stored in or transmitted from one computer-readable storage medium to another computer-readable storage medium, e.g. Coaxial cable, optical fiber, digital subscriber line (DSL)) or wireless (such as infrared, wireless, microwave, etc.) to another website site, computer, server or data center. The computer-readable storage medium may be any available medium that can be accessed by a computer, or a data storage device such as a server, a data center, etc. integrated with one or more available media. The available media may be magnetic media (eg, floppy disk, hard disk, magnetic tape), optical media (eg, DVD), or semiconductor media (eg, Solid State Disk (SSD)).

It should be noted that in this article, relational terms such as first and second are only used to distinguish one entity or operation from another entity or operation, and do not necessarily require or imply that there is a relationship between these entities or operations. There is no such actual relationship or order between them. Furthermore, the term "comprises", "comprises" or any other variation thereof is intended to cover a non-exclusive inclusion such that a process, method, article, or apparatus comprising a set of elements includes not only those elements, but also includes elements not expressly listed. other elements of or also include elements inherent in such a process, method, article, or device. Without further limitations, an element defined by the phrase "comprising a ..." does not preclude the presence of additional identical elements in the process, method, article, or apparatus that includes the element.

Each embodiment in this specification is described in a related manner, the same and similar parts of each embodiment can be referred to each other, and each embodiment focuses on the differences from other embodiments. In particular, as for the method embodiment, since it is basically similar to the system embodiment, the description is relatively simple, and for the related parts, please refer to the part of the description of the system embodiment.

The above are only preferred embodiments of the present invention, and are not intended to limit the protection scope of the present invention. Any modification, equivalent replacement, improvement, etc. made within the spirit and principles of the present invention are included in the protection scope of the present invention.

Claims (13)

1. A computing power service processing system, comprising at least one computing power service node, at least one computing power edge node, and at least one routing node, each computing power service node connected to at least one computing power server;

each computational power edge node is used for receiving a computational power service request message sent by terminal equipment and sending a multicast query message to the computational power service nodes in multicast groups which are taken as multicast sources, wherein leaf nodes in a multicast tree corresponding to each multicast group are computational power service nodes, non-leaf nodes are routing nodes, and root nodes are computational power edge nodes;

each computing power service node is used for responding to a target multicast query message from a target computing power edge node and sending a query response message to the target computing power edge node, wherein the query response message comprises computing power resource information of a computing power server connected with the computing power service node;

each computing force edge node is also used for selecting a target computing force server based on the received computing force resource information of each computing force server and forwarding a computing force service request message to the target computing force server.

2. The system according to claim 1, wherein the computing power service request message is used for requesting a computing power service of a specified service type;

each computing force edge node is specifically configured to, after receiving a computing force service request message, search for an assigned multicast group supporting the assigned service type from multiple multicast groups that serve as multicast sources, and send a multicast query message to a computing force service node in the assigned multicast group.

3. The system according to claim 1 or 2, wherein the target multicast query message is used for requesting to query computing resource information of a specified service type;

each computational power service node is specifically configured to screen out, in response to a received target multicast query message, a designated computational power server supporting the designated service type from connected computational power servers, and send the query response message to the target computational power edge node, where the query response message includes computational power resource information of the designated computational power server.

4. The system according to claim 1 or 2, wherein the multicast query message is used for requesting to query computing resource information of a specified service type;

each computational power service node is specifically configured to screen out, in response to a received target multicast query message, a specified computational power server that supports the specified service type and for which the remaining computational power resources meet preset conditions from connected computational power servers, and send the query response message to the target computational power edge node, where the query response message includes computational power resource information of the specified computational power server.

5. The system of claim 1,

each computing power service node is also used for periodically acquiring computing power resource information of each computing power server connected with the computing power service node.

6. The system of claim 1, further comprising an aggregation node;

each computing service node is also used for sending registration information to the aggregation node when the computing service node is accessed into the computing service processing system, wherein the registration information comprises the service type of a computing server connected with the computing service node;

and the sink node is used for responding to target registration information from a target computing power service node, adding the target computing power service node into a target multicast group matched with the service type carried by the target registration information based on the service type carried by the target registration information, and updating a multicast tree corresponding to the target multicast group.

7. A computing power service processing method is characterized in that the method is applied to any computing power edge node in a computing power service processing system, the computing power service processing system also comprises at least one computing power service node and at least one routing node, and each computing power service node is connected with at least one computing power server; the method comprises the following steps:

receiving a computing power service request message sent by terminal equipment;

sending a multicast query message to a computational power service node in a multicast group which is taken as a multicast source, wherein leaf nodes in a multicast tree corresponding to the multicast group are computational power service nodes, non-leaf nodes are routing nodes, and a root node is a computational power edge node;

receiving an inquiry response message sent by a computing service node in the multicast group, wherein the inquiry response message comprises computing resource information of a computing server connected with the computing service node;

and selecting a target computing power server based on the received computing power resource information of each computing power server, and forwarding the computing power service request message to the target computing power server.

8. The method of claim 7, wherein sending the multicast query message to the computation force service node in the multicast group comprises:

searching a specified multicast group supporting the specified service type from a plurality of multicast groups;

and sending the multicast query message to the computing service node in the specified multicast group.

9. A computing power service processing method is characterized in that the method is applied to any computing power service node in a computing power service processing system, the computing power service processing system further comprises at least one computing power edge node and at least one routing node, and each computing power service node is connected to at least one computing power server; the calculation force service node is a leaf node of a multicast tree corresponding to a multicast group, a non-leaf node of the multicast tree is a routing node, and a root node is a calculation force edge node; the method comprises the following steps:

receiving a multicast query message sent by a target computing power edge node, wherein the multicast query message is sent by the target computing power edge node after receiving a computing power service request message of a terminal device;

responding to the multicast query message, sending a query response message to the target computing power edge node, wherein the query response message comprises computing power resource information of the computing power servers connected with the computing power service node, so that the target computing power edge node selects one target computing power server based on the received computing power resource information of each computing power server, and forwards the computing power service request message to the target computing power server.

10. The method according to claim 9, wherein the multicast query message is used to request query for computing resource information of a specified service type, and the query response message includes computing resource information of a specified computing server supporting the specified service type;

before the sending of the query response message to the target computing force edge node, the method further includes:

and screening out the appointed force calculation server supporting the appointed service type from the connected force calculation servers, and acquiring the force calculation resource information of the appointed force calculation server.

11. The method according to claim 9, wherein the multicast query message is used to request query for computing power resource information of a specified service type, and the query response message includes resource information of a specified computing power server that supports the specified service type and for which the remaining computing power resources meet a preset condition;

before the sending of the query response message to the target computing force edge node, the method further includes:

and screening out a designated computing power server which supports the designated service type and has residual computing power resources meeting preset conditions from the server connected with the designated computing power server, and acquiring computing power resource information of the designated computing power server.

12. The computing power service processing device is applied to any computing power edge node in a computing power service processing system, the computing power service processing system also comprises at least one computing power service node and at least one routing node, and each computing power service node is connected with at least one computing power server; the device comprises:

the receiving module is used for receiving a computing power service request message sent by the terminal equipment;

a sending module, configured to send a multicast query packet to a computation force service node in a multicast group in which the computation force edge node serves as a multicast source, where leaf nodes in a multicast tree corresponding to the multicast group are all computation force service nodes, non-leaf nodes are routing nodes, and a root node is the computation force edge node;

the receiving module is further configured to receive a query response packet sent by a computational power service node in the multicast group, where the query response packet includes computational power resource information of a computational power server connected to the computational power service node;

the selection module is used for selecting a target calculation force server based on the calculation force resource information of each calculation force server received by the receiving module;

the sending module is further configured to forward the computing power service request message to the target computing power server selected by the selecting module.

13. The computing power service processing device is applied to any computing power service node in a computing power service processing system, the computing power service processing system also comprises at least one computing power edge node and at least one routing node, and each computing power service node is connected with at least one computing power server; the calculation force service node is a leaf node of a multicast tree corresponding to a multicast group, a non-leaf node of the multicast tree is a routing node, and a root node is a calculation force edge node; the device comprises:

the receiving module is used for receiving a multicast query message sent by a target computing power edge node, wherein the multicast query message is sent after the target computing power edge node receives a computing power service request message of a terminal device;

and the sending module is used for responding to the multicast query message and sending a query response message to the target computing power edge node, wherein the query response message comprises computing power resource information of the computing power servers connected with the computing power service node, so that the target computing power edge node selects one target computing power server based on the received computing power resource information of each computing power server and forwards the computing power service request message to the target computing power server.

Images