Detailed Description
For the purpose of promoting an understanding of the principles and advantages of the application, reference will now be made in detail to the drawings, in which embodiments illustrated in the drawings are intended to illustrate, but not limit the application to the specific embodiments illustrated. All other embodiments, which can be made by those skilled in the art based on the embodiments of the application without making any inventive effort, are intended to be within the scope of the application.
The embodiment of the application provides a distributed resource collaborative scheduling system, a method, a device, equipment and a medium, wherein the system comprises resource demand equipment, convergence switching equipment and a plurality of intelligent gateways, and the plurality of intelligent gateways are connected with the convergence switching equipment; the resource demand equipment is used for sending a resource request to the convergence switching equipment; the resource request carries the first resource amount required by the resource demand equipment and the information of the first task; the convergence switching equipment is used for receiving the resource requests and sending the resource requests to each intelligent gateway; any intelligent gateway is used for sending a connection request to the convergence switching device after receiving the resource request, wherein the connection request carries a second resource amount to be provided by the intelligent gateway and identification information of the intelligent gateway; the convergence switching device is further used for determining a target intelligent gateway connected with the resource demand device according to the first resource quantity and each second resource quantity; transmitting a target connection request corresponding to the target intelligent gateway to resource demand equipment; the resource demand equipment is also used for establishing connection with the target intelligent gateway according to the identification information of the target intelligent gateway carried in the received target connection request; the target intelligent gateway is further configured to execute the first task after establishing a connection with the resource demand device. In the embodiment of the application, the convergence switching equipment directly communicates with the resource demand equipment and the intelligent gateway, and the participation of a resource perception center platform is not needed, so that the cooperative scheduling decision time delay can be saved, and the communication time delay is reduced.
Example 1:
fig. 3 is a schematic structural diagram of a distributed resource cooperative scheduling system according to an embodiment of the present application, where the distributed resource cooperative scheduling system includes a resource demand device 301, a convergence switching device 302, and a plurality of intelligent gateways 303, where the plurality of intelligent gateways 303 are respectively connected to the convergence switching device 302;
a resource demand device 301, configured to send a resource request to an aggregation switching device 302; the resource request carries the first resource amount required by the resource demand device 301 and the information of the first task;
an aggregation switch device 302, configured to receive the resource request and send the resource request to each intelligent gateway 303;
any intelligent gateway 303 is configured to send a connection request to the aggregation switching device 302 after receiving a resource request, where the connection request carries a second resource amount to be provided by the intelligent gateway 303 and identification information of the intelligent gateway 303;
the aggregation switch device 302 is further configured to determine, according to the first resource amount and each second resource amount, a target intelligent gateway that establishes a connection with the resource demand device 301; and sends a target connection request corresponding to the target intelligent gateway to the resource demand device 301;
the resource demand device 301 is further configured to establish a connection with a target intelligent gateway according to the identification information of the target intelligent gateway carried in the received target connection request;
The target intelligent gateway is further configured to perform the first task after establishing a connection with the resource demand device 301.
In the distributed resource collaborative scheduling system provided by the embodiment of the application, the aggregation switching equipment 302 is connected with the resource demand equipment 301, the aggregation switching equipment 302 is connected with a plurality of intelligent gateways 303, wherein the plurality of intelligent gateways 303 connected with the aggregation switching equipment 302 are intelligent gateways in the aggregation switching equipment 302. The aggregation switch device 302 forwards the resource request initiated by the resource demand device 301 to at least one intelligent gateway 303 connected to the aggregation switch device 302, receives a connection request returned by the at least one intelligent gateway 303 and responding to the resource request, determines a target intelligent gateway, and schedules the target intelligent gateway to establish a communication connection with the resource demand device 301, so that the distributed intelligent gateway can execute the first task initiated by the resource demand device 301.
Fig. 4 shows a schematic diagram of a specific connection between the aggregation switch device 302 and the intelligent gateway 303, where a virtualization module and a resource awareness module are included in the intelligent gateway 303, and a co-scheduling module is included in the aggregation switch device 302. The virtualization module of the intelligent gateway 303 encapsulates resources such as computing resources and storage resources contained in the intelligent gateway, and connects the resources with an external device through a Virtual Machine (VM) interface, a container (Containers as a Service, caaS) interface, and a function (Function as a Service, faaS) interface, so that the external device can call the encapsulated resources. The resource sensing module of the intelligent gateway 303 provides the state sensing capability of a host (current intelligent gateway) and a container to an external device connected with the current intelligent gateway through an open remote procedure call (Google Remote Procedure Call, gRPC) interface, wherein the state comprises resource conditions such as computing resources, storage resources and the like; the resource sensing module stores the resource sensing result in real time through the time-sequence database and can provide the real-time resource sensing result to external equipment connected with the current intelligent gateway; wherein the time-stamped resource information is stored in the time-stamped database. The cooperative scheduling module of the aggregation switch device 302 may obtain, through a received resource request sent by the resource demand device 301 to the aggregation switch device 302, a first resource amount and first task information required by the resource demand device 301 carried in the resource request; and the cooperative scheduling module may receive a connection request sent by the intelligent gateway 303 to the aggregation switching device 302, obtain a second resource amount to be provided by the intelligent gateway 303 carried in the connection request, and combine with the network neighbor identifier to preferentially cooperatively schedule the intelligent gateway closest to the resource demand device 301, so as to meet the resource demand of the user.
FIG. 4 also shows that the current container Performance Analyzer (cAdvisor) is able to sense the service state and the time-sequential storage of data, but is not able to sense the host state; node-explore (node-explore) is able to perceive service state and host state, but is unable to perceive time-sequential storage condition of data; the data acquisition device (Telegraf) can sense the service state, the host state and the time-sequence storage condition of the data; the service state comprises resource information such as computing resources, storage resources and the like which can be provided by the intelligent gateway. Therefore, in the embodiment of the present application, the resource sensing module of the intelligent gateway 303 may employ Telegraf to sense.
The intelligent gateway 303 may encapsulate the second resource amount to be provided in the connection request and send the second resource amount to the aggregation switching device 302, so that the aggregation switching device 302 can obtain the second resource amount that can be provided by the intelligent gateway 303 from the connection request after receiving the connection request, thereby facilitating the aggregation switching device 302 to determine, according to the first resource amount and the second resource amount, a target intelligent gateway that establishes connection with the resource demand device 301.
In addition, fig. 4 also shows that the intelligent gateway 303 may further encapsulate the network neighbor identifier and the shortest path schedule into a cooperative scheduling module that sends the connection request to the aggregation switching device 302; the cooperative scheduling module of the aggregation switching device 302 may determine, according to the network neighbor identifier and the shortest path scheduling, an intelligent gateway closest to the resource demand device 301, so as to implement near-source computing, near-source storage and near-source security protection, where the near-source security protection may include trusted anti-flooding. The distributed resource collaborative scheduling system provided by the embodiment of the application can also calculate the cost of the resource amount required by the resource demand equipment 301 by adopting the trusted charging based on the blockchain, so that the corresponding cost is paid by the consumer corresponding to the resource demand equipment 301. The use mode of network neighbor identification and shortest path scheduling, trusted charging based on blockchain, near source calculation, near source storage and near source safety protection are the prior art, and are not repeated in the embodiment of the application.
In addition, in the embodiment of the present application, the relationship among the operator, manager and consumer of the intelligent gateway is shown in fig. 5, where the operator of the intelligent gateway includes, but is not limited to, a home broadband user, and the operator may bear the electricity fee of the intelligent gateway and obtain the flow incentive issued by the manager; the manager of the intelligent gateway may be an operator, which may sense, schedule and manage the resources of each intelligent gateway, ensure that the service can be provided for the consumer, and pay the consumer through the trusted charging based on the blockchain in fig. 4, and in one possible implementation, the manager is equivalent to the owner of the aggregation switching device in the embodiment of the present application; the consumer may be a resource demand device, and example consumers include, but are not limited to, video service content providers, and the consumer may purchase a service from a manager, which may be the amount of resources the consumer requires, and the manager may provide the corresponding resource service capability guarantee to the consumer.
The method comprises the steps that a resource renting relation is formed between an operator and a manager of the intelligent gateway, the operator can rent the resource quantity which can be provided by the intelligent gateway to the manager, so that the manager can provide the resource quantity which can be provided by the intelligent gateway to consumers, and accordingly, the manager can provide flow incentive for the operator to rewards the operator to share part of resources in the intelligent gateway with the consumers. The manager of the intelligent gateway and the consumers are in resource consumption relation, the manager can sense and schedule each intelligent gateway, the near source service capability guarantee is provided for the consumers, and correspondingly, the consumers can purchase resource services for the manager, and the resource services can be the amount of resources required by the consumers.
In the embodiment of the present application, the resource demand device 301 sends a resource request to the aggregation switch device 302, where the resource request carries a first resource amount required by the resource demand device 301 and information of a first task; the first resource amount may be a computing resource amount or a storage resource amount, and when the first resource amount is a computing resource amount, the first task is a computing task, that is, the intelligent gateway is made to provide the resource amount required by the computing task, and the computing task is processed; when the first resource amount is the storage resource amount, the first task is a storage task, that is, the intelligent gateway is enabled to provide the resource amount required by the storage task, and the resources required to be stored in the storage task are stored. For example, the first amount of resources may be 4 central processing unit (Central Processing Unit, CPU) resources. The first task may be a target recognition artificial intelligence (Artificial Intelligence, AI) task. Wherein the resource demand device 301 may generate a resource identifier (Resource Identifier, RID) according to the first amount of resources and the information of the first task, and carry the resource identifier RID in the resource request; the resource identifier RID is used to identify the required resource name and the amount of resources.
In addition, the resource request may further carry identification information of the resource demand device 301, where the identification information may be address information of the resource demand device 301.
The resource request may be encapsulated into a data packet, where the encapsulated data packet may include a first resource amount, information of the first task, a resource identifier RID corresponding to a resource name of the resource included in the first resource amount, and identification information of the resource demand device 301.
In one possible implementation, the destination address of the resource request may also be carried in the resource request, where the destination address may be a broadcast address, and the broadcast address may be used to enable the aggregation switch device 302 to forward the resource request to all intelligent gateways 303 in the domain, that is, forward the resource request to all intelligent gateways 303 connected to the aggregation switch device 302 at the same time.
The aggregation switch device 302 may monitor whether a resource request initiated by the resource demand device 301 is received, and if not, continue to monitor whether the resource request is received; if so, after receiving the resource request, the resource request is forwarded to each intelligent gateway 303 connected to the aggregation switch device 302.
In one possible implementation, after receiving a resource request sent by the aggregation switch device 302, any intelligent gateway 303 sends a connection request to the aggregation switch device 302 in response to the resource request, where the connection request carries a second resource amount that can be provided by the intelligent gateway 303 and identification information of the intelligent gateway 303, and the identification information of the intelligent gateway 303 may be address information of the intelligent gateway 303.
In a further possible implementation, after receiving a resource request sent by the aggregation switch device 302, any intelligent gateway 303 responds to the resource request, and sends a connection request to the resource demand device 301 according to the identification information of the resource demand device 301 carried in the resource request, where the aggregation switch device 302 can monitor the connection request sent by the intelligent gateway 303 to the resource demand device 301.
The intelligent gateway 303 may monitor, through a resource demand monitoring agent in itself, a resource request sent by the aggregation switch device 302, and determine that the resource request sent by the aggregation switch device 302 is received after monitoring the resource request sent by the aggregation switch device 302.
After the intelligent gateways 303 send the connection request, the aggregation switch device 302 determines, according to the second resource amount to be provided by the intelligent gateway carried in the received or monitored connection request sent by each intelligent gateway 303 and the first resource amount required by the resource demand device 301 carried in the received resource request sent by the resource demand device 301, a target intelligent gateway that establishes connection with the resource demand device 301, where one or more target intelligent gateways may be provided, and the total amount of the second resource amounts to be provided by all target intelligent gateways can meet the first resource amount required by the resource demand device 301. Wherein the total amount of the second resource amount to be provided by the target intelligent gateway can meet the first resource amount required by the resource demand device 301 means that the total amount of the second resource amount to be provided by the target intelligent gateway is not less than the first resource amount required by the resource demand device 301.
In one possible implementation, the aggregation switch device 302 may determine the target intelligent gateway according to the sequence of response time of the intelligent gateway 303 to the resource request, the first resource amount, and the second resource amount to be provided by the intelligent gateway 303.
For example, after receiving or monitoring a connection request sent by the intelligent gateway 303 for the first time, the convergence switching device 302 determines whether the second resource amount to be provided by the intelligent gateway 303 can meet the first resource amount required by the resource demand device 301, if yes, determines the intelligent gateway 303 as a target intelligent gateway, and does not determine other intelligent gateways as target intelligent gateways even if connection requests sent by other intelligent gateways are subsequently received; if not, determining the intelligent gateway 303 as a target intelligent gateway, and after receiving or monitoring a connection request sent by the intelligent gateway 303 for the second time, judging whether the total of the second resource amount to be provided by the current intelligent gateway 303 and the second resource amount to be provided by the determined target intelligent gateway can meet the first resource amount required by the resource demand device 301, if so, determining the current intelligent gateway as the target intelligent gateway; if not, determining the current intelligent gateway as a target intelligent gateway, and continuing to determine whether the total amount of the second resource amounts to be provided by all intelligent gateways which have responded to the resource request can meet the first resource amount after monitoring the connection request sent by the intelligent gateway 303 until it is determined that the total amount of the second resource amounts to be provided by all intelligent gateways which have responded to the resource request can meet the first resource amount, and determining all intelligent gateways as target intelligent gateways.
After determining the target intelligent gateway, the aggregation switching device 302 sends a target connection request corresponding to the target intelligent gateway to the resource demand device 301, so that the resource demand device 301 determines address information of the target intelligent gateway according to the identification information of the target intelligent gateway carried in the target connection request after receiving the target connection request, thereby establishing connection with the target intelligent gateway.
After the connection is established between the target intelligent gateway and the resource demand device 301, executing a first task corresponding to the resource demand device 301, and feeding back an execution result of the first task to the resource demand device 301.
In the embodiment of the application, the convergence switching equipment directly communicates with the resource demand equipment and the intelligent gateway, and the participation of a resource perception center platform is not needed, so that the cooperative scheduling decision time delay can be saved, and the communication time delay is reduced.
Example 2:
in order to further reduce the communication delay, in the embodiment of the present application, if the target intelligent gateway includes a plurality of target intelligent gateways;
the aggregation switching device 302 is further configured to divide, after the connection between the resource demand device 301 and the target intelligent gateways is established, the first task into sub-tasks with the number corresponding to the number of the target intelligent gateways according to the first resource amount and the second resource amount to be provided by each target intelligent gateway, and send each sub-task to the corresponding target intelligent gateway;
Any target intelligent gateway is further configured to execute a subtask corresponding to the target intelligent gateway, and send a subtask execution result to the resource requirement device 301.
In the embodiment of the present application, one or more target intelligent gateways may be provided, and when the number of target intelligent gateways is multiple, after the aggregation switch device 302 establishes a connection between the resource demand device 301 and each target intelligent gateway, according to a first resource amount carried in a received resource request sent by the resource demand device 301 and a second resource amount to be provided by the target intelligent gateway carried in a connection request sent by each target intelligent gateway, the first task corresponding to the resource demand device 301 may be divided into sub-tasks corresponding to the number of target intelligent gateways, and each sub-task after being divided is issued to a corresponding target intelligent gateway, so that the target intelligent gateway executes the sub-task corresponding to the target intelligent gateway. The second resource amount to be provided of each target intelligent gateway can meet the resource amount requirement of the subtasks received by the target intelligent gateway.
For example, in one possible implementation, assuming that the number of target intelligent gateways is 3, the first amount of resources required by the resource demand device 301 is 4CPU resources, the second amount of resources that can be provided by the first target intelligent gateway is 2CPU resources, the second amount of resources that can be provided by the second target intelligent gateway is 1CPU resources, and the second amount of resources that can be provided by the third target intelligent gateway is 1CPU resources, the aggregation switching device 302 may divide the first task into a first subtask with the amount of resources being 2CPU resources, a second subtask with the amount of resources being 1CPU resources, and a third subtask with the amount of resources being 1CPU resources; the first subtask is issued to a first target intelligent gateway, so that the first target intelligent gateway executes the first subtask; issuing the second subtask to a second target intelligent gateway, so that the second target intelligent gateway executes the second subtask; and issuing the third subtask to a third target intelligent gateway, so that the third target intelligent gateway executes the third subtask.
In yet another possible implementation, assuming that the first amount of resources required by the resource demand device 301 is 4CPU resources, the second amount of resources that the first target intelligent gateway (here, the first intelligent gateway responding to the resource request) can provide is 2CPU resources, the second amount of resources that the second target intelligent gateway (here, the second intelligent gateway responding to the resource request) can provide is 1CPU resources, and the second amount of resources that the third target intelligent gateway (here, the third intelligent gateway responding to the resource request) can provide is 2CPU resources, the aggregation switching device 302, after receiving the connection request sent by the first target intelligent gateway, divides the first subtask of which the amount of resources is 2CPU resources from the first task according to the second amount of resources to be provided by the first target intelligent gateway, and issues the first subtask to the first target intelligent gateway, so that the first target intelligent gateway processes the first subtask; after receiving the connection request sent by the second target intelligent gateway, the convergence switching device 302 segments a second subtask with the resource quantity of 1CPU resource from the first task according to the second resource quantity of 1CPU resource to be provided by the second target intelligent gateway, and sends the second subtask to the second target intelligent gateway so that the second target intelligent gateway processes the second subtask; after receiving the connection request sent by the third target intelligent gateway, the aggregation switching device 302 determines the residual resource amount corresponding to the first task according to the divided resource amounts of the first subtask and the second subtask, divides the third subtask with the resource amount of 1CPU resource (i.e., the residual resource amount) from the first task, and sends the third subtask to the third target intelligent gateway, so that the third target intelligent gateway processes the third subtask. The resource amount corresponding to the third subtask is determined according to the difference value between the first resource amount and the total amount of the second resource amounts to be provided by all target intelligent gateways responding before the third target intelligent gateway responds to the resource request.
After receiving the corresponding subtask, any target intelligent gateway executes the subtask and sends the subtask execution result to the resource demand device 301.
In the embodiment of the application, when the target intelligent gateways are multiple, the convergence switching equipment divides the first tasks into the sub tasks with the same number as the target intelligent gateways, and sends the sub tasks to each target intelligent gateway, so that the multiple target intelligent gateways process the first tasks in parallel, and the communication delay is further reduced.
Example 3:
based on the foregoing embodiments, in the embodiment of the present application, the aggregation switch device 302 is further configured to determine, according to the second resource amount to be provided by the corresponding intelligent gateway 303 carried in each received connection request, whether the total amount of the second resource amount to be provided meets the first resource amount, and if yes, not forward the received connection request of other intelligent gateways to the resource demand device 301.
After receiving the connection request sent by the intelligent gateway, the convergence switching device 302 determines whether the total amount of the second resource amount to be provided by the corresponding intelligent gateway carried in the connection request received currently and the second resource amount to be provided by the corresponding intelligent gateway carried in the connection request received before the current moment meets the first resource amount, if yes, the convergence switching device 302 does not forward the connection request of other intelligent gateways received after the current moment to the resource demand device 301; if not, the received connection request is forwarded to the resource requiring device 301.
On the basis of the foregoing embodiments, in the embodiment of the present application, when the aggregation switch device 302 segments a first task, a process of segment the first task may be implemented by a co-scheduling module in the aggregation switch device 302, and specifically, referring to a flow diagram of processing the first task by the co-scheduling module in the aggregation switch device shown in fig. 6, the flow diagram includes the following steps:
s601: the resource demand device sends a resource request to the aggregation switching device.
The resource request carries a resource identifier RID, a first resource amount required by the resource demand equipment and information of a first task.
S602: after receiving the resource request, the convergence switching device forwards the resource request to all the intelligent gateways in the domain, and acquires the connection request returned by each intelligent gateway.
And the connection request returned by each intelligent gateway carries a second resource amount to be provided by the intelligent gateway.
S603: and the cooperative scheduling module in the convergence switching device determines the target intelligent gateway according to the first resource amount in the resource request and the second resource amount in each connection request.
S604: and the cooperative scheduling module in the convergence switching device divides the first task into sub-tasks with the number corresponding to the number of the target intelligent gateways according to the first resource amount and each second resource amount.
S605: and the cooperative scheduling module in the convergence switching device transmits the subtasks to the corresponding target intelligent gateway.
S606: and a cooperative scheduling module in the convergence switching equipment acquires the execution result of the subtask by the target intelligent gateway, integrates the execution result of the subtask, and determines the execution result corresponding to the first task.
On the basis of the above embodiments, referring to the specific exemplary schematic diagram shown in fig. 7, the method includes the following steps:
step one, a first task of the resource demand device is used for identifying AI application as a target, a first resource amount required by the first task is 3CPU resources, a resource identifier RID is generated according to the first resource amount and the information of the first task, and a resource request is initiated to the convergence switching device, wherein the resource request carries the resource identifier RID.
And step two, after the convergence switching equipment receives the resource request, forwarding the resource request to all intelligent gateways in the domain.
Step three, the intelligent gateway responds to the resource request and feeds back a second resource amount which can be provided by the intelligent gateway to the convergence switching device through the connection request, for example, the intelligent gateway 1 can provide 1CPU resource, the intelligent gateway 2 can provide 1CPU resource, and the intelligent gateway 3 can provide 1CPU resource; when the convergence switching device receives the connection requests of the intelligent gateway 1, the intelligent gateway 2 and the intelligent gateway 3, the convergence switching device counts whether the total amount of resources which can be provided by the intelligent gateway responding to the resource requests can meet the required resources of the resource demand device, and if so, the connection requests of other intelligent gateways are not sent to the resource demand device.
And step four, the intelligent gateway 1, the intelligent gateway 2 and the intelligent gateway 3 establish communication connection with the resource demand equipment through the convergence switching equipment and start to provide resource service for the resource demand equipment.
Example 4:
in order to further reduce the communication delay, in the above embodiments, the aggregation switch device 302 is further configured to determine whether the response of any intelligent gateway 303 connected to the aggregation switch device 302 to the resource request is overtime, and if not, monitor whether a connection request sent by the intelligent gateway 303 is received.
After the convergence switching device 302 forwards the resource request to all the intra-domain intelligent gateways, a timer in the convergence switching device 302 may be started, and whether the response of any intelligent gateway 303 connected with the convergence switching device 302 to the resource request is overtime is judged by the timer, if not, the convergence switching device 302 continues to monitor whether the connection request sent by the intra-domain intelligent gateway is received. The intra-domain intelligent gateway is an intelligent gateway connected with the convergence switching equipment.
In the embodiment of the application, whether the response of the intelligent gateway connected with the convergence switching equipment is overtime is judged, the condition of communication delay caused by long-time unresponsiveness of the intelligent gateway is reduced, and the communication delay is further reduced.
On the basis of the above embodiments, referring to the communication mechanism workflow diagram shown in fig. 8, the method includes the following steps:
step one, resource demand equipment sends a resource request to convergence switching equipment, wherein the resource request carries first resource quantity and address information.
The address information includes a source address and a destination address, the source address is address information of the resource demand device, the destination address is a broadcast address, and the broadcast address can be used for enabling the convergence switching device to forward the resource request to all intelligent gateways in the domain of the convergence switching device.
And step two, the convergence switching equipment receives the resource request and forwards the resource request to all intelligent gateways in the domain.
And thirdly, after each intelligent gateway receives the resource request, establishing connection with the resource demand equipment through the convergence switching equipment, and acquiring a first task of the resource demand equipment.
Wherein the first task may be a computing task or a storage task.
And step four, each intelligent gateway returns the sub-task execution result of the first task to the resource demand equipment.
On the basis of the above embodiments, referring to the schematic workflow of the communication mechanism of the aggregation switching device shown in fig. 9, the method includes the following steps:
S901: the convergence switching device monitors whether a resource request initiated by the resource demand device is received, if yes, S902 is executed; if not, execution continues with S901.
S902: the convergence switching device forwards the resource request to the intra-domain intelligent gateway.
S903: the convergence switching device judges whether the response of the intra-domain intelligent gateway to the resource request is overtime, if yes, S904 is executed; if not, then S905 is performed.
S904: the convergence switching device forwards the resource request to other inter-domain intelligent gateways.
S905: the convergence switching device judges whether a connection request sent by the intelligent gateway is received, if yes, S906 is executed; if not, execution continues with S905.
S906: the convergence switching device forwards the connection request sent by the intelligent gateway which has responded to the resource request to the resource demand device.
S907: the convergence switching device judges whether the total amount of resources which can be provided by the intelligent gateway which has responded to the resource request can meet the resources required by the resource demand device, if so, S908 is executed; if not, execution continues with S907.
S908: the convergence switching device does not forward the received connection request of other intelligent gateways to the resource demand device.
Example 5:
in order to further reduce the communication delay, in the embodiments of the present application, the system further includes other convergence switching devices and at least one inter-domain intelligent gateway connected to the other convergence switching devices;
The convergence switching device 302 is further configured to forward the resource request to other convergence switching devices when it is determined that all intelligent gateways 303 connected to the convergence switching device 302 have time-out for the response to the resource request;
the other aggregation switching devices are configured to forward the resource request to the inter-domain intelligent gateway after receiving the resource request, receive an inter-domain connection request from the inter-domain intelligent gateway in response to the resource request, and send the inter-domain connection request to the aggregation switching device 302; the inter-domain connection request carries a third resource amount to be provided by the inter-domain intelligent gateway and identification information of the inter-domain intelligent gateway.
When the aggregation switch device 302 determines that the responses of all the intra-domain intelligent gateways (all the intelligent gateways 303 connected with the aggregation switch device) to the resource requests are all over time, the aggregation switch device 302 forwards the resource requests sent by the resource demand device 301 to other aggregation switch devices.
After receiving the resource request sent by the aggregation switch device 302, the other aggregation switch devices forward the resource request to the inter-domain intelligent gateway connected with the other aggregation switch devices. After receiving the resource request, the inter-domain intelligent gateway sends an inter-domain connection request of the inter-domain intelligent gateway responding to the resource request to the other convergence switching equipment; the inter-domain connection request carries the corresponding third resource amount to be provided by the inter-domain intelligent gateway and the identification information of the inter-domain intelligent gateway. The identification information of the inter-domain intelligent gateway may be address information of the inter-domain intelligent gateway.
The other aggregation switch device, after receiving the inter-domain intelligent gateway response and the inter-domain connection request of the resource request, sends the inter-domain connection request to the aggregation switch device 302. After receiving the inter-domain connection request, the aggregation switch device 302 may determine the target intelligent gateway in the inter-domain intelligent gateway according to the first resource amount and the third resource amount to be provided by the inter-domain intelligent gateway carried in the inter-domain connection request in the same manner as the determination of the target intelligent gateway according to the first resource amount and the second resource amount in the above embodiment.
After determining the target intelligent gateway in the inter-domain intelligent gateway, the convergence switching device 302 forwards the target connection request corresponding to the target intelligent gateway to the resource demand device 301; after receiving the target connection request, the resource demand device 301 establishes connection with the target intelligent gateway through the aggregation switching device 320 and other aggregation switching devices corresponding to the target intelligent gateway according to the identification information of the target intelligent gateway carried in the target connection request, so that the target intelligent gateway after establishing connection with the resource demand device 301 executes the first task and returns an execution result of the first task to the resource demand device.
In the embodiment of the application, when the convergence switching equipment determines that the response of the intra-domain intelligent gateway to the resource request is all over-time, the resource request is forwarded to the inter-domain intelligent gateway connected with other convergence switching equipment, so that the response time of the intra-domain intelligent gateway is saved, and the communication time delay is further reduced.
Example 6:
in order to further reduce the communication delay, in the foregoing embodiments of the present application, the target intelligent gateway is specifically configured to, after establishing a connection with the resource demand device 301, obtain, according to information of the first task carried in the resource request, the first task of the resource demand device 301, execute the first task, and return an execution result of the first task to the resource demand device 301.
In the current push type resource demand task, the intelligent gateway starts a process, first information of the resource quantity which can be provided by the intelligent gateway is sent to resource demand equipment, then the resource demand equipment initiates a connection request with the intelligent gateway after receiving the first information, and after the intelligent gateway establishes connection with the resource demand equipment, the resource demand equipment sends task information to the intelligent gateway, so that the intelligent gateway processes the task; at present, a push type resource demand task starts a process through an intelligent gateway and acquires task information from resource demand equipment, and more processes are needed, so that communication delay is increased. Therefore, in the embodiment of the present application, after the connection between the target intelligent gateway and the resource demand device 301 is established, the target intelligent gateway acquires the first task of the resource demand device in a pull mode according to the information of the first task carried in the resource request, executes the first task, and returns the execution result of the first task to the resource demand device 301.
In the embodiment of the application, the push type is changed into the pull type, so that the cooperative scheduling decision time delay is saved, the scheduling algorithm gives an accurate scheduling scheme in the millisecond solving time, and the communication time delay is further reduced.
Example 7:
based on the same concept, the present application provides a communication method based on the above embodiments, and fig. 10 is a schematic diagram of a distributed resource cooperative scheduling process provided by the embodiment of the present application, where the process includes:
s1001: and acquiring a resource request sent by the resource request equipment, wherein the resource request carries first resource quantity required by the resource demand equipment and information of a first task.
The distributed resource cooperative scheduling method provided by the embodiment of the application is applied to the aggregation switching equipment shown in each embodiment.
S1002: and sending a resource request to each intelligent gateway connected with the convergence switching equipment, and receiving a connection request returned by each intelligent gateway, wherein the connection request carries a second resource amount to be provided by the corresponding intelligent gateway and identification information of the intelligent gateway.
S1003: determining a target intelligent gateway connected with the resource demand equipment according to the first resource quantity and each second resource quantity; and sending a target connection request corresponding to the target intelligent gateway to the resource demand equipment, so that the resource demand equipment and the target intelligent gateway are connected, and the target intelligent gateway executes a first task after the connection is established with the resource demand equipment.
In the embodiment of the application, the convergence switching equipment directly communicates with the resource demand equipment and the intelligent gateway, and the participation of a resource perception center platform is not needed, so that the cooperative scheduling decision time delay can be saved, and the communication time delay is reduced.
In order to further reduce the communication delay, in the embodiments of the present application, if the target intelligent gateway includes a plurality of target intelligent gateways, the method further includes:
after the resource demand equipment and the target intelligent gateways are connected, according to the first resource quantity and the second resource quantity to be provided by each target intelligent gateway, dividing the first task into subtasks with the quantity corresponding to the quantity of the target intelligent gateways, sending each subtask to the corresponding target intelligent gateway, enabling any target intelligent gateway to execute the subtasks corresponding to the target intelligent gateways, and sending the subtask execution results to the resource demand equipment.
In order to further reduce the communication delay, on the basis of the above embodiments, in the embodiment of the present application, the method further includes:
judging whether the response of any intelligent gateway connected with the convergence switching device to the resource request is overtime, if not, monitoring whether the connection request sent by the intelligent gateway is received.
In order to further reduce the communication delay, on the basis of the above embodiments, in the embodiment of the present application, the method further includes:
when judging that the response time of all intelligent gateways connected with the convergence switching equipment to the resource request is out, forwarding the resource request to other convergence switching equipment to enable the other convergence switching equipment to forward the resource request to the inter-domain intelligent gateway after receiving the resource request, receiving the inter-domain connection request of the inter-domain intelligent gateway in response to the resource request, and sending the inter-domain connection request to the convergence switching equipment; the inter-domain connection request carries a third resource amount to be provided by the inter-domain intelligent gateway and identification information of the inter-domain intelligent gateway.
In order to further reduce the communication delay, on the basis of the above embodiments, in the embodiment of the present application, the method further includes:
judging whether the total amount of the second resource amount to be provided meets the first resource amount according to the second resource amount to be provided of the corresponding intelligent gateway carried in each received connection request, and if yes, not forwarding the received connection requests of other intelligent gateways to resource demand equipment.
Example 8:
based on the same technical concept, the present application provides a distributed resource cooperative scheduling device based on the above embodiments, and fig. 11 is a schematic structural diagram of a distributed resource cooperative scheduling device provided by the embodiment of the present application, as shown in fig. 11, where the device includes:
An obtaining module 1101, configured to obtain a resource request sent by a resource request device, where the resource request carries a first resource amount and information of a first task required by a resource demand device;
the forwarding module 1102 is configured to send a resource request to each intelligent gateway connected to the aggregation switching device, and receive a connection request returned by each intelligent gateway, where the connection request carries a second resource amount to be provided by a corresponding intelligent gateway and identification information of the intelligent gateway;
a determining module 1103, configured to determine, according to the first resource amount and each second resource amount, a target intelligent gateway that establishes a connection with the resource demand device; and sending a target connection request corresponding to the target intelligent gateway to the resource demand equipment, so that the resource demand equipment and the target intelligent gateway are connected, and the target intelligent gateway executes a first task after the connection is established with the resource demand equipment.
In a possible implementation manner, the determining module 1103 is further configured to, if the target intelligent gateways include a plurality of target intelligent gateways, divide the first task into a number of subtasks corresponding to the number of target intelligent gateways according to the first resource amount and the second resource amount to be provided by each target intelligent gateway after the resource demand device and the target intelligent gateways establish a connection, send each subtask to the corresponding target intelligent gateway, enable any target intelligent gateway to execute the subtask corresponding to the target intelligent gateway, and send the subtask execution result to the resource demand device.
In a possible implementation manner, the forwarding module 1102 is further configured to determine whether a response of any intelligent gateway connected to the aggregation switching device to the resource request is overtime, and if not, monitor whether a connection request sent by the intelligent gateway is received.
In a possible implementation manner, the forwarding module 1102 is further configured to, when determining that responses of all intelligent gateways connected to the aggregation switching device to the resource request are over time, forward the resource request to other aggregation switching devices, so that the other aggregation switching devices forward the resource request to the inter-domain intelligent gateway after receiving the resource request, receive an inter-domain connection request of the inter-domain intelligent gateway in response to the resource request, and send the inter-domain connection request to the aggregation switching device; the inter-domain connection request carries a third resource amount to be provided by the inter-domain intelligent gateway and identification information of the inter-domain intelligent gateway.
In a possible implementation manner, the determining module 1103 is further configured to determine, according to the second resource amount to be provided by the corresponding intelligent gateway carried in each received connection request, whether the total amount of the second resource amount to be provided meets the first resource amount, and if yes, not forward the received connection request of other intelligent gateways to the resource demand device.
Example 9:
based on the same technical concept, the present application further provides an electronic device, and fig. 12 is a schematic structural diagram of an electronic device provided by an embodiment of the present application, as shown in fig. 12, including: the device comprises a processor 1201, a communication interface 1202, a memory 1203 and a communication bus 1204, wherein the processor 1201, the communication interface 1202 and the memory 1203 are communicated with each other through the communication bus 1204;
the memory 1203 has stored therein a computer program which, when executed by the processor 1201, causes the processor 1201 to perform the steps of:
acquiring a resource request sent by resource request equipment, wherein the resource request carries first resource quantity required by resource demand equipment and information of a first task;
sending a resource request to each intelligent gateway connected with the convergence switching equipment, and receiving a connection request returned by each intelligent gateway, wherein the connection request carries a second resource amount to be provided by the corresponding intelligent gateway and identification information of the intelligent gateway;
determining a target intelligent gateway connected with the resource demand equipment according to the first resource quantity and each second resource quantity; and sending a target connection request corresponding to the target intelligent gateway to the resource demand equipment, so that the resource demand equipment and the target intelligent gateway are connected, and the target intelligent gateway executes a first task after the connection is established with the resource demand equipment.
In a possible implementation manner, the processor 1201 is further configured to divide, after the connection between the resource demand device and the target intelligent gateways is established, the first task into a number of subtasks corresponding to the number of the target intelligent gateways according to the first resource amount and the second resource amount to be provided by each target intelligent gateway, and send each subtask to the corresponding target intelligent gateway, so that any target intelligent gateway executes the subtask corresponding to the target intelligent gateway, and send the subtask execution result to the resource demand device.
In a possible implementation manner, the processor 1201 is further configured to determine whether a response of any intelligent gateway connected to the aggregation switch device to the resource request is overtime, and if not, monitor whether a connection request sent by the intelligent gateway is received.
In one possible implementation manner, the processor 1201 is further configured to, when determining that responses of all intelligent gateways connected to the aggregation switching device to the resource request are over time, forward the resource request to other aggregation switching devices, so that the other aggregation switching devices forward the resource request to the inter-domain intelligent gateway after receiving the resource request, receive an inter-domain connection request of the inter-domain intelligent gateway in response to the resource request, and send the inter-domain connection request to the aggregation switching device; the inter-domain connection request carries a third resource amount to be provided by the inter-domain intelligent gateway and identification information of the inter-domain intelligent gateway.
In a possible implementation manner, the processor 1201 is further configured to determine, according to the second resource amount to be provided by the corresponding intelligent gateway carried in each received connection request, whether the total amount of the second resource amount to be provided meets the first resource amount, and if yes, not forward the received connection request of the other intelligent gateway to the resource demand device.
The communication bus mentioned above for the electronic devices may be a peripheral component interconnect standard (Peripheral Component Interconnect, PCI) bus or an extended industry standard architecture (Extended Industry Standard Architecture, EISA) bus, etc. The communication bus may be classified as an address bus, a data bus, a control bus, or the like. For ease of illustration, the figures are shown with only one bold line, but not with only one bus or one type of bus.
The communication interface 1202 is used for communication between the above-described electronic device and other devices.
The Memory may include random access Memory (Random Access Memory, RAM) or may include Non-Volatile Memory (NVM), such as at least one disk Memory. Optionally, the memory may also be at least one memory device located remotely from the aforementioned processor.
The processor may be a general-purpose processor, including a central processing unit, a network processor (Network Processor, NP), etc.; but also digital instruction processors (Digital Signal Processing, DSP), application specific integrated circuits, field programmable gate arrays or other programmable logic devices, discrete gate or transistor logic devices, discrete hardware components, etc.
Example 10:
based on the same technical idea, an embodiment of the present application provides a computer readable storage medium, in which a computer program executable by an electronic device is stored, which when executed on the electronic device causes the electronic device to implement any of the above embodiments.
The computer readable storage medium may be any available medium or data storage device that can be accessed by a processor in an electronic device, including but not limited to magnetic memories such as floppy disks, hard disks, magnetic tapes, magneto-optical disks (MO), etc., optical memories such as CD, DVD, BD, HVD, etc., and semiconductor memories such as ROM, EPROM, EEPROM, nonvolatile memories (NAND FLASH), solid State Disks (SSD), etc.
It will be appreciated by those skilled in the art that embodiments of the present application may be provided as a method, system, or computer program product. Accordingly, the present application may take the form of an entirely hardware embodiment, an entirely software embodiment or an embodiment combining software and hardware aspects. Furthermore, the present application may take the form of a computer program product embodied on one or more computer-usable storage media (including, but not limited to, disk storage, CD-ROM, optical storage, and the like) having computer-usable program code embodied therein.
The present application is described with reference to flowchart illustrations and/or block diagrams of methods, apparatus (systems) and computer program products according to the application. It will be understood that each flow and/or block of the flowchart illustrations and/or block diagrams, and combinations of flows and/or blocks in the flowchart illustrations and/or block diagrams, can be implemented by computer program instructions. These computer program instructions may be provided to a processor of a general purpose computer, special purpose computer, embedded processor, or other programmable data processing apparatus to produce a machine, such that the instructions, which execute via the processor of the computer or other programmable data processing apparatus, create means for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be stored in a computer-readable memory that can direct a computer or other programmable data processing apparatus to function in a particular manner, such that the instructions stored in the computer-readable memory produce an article of manufacture including instruction means which implement the function specified in the flowchart flow or flows and/or block diagram block or blocks.
These computer program instructions may also be loaded onto a computer or other programmable data processing apparatus to cause a series of operational steps to be performed on the computer or other programmable apparatus to produce a computer implemented process such that the instructions which execute on the computer or other programmable apparatus provide steps for implementing the functions specified in the flowchart flow or flows and/or block diagram block or blocks.
It will be apparent to those skilled in the art that various modifications and variations can be made to the present application without departing from the spirit or scope of the application. Thus, it is intended that the present application also include such modifications and alterations insofar as they come within the scope of the appended claims or the equivalents thereof.