WO2023155802A1 - 数据调度方法、装置、设备及存储介质 - Google Patents

数据调度方法、装置、设备及存储介质 Download PDF

Info

Publication number
WO2023155802A1
WO2023155802A1 PCT/CN2023/076165 CN2023076165W WO2023155802A1 WO 2023155802 A1 WO2023155802 A1 WO 2023155802A1 CN 2023076165 W CN2023076165 W CN 2023076165W WO 2023155802 A1 WO2023155802 A1 WO 2023155802A1
Authority
WO
WIPO (PCT)
Prior art keywords
forwarding
data
processing logic
queue
network element
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Ceased
Application number
PCT/CN2023/076165
Other languages
English (en)
French (fr)
Inventor
程志密
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Datang Mobile Communications Equipment Co Ltd
Original Assignee
Datang Mobile Communications Equipment Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Datang Mobile Communications Equipment Co Ltd filed Critical Datang Mobile Communications Equipment Co Ltd
Priority to JP2024547292A priority Critical patent/JP2025505462A/ja
Priority to KR1020247029076A priority patent/KR20240144293A/ko
Priority to EP23755804.4A priority patent/EP4482115A4/en
Publication of WO2023155802A1 publication Critical patent/WO2023155802A1/zh
Anticipated expiration legal-status Critical
Ceased legal-status Critical Current

Links

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00—Traffic control in data switching networks
    • H04L47/50—Queue scheduling
    • H04L47/56—Queue scheduling implementing delay-aware scheduling
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00—Traffic control in data switching networks
    • H04L47/50—Queue scheduling
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00—Traffic control in data switching networks
    • H04L47/10—Flow control; Congestion control
    • H04L47/18—End to end
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00—Traffic control in data switching networks
    • H04L47/10—Flow control; Congestion control
    • H04L47/20—Traffic policing
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04W—WIRELESS COMMUNICATION NETWORKS
    • H04W40/00—Communication routing or communication path finding
    • H04W40/24—Connectivity information management, e.g. connectivity discovery or connectivity update
    • H04W40/248—Connectivity information update
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L47/00—Traffic control in data switching networks
    • H04L47/10—Flow control; Congestion control
    • H04L47/28—Flow control; Congestion control in relation to timing considerations
    • H04L47/283—Flow control; Congestion control in relation to timing considerations in response to processing delays, e.g. caused by jitter or round trip time [RTT]
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04W—WIRELESS COMMUNICATION NETWORKS
    • H04W40/00—Communication routing or communication path finding
    • H04W40/24—Connectivity information management, e.g. connectivity discovery or connectivity update
    • H04W40/246—Connectivity information discovery

Definitions

  • the present disclosure relates to the technical field of communications, and in particular, to a data scheduling method, device, device, and storage medium.
  • Deterministic Networking can realize the definite data transmission path in the second layer bridge and the third layer routing segment, according to these paths, the worst case limit of delay, packet loss and jitter can be determined, so as to control and reduce end-to-end latency.
  • the sending end will periodically measure the packet loss, delay, and jitter of each path, according to algorithms such as the shortest delay, minimum packet loss, or minimum jitter
  • a corresponding sending path is selected for the data stream, where at least one forwarding device is included in the sending path.
  • the forwarding device when forwards the data flow, it will insert the data flow into the corresponding queue according to the priority of the data flow, so as to reduce the delay and jitter of the high-priority data flow as much as possible, while the low-priority data flow will wait in line or be discarded.
  • the queuing delay of the data flow cannot be determined, the delay on the sending path cannot be determined, and thus the delay cannot be controlled.
  • the present disclosure provides a data scheduling method, device, device and storage medium, which are used to ensure the determinism of data transmission delay in a deterministic network, thereby realizing the control of end-to-end delay in a deterministic network.
  • the present disclosure provides a data scheduling method, which is applied to a network element with a network control function.
  • the data scheduling method includes: obtaining packet processing logic of a data stream, and the packet processing logic is based on a queue configuration rule of a forwarding port of a forwarding device Obtained, the queue configuration rule is determined according to the data forwarding cycle of the forwarding device and the queue number of the message queue supported by the forwarding port of the forwarding device; the message processing logic is configured for the target forwarding device, and the message processing logic is used for the corresponding data flow forwarding.
  • obtaining the message processing logic of the data flow includes: receiving the first data packet sent by the forwarding device; and obtaining the message processing logic based on the first data packet and queue configuration rules.
  • the message processing logic is obtained based on the first data packet and the queue configuration rule, including: parsing the first data packet to obtain the demand information of the data flow; obtaining the message processing logic according to the demand information and the queue configuration rule .
  • obtain message processing logic including: The functional network element sends the demand information; receives the routing and forwarding rules obtained by the policy management functional network element according to the demand information and queue configuration rules; obtains the packet processing logic according to the routing and forwarding rules.
  • obtaining the message processing logic includes: sending the first data packet to the network element with the policy management function, for the network element with the policy management function to obtain the information of the data flow according to the first data packet Requirement information; receive routing and forwarding rules obtained by network elements with policy management functions according to the requirement information and queue configuration rules; obtain message processing logic according to routing and forwarding rules.
  • the message processing logic is obtained, including: according to the routing and forwarding rules, determining the queue information of the data flow, the queue information is used to indicate the queue used to send the data flow; according to the queue information and the routing and forwarding rules, Obtain the packet processing logic.
  • obtaining message processing logic according to routing and forwarding rules includes: receiving queue information obtained by network elements with policy management functions according to demand information; obtaining message processing logic according to routing forwarding rules and queue information.
  • the obtained message processing logic includes: parsing the first data packet to obtain the demand information of the data flow; sending the demand information to the policy management function network element; receiving the policy The message processing logic obtained by the management function network element according to the demand information.
  • the obtained message processing logic includes: sending the first data packet to the policy management function network element; receiving the message obtained by the policy management function network element according to the first data packet processing logic.
  • the message processing logic of the data flow before obtaining the message processing logic of the data flow, it also includes: determining the queue configuration rules of the forwarding port according to the data forwarding cycle of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; or, Receive the queue configuration rule sent by the policy management function network element; wherein, the queue configuration rule is used to indicate the data forwarding time of each message queue within the forwarding cycle of the forwarding port, and the length of the data forwarding time is the data forwarding cycle of the forwarding device.
  • the present disclosure provides a data scheduling method, which is applied to network elements with policy management functions.
  • the data scheduling method includes: obtaining demand information of data flows; determining routing and forwarding rules according to the demand information and queue configuration rules, and the queue configuration rules are Determined according to the data forwarding cycle of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; determine the message processing logic of the data flow according to the routing and forwarding rules; send the message processing logic to the network control function network element, the message The processing logic is used for forwarding of corresponding data streams.
  • determining message processing logic according to routing and forwarding rules includes: determining queue information for processing data flows according to demand information and queue configuration rules; determining message processing logic according to routing forwarding rules and queue information.
  • the present disclosure provides a data scheduling method, which is applied to network elements with policy management functions.
  • the data scheduling method includes: obtaining demand information of data streams; obtaining routing and forwarding rules according to the demand information and queue configuration rules, and the queue configuration rules are It is determined according to the data forwarding period of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; the routing and forwarding rules are sent to the network element with the network control function, and the routing and forwarding rules are used to determine the message processing logic. For the forwarding of the corresponding data stream.
  • sending the routing and forwarding rules to the network control function network element including: determining the queue information according to the demand information and queue configuration rules; sending the queue information and routing forwarding rules to the network control function network element for the network control function network element Determine the message processing logic according to routing forwarding rules and queue information.
  • obtaining the demand information of the data flow includes: receiving the first data sent by the network element of the network control function Requirements information for the data flow in the package.
  • acquiring the demand information of the data flow includes: receiving a first data packet sent by a network element with a network control function; parsing the first data packet to obtain the demand information of the data flow.
  • the queue configuration rule sent by the functional network element; wherein, the queue configuration rule is used to indicate the data forwarding time of each message queue within the forwarding cycle of the forwarding port, and the length of the data forwarding time is the data forwarding cycle of the forwarding device.
  • an embodiment of the present disclosure provides a data scheduling method, which is applied to a forwarding device.
  • the data scheduling method includes: in response to receiving a data flow to be processed, determining a target queue for forwarding the data flow to be processed based on packet processing logic ; Based on the queue configuration rules of the forwarding device, determine the forwarding time of the data flow to be processed, and the message processing logic is configured by the network control function network element for the forwarding device; forward the data flow to be processed at the forwarding time through the target queue.
  • the data scheduling method further includes: sending the first data packet to the network control function network element; receiving message processing logic obtained by the network control function network element according to the first data packet.
  • the embodiment of the present disclosure provides a data scheduling device, which is applied to a network element with a network control function.
  • the data scheduling device includes: an acquisition module, used to acquire the message processing logic of the data stream, and the queue configuration rule is based on the forwarding device The data forwarding cycle and the number of message queues supported by the forwarding port of the forwarding device are determined; the configuration module is used to configure message processing logic for the target forwarding device, and is used for forwarding corresponding data streams.
  • the acquiring module is specifically configured to: receive the first data packet sent by the forwarding device; and obtain message processing logic based on the first data packet and queue configuration rules.
  • the obtaining module is specifically configured to: analyze the first data packet to obtain demand information of the data flow; obtain message processing logic according to the demand information and queue configuration rules.
  • the obtaining module is specifically used to: send demand information to the network element with policy management function; receive routing and forwarding rules obtained by the network element with policy management function according to the demand information and queue configuration rules; obtain message processing logic according to the routing and forwarding rules.
  • the acquisition module is specifically configured to: send the first data packet to the policy management function network element, and use the policy management function network element to obtain the demand information of the data flow according to the first data packet; receive the policy management function network element according to the demand information and the routing and forwarding rules obtained from the queue configuration rules; according to the routing and forwarding rules, the packet processing logic is obtained.
  • the obtaining module is specifically used to: determine the queue information of the data flow according to the routing and forwarding rules, and the queue information is used to indicate the queue used to send the data flow; obtain the message processing logic according to the queue information and the routing and forwarding rules.
  • the obtaining module is specifically used to: receive queue information obtained by the policy management function network element according to the demand information; obtain message processing logic according to the routing forwarding rules and queue information.
  • the acquisition module is specifically used to: analyze the first data packet to obtain the demand information of the data flow; send the demand information to the policy management function network element; receive the message processing logic obtained by the policy management function network element according to the demand information .
  • the obtaining module is specifically configured to: send the first data packet to the network element with the policy management function; receive the message processing logic obtained by the network element with the policy management function according to the first data packet.
  • the data scheduling device further includes: a determination module, configured to determine the queue configuration rules of the forwarding port according to the data forwarding cycle of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; or, the receiving module , used to receive the queue configuration rules sent by the policy management function network element; wherein, the queue configuration rules are used to indicate the data forwarding time of each message queue within the forwarding period of the forwarding port, and the length of the data forwarding time is the data forwarding period of the forwarding device .
  • an embodiment of the present disclosure provides a data scheduling device, which is applied to a network element with a policy management function, and the data scheduling device includes:
  • the acquisition module is used to obtain the demand information of the data stream; the determination module is used to determine the routing and forwarding rules according to the demand information and queue configuration rules, and determine the message processing logic of the data stream according to the routing and forwarding rules.
  • the queue configuration rules are based on the forwarding device The data forwarding cycle and the number of message queues supported by the forwarding port of the forwarding device are determined; the sending module is used to send the message processing logic to the network control function network element, and the message processing logic is used for forwarding the corresponding data flow.
  • the determining module is specifically configured to: determine queue information for processing data flows according to demand information and queue configuration rules; determine message processing logic according to routing forwarding rules and queue information.
  • an embodiment of the present disclosure provides a data scheduling device, which is applied to a network element with a policy management function.
  • the data scheduling device includes: an acquisition module, used to acquire demand information of a data flow, and obtain a route according to the demand information and queue configuration rules. Forwarding rules and queue configuration rules are determined according to the data forwarding period of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; the sending module is used to send routing and forwarding rules to network elements with network control functions. To determine the message processing logic, the message processing logic is used for forwarding the corresponding data flow.
  • the sending module is specifically used to: determine queue information according to demand information and queue configuration rules; send queue information and routing forwarding rules to the network control function network element, and use the network control function network element according to the routing forwarding rules and queue information , to determine the packet processing logic.
  • the obtaining module is specifically configured to: receive the demand information of the data flow in the first data packet sent by the network element with the network control function.
  • the obtaining module is specifically configured to: receive the first data packet sent by the network element with the network control function; analyze the first data packet to obtain the demand information of the data flow.
  • the data scheduling device further includes: a determining module, configured to determine the queue configuration rules of the forwarding port according to the data forwarding period of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; or, receive network control The queue configuration rule sent by the functional network element; wherein, the queue configuration rule is used to indicate the data forwarding time of each message queue within the forwarding cycle of the forwarding port, and the length of the data forwarding time is the data forwarding cycle of the forwarding device.
  • a determining module configured to determine the queue configuration rules of the forwarding port according to the data forwarding period of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; or, receive network control The queue configuration rule sent by the functional network element; wherein, the queue configuration rule is used to indicate the data forwarding time of each message queue within the forwarding cycle of the forwarding port, and the length of the data forwarding time is the data forwarding cycle of the forwarding device.
  • an embodiment of the present disclosure provides a data scheduling device, which is applied to a forwarding device.
  • the data scheduling device includes: a determining module, configured to determine the forwarding pending data stream based on message processing logic in response to receiving the data stream to be processed.
  • the target queue of the data flow is based on the queue configuration rules of the forwarding device to determine the forwarding time of the data flow to be processed.
  • the message processing logic is configured by the network control function network element for the forwarding device; Time to forward pending data streams.
  • the data scheduling device further includes: a sending module, configured to send the first data packet to the network control function network element; a receiving module, configured to receive the message processing logic obtained by the network control function network element according to the first data packet .
  • the embodiment of the present disclosure provides a network control function network element, including: a memory, used to store computer programs; a transceiver, used to send and receive data under the control of a processor; a processor, used to read the computer program and do the following:
  • the message processing logic is obtained based on the queue configuration rules of the forwarding port of the forwarding device, and the queue configuration rules are based on the data forwarding cycle of the forwarding device and the message queue supported by the forwarding port of the forwarding device The number of queues is determined; the message processing logic is configured for the target forwarding device for the forwarding of the corresponding data flow.
  • obtaining the message processing logic of the data flow includes: receiving the first data packet sent by the forwarding device; and obtaining the message processing logic based on the first data packet and queue configuration rules.
  • the message processing logic is obtained based on the first data packet and the queue configuration rule, including: parsing the first data packet to obtain the demand information of the data flow; obtaining the message processing logic according to the demand information and the queue configuration rule .
  • the message processing logic is obtained according to the demand information and the queue configuration rules, including: sending the demand information to the network element with the policy management function; receiving the routing and forwarding rules obtained by the network element with the policy management function according to the demand information and the queue configuration rules; Routing and forwarding rules to obtain message processing logic.
  • obtaining the message processing logic includes: sending the first data packet to the network element with the policy management function, for the network element with the policy management function to obtain the information of the data flow according to the first data packet Requirement information; receive routing and forwarding rules obtained by network elements with policy management functions according to the requirement information and queue configuration rules; obtain message processing logic according to routing and forwarding rules.
  • the message processing logic is obtained, including: according to the routing and forwarding rules, determining the queue information of the data flow, the queue information is used to indicate the queue used to send the data flow; according to the queue information and the routing and forwarding rules, Obtain the packet processing logic.
  • obtaining message processing logic according to routing and forwarding rules includes: receiving queue information obtained by network elements with policy management functions according to demand information; obtaining message processing logic according to routing forwarding rules and queue information.
  • the obtained message processing logic includes: parsing the first data packet to obtain the demand information of the data flow; sending the demand information to the policy management function network element; receiving the policy The message processing logic obtained by the management function network element according to the demand information.
  • the obtained message processing logic includes: sending the first data packet to the policy management function network element; receiving the message obtained by the policy management function network element according to the first data packet processing logic.
  • the processor is also used to: determine the queue configuration rules of the forwarding port according to the data forwarding cycle of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device ; Or, receiving the queue configuration rule sent by the policy management function network element; the queue configuration rule is used to indicate the data forwarding time of each message queue within the forwarding cycle of the forwarding port, and the duration of the data forwarding time is the data forwarding cycle of the forwarding device.
  • an embodiment of the present disclosure provides a network element with a policy management function, including:
  • a memory for storing a computer program; a transceiver for sending and receiving data under the control of the processor; a processor for reading the computer program in the memory and performing the following operations: obtaining demand information of the data stream; according to the demand information and Queue configuration rules, determine routing and forwarding rules, queue configuration rules are based on the data of forwarding devices The forwarding cycle and the number of message queues supported by the forwarding port of the forwarding device are determined; the message processing logic of the data flow is determined according to the routing and forwarding rules; the message processing logic is sent to the network control function network element, and the message processing logic is used for corresponding data flow forwarding.
  • determining message processing logic according to routing and forwarding rules includes: determining queue information for processing data flows according to demand information and queue configuration rules; determining message processing logic according to routing forwarding rules and queue information.
  • an embodiment of the present disclosure provides a network element with a policy management function, including: a memory for storing computer programs; a transceiver for sending and receiving data under the control of a processor; a processor for reading the memory and perform the following operations: obtain the demand information of the data flow; obtain the routing and forwarding rules according to the demand information and queue configuration rules, and the queue configuration rules are based on the data forwarding cycle of the forwarding device and the message queue supported by the forwarding port of the forwarding device The number of queues is determined; the routing forwarding rule is sent to the network element of the network control function, and the routing forwarding rule is used to determine the message processing logic, and the message processing logic is used for forwarding the corresponding data flow.
  • sending the routing and forwarding rules to the network control function network element including: determining the queue information according to the demand information and queue configuration rules; sending the queue information and routing forwarding rules to the network control function network element for the network control function network element Determine the message processing logic according to routing forwarding rules and queue information.
  • acquiring the requirement information of the data flow includes: receiving the requirement information of the data flow in the first data packet sent by the network element with the network control function.
  • acquiring the demand information of the data flow includes: receiving a first data packet sent by a network element with a network control function; parsing the first data packet to obtain the demand information of the data flow.
  • the processor is further configured to: determine the queue configuration rules of the forwarding port according to the data forwarding period of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; or, Receive the queue configuration rule sent by the network control function network element; wherein, the queue configuration rule is used to indicate the data forwarding time of each message queue within the forwarding cycle of the forwarding port, and the duration of the data forwarding time is the data forwarding cycle of the forwarding device.
  • an embodiment of the present disclosure provides a forwarding device, including: a memory, used to store computer programs; a transceiver, used to send and receive data under the control of a processor; a processor, used to read the computer program stored in the memory program and do the following:
  • the target queue for forwarding the data flow to be processed based on the message processing logic; determine the forwarding time of the data flow to be processed based on the queue configuration rules of the forwarding device.
  • the message processing logic is network control
  • the functional network element is configured for the forwarding device; through the target queue, the pending data flow is forwarded at the forwarding time.
  • the processor is further configured to: send the first data packet to the network element with the network control function; and receive the message processing logic obtained by the network element with the network control function according to the first data packet.
  • an embodiment of the present disclosure provides a processor-readable storage medium, where a computer program is stored in the processor-readable storage medium, and the computer program is used to enable the processor to execute the first aspect, the second aspect, the third aspect and The data scheduling method of any one of the fourth aspects.
  • an embodiment of the present disclosure provides a computer program product, including: a computer program, when the computer program is executed by a processor, any one of the first aspect, the second aspect, the third aspect and the fourth aspect can be realized Data scheduling method.
  • the data scheduling method, device, device, and storage medium provided by the present disclosure, the message processing logic of the network control function network element to obtain the data flow; and the message processing logic configured for the target forwarding device, which is used for the target forwarding device based on the message processing logic , to forward the corresponding data flow.
  • each data stream will be forwarded in a specific queue and according to a specific forwarding time, which can accurately determine the delay of the data transmission process, and then realize the control of the end-to-end delay in the deterministic network.
  • FIG. 1 is a schematic diagram of an application scenario provided by an embodiment of the present disclosure
  • FIG. 2 is a schematic flowchart of a data scheduling method provided by an embodiment of the present disclosure
  • FIG. 3 is a first schematic flowchart of a message processing logic configuration mode provided by an embodiment of the present disclosure
  • FIG. 4 is a second schematic flow diagram of a message processing logic configuration mode provided by an embodiment of the present disclosure.
  • FIG. 5 is a third schematic flowchart of a message processing logic configuration mode provided by an embodiment of the present disclosure.
  • FIG. 6 is a fourth schematic flowchart of a message processing logic configuration method provided by an embodiment of the present disclosure.
  • FIG. 7 is a schematic flow diagram five of a message processing logic configuration mode provided by an embodiment of the present disclosure.
  • FIG. 8 is a sixth schematic flow diagram of a message processing logic configuration method provided by an embodiment of the present disclosure.
  • FIG. 9 is a schematic flow diagram VII of a packet processing logic configuration method provided by an embodiment of the present disclosure.
  • FIG. 10 is an eighth schematic flowchart of a packet processing logic configuration method provided by an embodiment of the present disclosure.
  • FIG. 11 is a schematic flowchart of a message processing logic configuration method provided in an embodiment of the present disclosure (9);
  • FIG. 12 is a first structural schematic diagram of a data scheduling device provided by an embodiment of the present disclosure.
  • FIG. 13 is a second structural schematic diagram of a data scheduling device provided by an embodiment of the present disclosure.
  • FIG. 14 is a schematic structural diagram III of a data scheduling device provided by an embodiment of the present disclosure.
  • FIG. 15 is a fourth structural schematic diagram of a data scheduling device provided by an embodiment of the present disclosure.
  • FIG. 16 is a schematic structural diagram of a network element with a network control function provided by an embodiment of the present disclosure
  • FIG. 17 is a schematic structural diagram of a network element with a policy management function provided by an embodiment of the present disclosure.
  • FIG. 18 is a schematic structural diagram of a forwarding device provided by an embodiment of the present disclosure.
  • Application Plane The plane where applications and services that define network behavior reside.
  • Control Plane Decide how one or more network devices forward data packets, and send these decisions to the network devices in the form of flow tables for execution.
  • Management Plane responsible for monitoring, configuring, and maintaining network devices, for example, making decisions about the status of network devices.
  • the management plane mainly interacts with the operation plane of the device.
  • Forwarding Plane A functional module responsible for processing packets in the data path according to instructions received from the control plane.
  • the operations of the forwarding plane include, but are not limited to, forwarding, dropping, and altering packets.
  • Operational Plane responsible for managing the operational status of the network device where it resides, for example, whether the device is active or inactive, the number of available ports, the status of each port, and so on.
  • the operation plane is responsible for network device resources, such as ports and memory.
  • FIG. 1 is a schematic diagram of an application scenario provided by an embodiment of the present disclosure. As shown in FIG. 1 , this scenario includes: a network element with a network control function, a network element with a policy management function, and a forwarding device.
  • the network control function network element is located in the control plane
  • the policy management function network element is located in the application plane
  • the forwarding device is located in the forwarding plane.
  • the type of the forwarding device is not specifically limited.
  • the forwarding device can be a network device with a data forwarding function such as a base station, specifically, it can be a Global System of Mobile communication (GSM) or , a base station and/or a base station controller in Code Division Multiple Access (CDMA), or a base station (NodeB, NB) and/or in Wideband Code Division Multiple Access (WCDMA) Or a radio network controller (Radio Network Controller, RNC), or an evolved base station (Evolutional NodeB, 4G base station or eNodeB) in the long-term evolution (Long Term Evolution, LTE), or a relay station or an access point, or a future 5G Base stations (5G base stations) in the network, etc.
  • GSM Global System of Mobile communication
  • CDMA Code Division Multiple Access
  • NodeB, NB base station
  • WCDMA Wideband Code Division Multiple Access
  • RNC Radio Network Controller
  • Evolutional NodeB, 4G base station or eNodeB in
  • FIG. 1 exemplarily shows a communication scenario of a network control function network element, a policy management function network element, and a forwarding device.
  • other devices may also be included in this scenario.
  • the implementation of the present disclosure Examples are not limited to this.
  • DetNet network implement deterministic transmission paths for Layer 2 bridges and Layer 3 routing segments that provide worst-case bounds on delay, packet loss, and jitter to control and reduce end-to-end latency Technology.
  • the current processing method of the Internet Engineering Task Force (IETF) for the DetNet data flow is to use the processing method in the Time-Sensitive Networking (TSN)
  • TSN Time-Sensitive Networking
  • the IETF has not yet defined these For how the processing technology of L2 data frames is used by DetNet nodes, if the existing IP forwarding mechanism is adopted, although resource reservation and priority scheduling are used together, But the lack of control over the behavior of each data packet results in queuing to form microbursts.
  • the scheduling module estimates according to the delay and packet loss prediction model, according to the shortest delay/minimum Algorithms such as packet loss/jitter minimum select one of the paths as the sending path of this packet.
  • the sending end assigns a Quality of Service (QoS) level to each data flow.
  • QoS Quality of Service
  • the forwarding device receives a packet, it checks its level and inserts the packet into the corresponding queue according to the level.
  • the forwarding device When the forwarding device is forwarding, it will give priority to processing the high priority packets, and if the priority is the same, it will be processed according to the order of entry. At this time, each group will occupy BUFFER resources according to the priority.
  • the switch will select the lowest-priority packet to discard, and allocate the vacated BUFFER to the new incoming packet.
  • High-priority packets are used, and the delay and jitter of high-priority packets are as low as possible.
  • parameters such as end-to-end delay are monitored through the network.
  • delay estimation is performed in order to expect to arrive at the receiving end according to the expected end-to-end delay.
  • the parameters measured by the network are cumulative parameters, which represent the past time Performance, while network conditions always change instantaneously, this estimate is inaccurate, and due to the lack of control over the behavior of each data packet, queuing to form micro-bursts, or even micro-burst iterations, making deterministic The delay in the network will not be determined, and thus the delay cannot be controlled.
  • an embodiment of the present disclosure provides a data scheduling method, device, device, and storage medium, and the packet processing logic of the data flow is obtained by the network control function network element; the packet processing logic is configured for the target forwarding device, and is used for the target The forwarding device forwards the corresponding data flow based on the packet processing logic.
  • each data stream will be forwarded in a specific queue and according to a specific forwarding time, which can accurately determine the delay of the data transmission process, and then realize the end-to-end delay in the deterministic network. control.
  • the applicable system may be global system of mobile communication (GSM) system, code division multiple access (code division multiple access, CDMA) system, wideband code division multiple access (Wideband Code Division Multiple Access, WCDMA) general packet Wireless service (general packet radio service, GPRS) system, long term evolution (long term evolution, LTE) system, LTE frequency division duplex (frequency division duplex, FDD) system, LTE time division duplex (time division duplex, TDD) system, Long term evolution advanced (LTE-A) system, universal mobile telecommunications system (UMTS), worldwide interoperability for microwave access (WiMAX) system, 5G New Radio (New Radio, NR) system, etc.
  • GSM global system of mobile communication
  • CDMA code division multiple access
  • WCDMA wideband Code Division Multiple Access
  • General packet Wireless service general packet Radio service
  • GPRS general packet Wireless service
  • LTE long term evolution
  • LTE long term evolution
  • FDD frequency division duplex
  • TDD time division duplex
  • LTE-A Long term evolution advanced
  • Fig. 2 is a schematic flowchart of a data scheduling method provided by an embodiment of the present disclosure. As shown in Figure 2, the data scheduling method provided by the embodiment of the present disclosure includes the following steps:
  • a network element with a network control function acquires packet processing logic of a data flow.
  • the packet processing logic is used to instruct the forwarding device to forward the data flow corresponding to the data flow.
  • the message processing logic is obtained based on the queue configuration rule of the forwarding port of the forwarding device, and the queue configuration rule is determined according to the data forwarding cycle of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device Yes, as for how to obtain queue configuration rules, it will be shown in subsequent embodiments.
  • the message processing logic includes: matching domain (for example, IP-six-tuple or IP-five-tuple), priority of data flow, action domain (for example, for forwarding data flow message queue and exit), As for the way of obtaining the message processing logic, it will be shown in the subsequent embodiments.
  • matching domain for example, IP-six-tuple or IP-five-tuple
  • priority of data flow for example, IP-six-tuple or IP-five-tuple
  • action domain for example, for forwarding data flow message queue and exit
  • the network element with the network control function configures message processing logic for the target forwarding device, so that the target forwarding device forwards corresponding data streams based on the message processing logic.
  • the network element with the network control function sends a configuration request to the forwarding device, wherein the configuration request carries the message processing logic, and correspondingly, after receiving the configuration request, the forwarding device obtains the message processing logic carried in it , and configure each forwarding port according to the packet processing logic.
  • the forwarding device may send a configuration response to the network control function network element, where the configuration response is used to indicate that the message processing logic is configured.
  • the forwarding device determines a target queue for forwarding the data flow to be processed based on packet processing logic.
  • the forwarding device when the forwarding device receives the data stream to be processed, it first performs packet matching according to the configured message processing logic, that is, if the received IP-six-tuple (or IP-five-tuple) of the data stream to be processed If it is consistent with the matching domain in a certain message processing logic configured, then based on the priority and action domain in the message processing logic, put the data flow to be processed into the target queue indicated in the message processing logic, Therefore, the target queue is used to forward the data flow to be processed.
  • the configured message processing logic that is, if the received IP-six-tuple (or IP-five-tuple) of the data stream to be processed If it is consistent with the matching domain in a certain message processing logic configured, then based on the priority and action domain in the message processing logic, put the data flow to be processed into the target queue indicated in the message processing logic, Therefore, the target queue is used to forward the data flow to be processed.
  • the data flow to be processed is discarded, or the identification result is reported to the network control function network element.
  • the forwarding device determines the forwarding time of the data flow to be processed based on the queue configuration rule of the forwarding device.
  • the forwarding time corresponding to the target queue is determined, so as to forward the data stream to be processed at the forwarding time.
  • the forwarding device forwards the data flow to be processed at the forwarding time through the target queue.
  • DetNet flow is subsequently determined to be forwarded, data packets are processed based on the priority and action domain in the packet processing logic.
  • a non-DetNet flow when a non-DetNet flow is received, it can also be processed according to the message processing logic, but The priority of the non-DetNet flow is lower than that of the DetNet flow on all forwarding ports, that is, when there is no DetNet flow in the queue, the non-DetNet flow is forwarded, and the non-DetNet flow that cannot be forwarded is discarded. to process.
  • the message processing logic is obtained based on the queue configuration rules of the forwarding port of the forwarding device, and the queue configuration rules are based on the data forwarding period of the forwarding device and the forwarding port of the forwarding device supported
  • the number of queues in the message queue is determined. Therefore, when forwarding data streams, each data stream will be forwarded in a specific queue and according to a specific forwarding time, so that the delay of the data transmission process can be accurately determined, and then the determination of the data stream can be realized. End-to-end delay control in a network.
  • step S201 specifically includes the following steps:
  • the first data packet is the first packet received by the forwarding device after the configuration of the queue configuration rule is completed, and the first data packet includes the demand information of the data flow.
  • the message can obtain the demand information of the data flow contained in the first packet, so as to configure the corresponding message processing logic for the data flow according to the demand information, and when the data flow is subsequently received , the data flow can be processed accordingly according to the packet processing logic.
  • FIG. 3 is a schematic flowchart of a packet processing logic configuration manner provided by an embodiment of the present disclosure.
  • the message processing logic configuration method provided by the embodiment of the present disclosure includes the following steps:
  • the embodiment of the present disclosure does not specifically limit the network element device that acquires the queue configuration rule.
  • the queue configuration rule of the forwarding device may be acquired by the network element with the network control function, and in the second aspect, the queue configuration rule of the forwarding device may also be acquired by the network element with the policy management function.
  • any one of the network control function network element and the policy management function network element may report the queue configuration rule to another network element.
  • FIG. 3 an example is shown in which a network element with a network control function acquires a queue configuration rule of a forwarding device, but it is not limited thereto.
  • the queue configuration rules, forwarding cycle, and forwarding time of each message queue of each forwarding device can be sent to the corresponding forwarding device, which is used for the forwarding device to determine the forwarding time of each message queue. divided.
  • the policy management function network element may first send the queue configuration rules to the network management function network element, and the network management function network element sends the queue configuration rules to the forwarding device for configuration.
  • each forwarding device may include multiple message queues, and the queue configuration rules are used to indicate the data transmission rate of each message queue (for example, maximum transmission rate, minimum transmission rate, and average transmission rate, etc.), each message queue The priority when forwarding data streams, and the corresponding forwarding time of each message queue in the forwarding cycle, etc.
  • any of the above-mentioned network elements obtains the queue configuration rules, firstly, based on the network topology, that is, the location of the forwarding device, the number of message queues supported by the forwarding port of the forwarding device and the forwarding period of the forwarding port are determined, and at the same time Obtain the data transmission rate of each message queue of the forwarding port and the priority when forwarding the data flow.
  • the forwarding cycle is evenly distributed to each message queue, so as to obtain the forwarding time of each message queue in the forwarding cycle, wherein, the duration of the forwarding time corresponding to each message queue Are the same.
  • the queue configuration rule is obtained based on the data transmission rate of each message queue, the priority when forwarding the data stream, and the forwarding time in the forwarding cycle.
  • the forwarding device sends the first data packet to the network element with the network control function.
  • the first data packet is the first packet received by the forwarding device after the configuration of the queue configuration rule is completed, and the first data packet includes the demand information of the data flow.
  • the network element with the network control function parses the first data packet to obtain demand information of the data flow.
  • the requirement information of the data flow includes, but is not limited to, any one or more of the following: DetNet flow characteristics, DetNet flow service requirements, DetNet flow identification, and the like.
  • DetNet flow identification includes DetNet flow, source and destination address, protocol type, port number and other information
  • DetNet flow service requirements include information such as end-to-end maximum delay, jitter, minimum bandwidth, packet loss rate, and maximum number of out-of-sequence packets
  • DetNet flow characteristics include interval, maximum/minimum payload size, number of packets in maximum/minimum time period, etc.
  • the network element with the network control function sends the demand information to the network element with the policy management function.
  • the embodiment of the present disclosure does not specifically limit the method of sending demand information.
  • the network element with the network control function may send a user plane establishment request to the network element with the policy management function, and carry the user plane establishment request in the user plane establishment request.
  • the demand information as for other methods, this disclosure will not repeat them one by one.
  • the policy management functional network element determines routing and forwarding rules according to the demand information and queue configuration rules.
  • the route forwarding rule includes: at least part of the DetNet flow identifier (for discriminating the flow and generating subsequent matching items), for forwarding the message queue of each forwarding device on the forwarding path of the data flow, next hop, priority, each The maximum rate and minimum rate corresponding to the message queue, etc.
  • the network element with the policy management function sends the routing forwarding rule to the network element with the network control function.
  • the embodiment of the present disclosure does not specifically limit the method of sending routing and forwarding rules.
  • the policy management function network element may also send a user plane establishment request to the network control function network element, and establish a user plane request on the user plane.
  • the routing forwarding rule is carried in the request.
  • the network element with the network control function determines the queue information according to the routing and forwarding rules, and obtains message processing logic according to the queue information and the routing and forwarding rules.
  • the queue information is used to indicate the message queue of the forwarding device sending the data flow.
  • the queue information of each forwarding device is obtained from the routing and forwarding rules, so as to generate message processing logic according to the queue information and the routing and forwarding rules.
  • the network control function network element configures message processing logic for the target forwarding device, so that the target forwarding device forwards corresponding data streams based on the message processing logic.
  • step S308 and the way the forwarding device forwards the data flow are the same as those in the embodiment shown in FIG. 2
  • the scheme is the same and will not be repeated here.
  • FIG. 4 is a second schematic flowchart of a packet processing logic configuration manner provided by an embodiment of the present disclosure.
  • the message processing logic configuration method provided by the embodiment of the present disclosure includes the following steps:
  • the forwarding device sends the first data packet to the network element with the network control function.
  • the network element with the network control function parses the first data packet to obtain demand information of the data flow.
  • the network element with the network control function sends the demand information to the network element with the policy management function.
  • steps S401-S404 are similar to those of steps S301-S304 in the embodiment shown in FIG.
  • the network element with the policy management function determines routing and forwarding rules and queue information according to the demand information and queue configuration rules.
  • the queue information can be determined by the network element with the policy management function, and the method of determining the routing and forwarding rules and the method of determining the queue information are the same as those of the network control function network element in the embodiment shown in FIG. 3 The manner of execution is similar and will not be repeated here.
  • the network element with the policy management function sends the routing forwarding rule and queue information to the network element with the network control function.
  • the method of sending routing forwarding rules and queue information is not specifically limited in the embodiments of the present disclosure.
  • the network element with the policy management function may send a user plane establishment request to the network element with the network control function, and in the user plane
  • the route forwarding rule and queue information are carried in the establishment request, and other methods will not be described in detail in this disclosure.
  • the network element with the network control function determines message processing logic according to the routing and forwarding rules and queue information.
  • the network control function network element configures message processing logic for the target forwarding device, so that the target forwarding device forwards corresponding data streams based on the message processing logic.
  • steps S407-S408 are similar to those of steps S307-S308 in the embodiment shown in FIG.
  • FIG. 5 is a third schematic flowchart of a packet processing logic configuration mode provided by an embodiment of the present disclosure. As shown in Figure 5, the message processing logic configuration method provided by the embodiment of the present disclosure includes the following steps:
  • the forwarding device sends the first data packet to the network element with the network control function.
  • the network element with the network control function parses the first data packet to obtain demand information of the data flow.
  • the network element with the network control function sends the demand information to the network element with the policy management function.
  • steps S501-S504 are similar to those of steps S301-S304 in the embodiment shown in FIG. 3 .
  • steps S501-S504 are similar to those of steps S301-S304 in the embodiment shown in FIG. 3 .
  • steps S301-S304 are similar to those of steps S301-S304 in the embodiment shown in FIG. 3 .
  • steps S501-S504 are similar to those of steps S301-S304 in the embodiment shown in FIG. 3 .
  • steps S501-S504 are similar to those of steps S301-S304 in the embodiment shown in FIG. 3 .
  • the policy management function network element determines routing and forwarding rules and queue information according to the requirement information and queue configuration rules, and determines message processing logic according to the queue information and routing and forwarding rules.
  • queue information and message processing logic can be determined by the policy management function network element, and the way of determining the routing and forwarding rules, as well as the way of determining the queue information and message processing logic are the same as those shown in Figure 3
  • the network element of the network control function executes in a similar manner, which will not be repeated here.
  • the network element with the policy management function sends message processing logic to the network element with the network control function.
  • the embodiment of the present disclosure does not specifically limit the method of sending message processing logic.
  • the policy management function network element may send a user plane establishment request to the network control function network element, and establish the request on the user plane
  • the message processing logic is carried in , as for other methods, this disclosure will not repeat them one by one.
  • the network element with the network control function configures message processing logic for the target forwarding device, so that the target forwarding device forwards corresponding data streams based on the message processing logic.
  • step S507 are similar to the method and principle of step S308 in the embodiment shown in FIG. 3 , and the specific implementation may refer to the embodiment shown in FIG. 3 , which will not be repeated here.
  • FIG. 6 is a fourth schematic flowchart of a packet processing logic configuration manner provided by an embodiment of the present disclosure.
  • the message processing logic configuration method provided by the embodiment of the present disclosure includes the following steps:
  • the forwarding device sends the first data packet to the network element with the network control function.
  • steps S601-S602 are similar to those of steps S301-S302 in the embodiment shown in FIG. 3 .
  • steps S301-S302 refer to the embodiment shown in FIG. 3 , which will not be repeated here.
  • the network element with the network control function sends the first data packet to the network element with the policy management function.
  • the network control function does not analyze the first data packet, and may send the first data packet to the policy management function network element through a user plane establishment request.
  • the request can also be established through the user plane to carry the forwarding time, forwarding period and queue configuration rules of each message queue.
  • the network element with the policy management function parses the first data packet, obtains demand information of the data flow, and determines routing and forwarding rules according to the demand information and queue configuration rules.
  • the manner in which the network element with the policy management function parses the first data packet to obtain the demand information and the manner in which the routing and forwarding rules are obtained according to the demand information and queue configuration rules are the same as those described by the network control function network element in the embodiment shown in FIG. 3 .
  • the implementation schemes are the same, and will not be repeated here.
  • the network element with the policy management function sends the routing forwarding rule to the network element with the network control function.
  • the network element with the network control function determines the queue information according to the routing and forwarding rules, and obtains message processing logic according to the queue information and the routing and forwarding rules.
  • the network control function network element configures message processing logic for the target forwarding device, so that the target forwarding device forwards corresponding data streams based on the message processing logic.
  • steps S605-S606 are similar to those of steps S306-S308 in the embodiment shown in FIG.
  • FIG. 7 is a fifth schematic flowchart of a packet processing logic configuration manner provided by an embodiment of the present disclosure.
  • the message processing logic configuration method provided by the embodiment of the present disclosure includes the following steps:
  • the forwarding device sends the first data packet to the network element with the network control function.
  • the network element with the network control function sends the first data packet to the network element with the policy management function.
  • the network element with the policy management function parses the first data packet, obtains demand information of the data flow, and determines routing forwarding rules and queue information according to the demand information and queue configuration rules.
  • the network element with the policy management function sends the routing and forwarding rules and queue information to the network element with the network control function.
  • the network element with the network control function obtains message processing logic according to the routing and forwarding rules and queue information.
  • the network element with the network control function configures message processing logic for the target forwarding device, so that the target forwarding device forwards corresponding data streams based on the message processing logic.
  • steps S701-S702 are similar to those of steps S301-S302 in the embodiment shown in FIG.
  • the method and principle of ⁇ S406 are similar, and the method and principle of steps S706 ⁇ S707 are similar to those of steps S407 ⁇ S408 in the embodiment shown in FIG.
  • FIG. 8 is a sixth schematic flowchart of a packet processing logic configuration manner provided by an embodiment of the present disclosure.
  • the message processing logic configuration method provided by the embodiment of the present disclosure includes the following steps:
  • the forwarding device sends the first data packet to the network element with the network control function.
  • the network element with the network control function sends the first data packet to the network element with the policy management function.
  • the network element with the policy management function parses the first data packet to obtain demand information of the data flow.
  • the network element with the policy management function determines routing and forwarding rules and queue information according to the requirement information and queue configuration rules, and obtains message processing logic according to the routing and forwarding rules and queue information.
  • the network element with the policy management function sends message processing logic to the network element with the network control function.
  • the network control function network element configures message processing logic for the target forwarding device, so that the target forwarding device forwards corresponding data streams based on the message processing logic.
  • steps S801-S802 are similar to the methods and principles of steps S301-S302 in the embodiment shown in FIG.
  • the method and principle of ⁇ S506 are similar, and the method and principle of steps S806 ⁇ S807 are similar to those of steps S506 ⁇ S507 in the embodiment shown in FIG.
  • the demand information of the data flow may also be obtained without the first data packet.
  • step S201 specifically includes the following solutions:
  • the policy management function network element obtains the demand information of the data flow
  • the policy management function network element root demand information determines the routing and forwarding rules
  • At least one of the policy management function network element or the network control function network element determines the queue information according to the routing and forwarding rules, and obtains the message processing logic according to the queue information and the routing and forwarding rules.
  • FIG. 9 is a seventh schematic flowchart of a packet processing logic configuration manner provided by an embodiment of the present disclosure.
  • the message processing logic configuration method provided by the embodiment of the present disclosure includes the following steps:
  • the embodiment of the present disclosure does not specifically limit the network element device that acquires the queue configuration rule.
  • the queue configuration rule of the forwarding device may be acquired by the network element with the network control function, and in the second aspect, the queue configuration rule of the forwarding device may also be acquired by the network element with the policy management function.
  • any one of the network control function network element and the policy management function network element may report the queue configuration rule to another network element.
  • the queue configuration rules, forwarding cycle, and forwarding time of each message queue of each forwarding device can be sent to the corresponding forwarding device, which is used for the forwarding device to determine the forwarding time of each message queue. divided.
  • the policy management function network element may first send the queue configuration rules to the network management function network element, and the network management function network element sends the queue configuration rules to the forwarding device for configuration.
  • each forwarding device may include multiple message queues, and the queue configuration rules are used to indicate the data transmission rate of each message queue (for example, maximum transmission rate, minimum transmission rate, and average transmission rate, etc.), each message queue The priority when forwarding data streams, and the corresponding forwarding time of each message queue in the forwarding cycle, etc.
  • any of the above-mentioned network elements obtains the queue configuration rules, firstly, based on the network topology, that is, the location of the forwarding device, the number of message queues supported by the forwarding port of the forwarding device and the forwarding period of the forwarding port are determined, and at the same time Obtain the data transmission rate of each message queue of the forwarding port and the priority when forwarding the data flow.
  • the forwarding cycle is evenly distributed to each message queue, so as to obtain the forwarding time of each message queue in the forwarding cycle, wherein, the duration of the forwarding time corresponding to each message queue Are the same.
  • the queue configuration rule is obtained based on the data transmission rate of each message queue, the priority when forwarding the data stream, and the forwarding time in the forwarding cycle.
  • the network element with the policy management function acquires requirement information of the data flow, and determines a routing and forwarding rule according to the requirement information.
  • the network element with the policy management function may obtain the demand information of the data flow through the service layer and/or the application layer.
  • this embodiment of the present disclosure does not limit it.
  • the network element with the policy management function sends the routing forwarding rule to the network element with the network control function.
  • the network element with the network control function determines queue information according to the routing and forwarding rules, and obtains message processing logic according to the queue information and the routing and forwarding rules.
  • steps S902-S904 are similar to those of steps S305-S307 in the embodiment shown in FIG.
  • the network control function network element configures message processing logic for the target forwarding device, so that the target forwarding device forwards corresponding data streams based on the message processing logic.
  • the network element with the network control function sends a configuration request to the forwarding device, wherein the configuration request carries the message processing logic, and correspondingly, after receiving the configuration request, the forwarding device obtains the message carried in it Processing logic, and configure each forwarding port according to the packet processing logic.
  • the forwarding device may send a configuration response to the network control function network element, where the configuration response is used to indicate that the packet processing logic configuration is completed.
  • the network element of the network control function may also send a user plane establishment response to the network element of the policy management function, and the user plane establishment response is used to indicate the packet processing logic configuration of the forwarding device Finish.
  • FIG. 10 is an eighth schematic flowchart of a packet processing logic configuration manner provided by an embodiment of the present disclosure.
  • the message processing logic configuration method provided by the embodiment of the present disclosure includes the following steps:
  • the network element with the policy management function obtains the demand information of the data flow, and determines routing and forwarding rules and queue information according to the demand information.
  • the network element with the policy management function sends the routing and forwarding rules and queue information to the network element with the network control function.
  • the network element with the network control function generates message processing logic according to the routing and forwarding rules and queue information.
  • step S1001 is similar to that of step S301 in the embodiment shown in FIG. The foregoing embodiments will not be repeated here.
  • the network element with the network control function configures message processing logic for the target forwarding device, so that the target forwarding device forwards corresponding data streams based on the message processing logic.
  • the network element with the network control function sends a configuration request to the forwarding device, wherein the configuration request carries the message processing logic, and correspondingly, after receiving the configuration request, the forwarding device obtains the message processing logic carried in it , and configure each forwarding port according to the packet processing logic.
  • the forwarding device may send a configuration response to the network control function network element, where the configuration response is used to indicate that the message processing logic is configured.
  • the network element of the network control function may also send a user plane establishment response to the network element of the policy management function, and the user plane establishment response is used to indicate the packet processing logic configuration of the forwarding device Finish.
  • FIG. 11 is a ninth schematic flowchart of a packet processing logic configuration method provided by an embodiment of the present disclosure.
  • the message processing logic configuration method provided by the embodiment of the present disclosure includes the following steps:
  • the network element with the policy management function obtains the demand information of the data flow, determines routing forwarding rules and queue information according to the demand information, and generates message processing logic according to the routing forwarding rules and queue information.
  • the network element with the policy management function sends message processing logic to the network element with the network control function.
  • step S1101 is similar to that of step S301 in the embodiment shown in FIG. The foregoing embodiments will not be repeated here.
  • the network element with the network control function configures message processing logic for the target forwarding device, so that the target forwarding device forwards corresponding data streams based on the message processing logic.
  • the network element with the network control function sends a configuration request to the forwarding device, wherein the configuration request carries the message processing logic, and correspondingly, after receiving the configuration request, the forwarding device obtains the message processing logic carried in it , and configure each forwarding port according to the packet processing logic.
  • the forwarding device may send a configuration response to the network control function network element, where the configuration response is used to indicate that the message processing logic is configured.
  • the network element with the network control function may also send a user plane establishment response to the network element with the policy management function, and the user plane establishment response is used to indicate the packet processing logic configuration of the forwarding device Finish.
  • FIG. 12 is a first structural schematic diagram of the data scheduling device provided by the embodiment of the present disclosure. As shown in Figure 12, the data scheduling device 1200 includes:
  • the obtaining module 1201 is used to obtain the message processing logic of the data stream, and the queue configuration rule is determined according to the data forwarding cycle of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device;
  • the configuration module 1202 is configured to configure message processing logic for the target forwarding device for forwarding corresponding data streams.
  • the acquiring module 1201 is specifically configured to: receive the first data packet sent by the forwarding device; and obtain message processing logic based on the first data packet and queue configuration rules.
  • the obtaining module 1201 is specifically configured to: analyze the first data packet to obtain demand information of the data flow; obtain message processing logic according to the demand information and queue configuration rules.
  • the obtaining module 1201 is specifically configured to: send demand information to the policy management function network element; receive the routing and forwarding rules obtained by the policy management function network element according to the demand information and queue configuration rules; obtain the packet processing logic according to the routing forwarding rules .
  • the acquisition module 1201 is specifically configured to: send the first data packet to the policy management function network element, and use the policy management function network element to obtain the demand information of the data flow according to the first data packet; receive the policy management function network element according to the demand information Routing and forwarding rules obtained from information and queue configuration rules; message processing logic is obtained according to routing and forwarding rules.
  • the obtaining module 1201 is specifically configured to: determine the queue information of the data flow according to the routing and forwarding rules, and the queue information is used to indicate the queue used to send the data flow; obtain the packet processing logic according to the queue information and the routing and forwarding rules.
  • the obtaining module 1201 is specifically configured to: receive the queue information obtained by the network element with the policy management function according to the demand information; obtain message processing logic according to the routing forwarding rule and the queue information.
  • the obtaining module 1201 is specifically configured to: analyze the first data packet, and obtain the demand information of the data flow. Send the demand information to the policy management function network element; receive the message processing logic obtained by the policy management function network element according to the demand information.
  • the obtaining module 1201 is specifically configured to: send the first data packet to the network element with the policy management function; receive the message processing logic obtained by the network element with the policy management function according to the first data packet.
  • the data scheduling apparatus 1200 further includes: a determining module 1203, configured to determine the queue configuration rule of the forwarding port according to the data forwarding cycle of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; or,
  • the receiving module 1204 is used to receive the queue configuration rule sent by the policy management function network element; wherein, the queue configuration rule is used to indicate the data forwarding time of each message queue in the forwarding cycle of the forwarding port, and the duration of the data forwarding time is the forwarding device. Data forwarding cycle.
  • the above-mentioned data scheduling device 1200 provided in the present disclosure can realize the steps of the data scheduling method corresponding to the network control function network element in the above-mentioned method embodiment, and can achieve the same technical effect. Parts and beneficial effects in this embodiment that are the same as those in the method embodiment are specifically described in detail.
  • FIG. 13 is a second structural schematic diagram of the data scheduling device provided by the embodiment of the present disclosure. As shown in Figure 13, the data scheduling device 1300 includes:
  • the obtaining module 1301 is used to obtain the demand information of the data stream; the determination module 1302 is used to determine the routing and forwarding rules according to the demand information and queue configuration rules, and determine the message processing logic of the data stream according to the routing forwarding rules.
  • the queue configuration rules are based on The data forwarding period of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device are determined; the sending module 1303 is used to send the message processing logic to the network control function network element, and the message processing logic is used for the corresponding data flow forwarding.
  • the determination module 1302 is specifically configured to: determine queue information for processing data flows according to demand information and queue configuration rules; determine message processing logic according to routing forwarding rules and queue information.
  • the above-mentioned data scheduling device 1300 provided by the present disclosure can realize the steps of the data scheduling method corresponding to the policy management function network element in the above-mentioned method embodiment, and can achieve the same technical effect. Parts and beneficial effects in this embodiment that are the same as those in the method embodiment are specifically described in detail.
  • FIG. 14 is a schematic structural diagram III of the data scheduling device provided by the embodiment of the present disclosure. As shown in Figure 14, the data scheduling device 1400 includes:
  • the obtaining module 1401 is used to obtain the demand information of the data stream, and obtain the routing and forwarding rules according to the demand information and queue configuration rules.
  • the queue configuration rules are based on the data forwarding cycle of the forwarding device and the number of queues supported by the forwarding port of the forwarding device Determined;
  • the sending module 1402 is configured to send routing and forwarding rules to network elements with network control functions, where the routing and forwarding rules are used to determine packet processing logic, and the packet processing logic is used to forward corresponding data streams.
  • the sending module 1402 is specifically configured to: determine queue information according to demand information and queue configuration rules; send queue information and routing forwarding rules to the network control function network element, for the network control function network element to information to determine the packet processing logic.
  • the obtaining module 1401 is specifically configured to: receive the demand information of the data flow in the first data packet sent by the network element with the network control function.
  • the obtaining module 1401 is specifically configured to: receive the first data packet sent by the network element with the network control function; Analyze the first data packet to obtain the demand information of the data flow.
  • the data scheduling apparatus 1400 further includes: a determination module 1403, configured to determine the queue configuration rule of the forwarding port according to the data forwarding cycle of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; or, receive The queue configuration rule sent by the network element of the network control function; wherein, the queue configuration rule is used to indicate the data forwarding time of each message queue in the forwarding cycle of the forwarding port, and the duration of the data forwarding time is the data forwarding cycle of the forwarding device.
  • a determination module 1403 configured to determine the queue configuration rule of the forwarding port according to the data forwarding cycle of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; or, receive The queue configuration rule sent by the network element of the network control function; wherein, the queue configuration rule is used to indicate the data forwarding time of each message queue in the forwarding cycle of the forwarding port, and the duration of the data forwarding time is the data forwarding cycle of the forwarding device.
  • the above-mentioned data scheduling device 1400 provided by the present disclosure can realize the steps of the data scheduling method corresponding to the policy management function network element in the above-mentioned method embodiment, and can achieve the same technical effect. Parts and beneficial effects in this embodiment that are the same as those in the method embodiment are specifically described in detail.
  • FIG. 15 is a fourth structural schematic diagram of the data scheduling device provided by the embodiment of the present disclosure.
  • the data scheduling device 1500 includes:
  • the determining module 1501 is configured to, in response to receiving the data flow to be processed, determine a target queue for forwarding the data flow to be processed based on message processing logic, determine a forwarding time of the data flow to be processed based on a queue configuration rule of the forwarding device, and report
  • the text processing logic is configured by the network control function network element for the forwarding device; the forwarding module 1502 is used to forward the data flow to be processed at the forwarding time through the target queue.
  • the data scheduling apparatus 1500 further includes: a sending module 1503, configured to send the first data packet to a network element with a network control function;
  • the receiving module 1504 is configured to receive the message processing logic obtained by the network control function network element according to the first data packet.
  • the above-mentioned data scheduling apparatus 1500 can realize the steps of the data scheduling method corresponding to the forwarding device in the above-mentioned method embodiment, and can achieve the same technical effect.
  • the same parts and beneficial effects as those in the method embodiment will be described in detail.
  • FIG. 16 is a schematic structural diagram of the network element with a network control function provided by an embodiment of the present disclosure.
  • the network element with the network control function includes: a transceiver 1601 , a processor 1602 and a memory 1603 .
  • the transceiver 1601 is used for receiving and sending data under the control of the processor 1602 .
  • the bus architecture may include any number of interconnected buses and bridges, specifically one or more processors represented by the processor 1602 and various circuits of the memory represented by the memory 1603 are linked together.
  • the bus architecture can also link together various other circuits such as peripherals, voltage regulators, and power management circuits, etc., which are well known in the art and therefore will not be further described herein.
  • the bus interface provides the interface.
  • the transceiver 1601 may be multiple elements, including a transmitter and a receiver, providing a unit for communicating with various other devices over transmission media, such as wireless channels, wired channels, optical cables, and other transmission media.
  • the processor 1602 is responsible for managing the bus architecture and general processing, and the memory 1603 can store data used by the processor 1602 when performing operations.
  • the processor 1602 is responsible for managing the bus architecture and general processing, and the memory 1603 can store data used by the processor 1602 when performing operations.
  • the processor 1602 may be a central processing unit (central processing unit, CPU), an application specific integrated circuit (Application Specific Integrated Circuit, ASIC), a field programmable gate array (Field-Programmable Gate Array, FPGA) or a complex programmable A logic device (Complex Programmable Logic Device, CPLD), and a processor may also adopt a multi-core architecture.
  • Processor 1602 saves by calling memory 1603
  • the stored computer program is used to execute any method related to the terminal device provided by the embodiments of the present disclosure according to the obtained executable instructions, and the processor and the memory may also be arranged physically separately.
  • the processor 1602 is configured to read the computer program in the memory and perform the following operations: obtain the packet processing logic of the data flow, the packet processing logic is obtained based on the queue configuration rules of the forwarding port of the forwarding device, and the queue configuration rules It is determined according to the data forwarding cycle of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; the message processing logic is configured for the target forwarding device for forwarding the corresponding data flow.
  • obtaining the message processing logic of the data flow includes: receiving the first data packet sent by the forwarding device; and obtaining the message processing logic based on the first data packet and queue configuration rules.
  • the message processing logic is obtained based on the first data packet and the queue configuration rule, including: parsing the first data packet to obtain the demand information of the data flow; obtaining the message processing logic according to the demand information and the queue configuration rule .
  • the message processing logic is obtained according to the demand information and the queue configuration rules, including: sending the demand information to the network element with the policy management function; receiving the routing and forwarding rules obtained by the network element with the policy management function according to the demand information and the queue configuration rules; Routing and forwarding rules to obtain message processing logic.
  • obtaining the message processing logic includes: sending the first data packet to the network element with the policy management function, for the network element with the policy management function to obtain the information of the data flow according to the first data packet Requirement information; receive routing and forwarding rules obtained by network elements with policy management functions according to the requirement information and queue configuration rules; obtain message processing logic according to routing and forwarding rules.
  • the message processing logic is obtained, including: according to the routing and forwarding rules, determining the queue information of the data flow, the queue information is used to indicate the queue used to send the data flow; according to the queue information and the routing and forwarding rules, Obtain the packet processing logic.
  • obtaining message processing logic according to routing and forwarding rules includes: receiving queue information obtained by network elements with policy management functions according to demand information; obtaining message processing logic according to routing forwarding rules and queue information.
  • the obtained message processing logic includes:
  • Analyzing the first data packet to obtain the demand information of the data flow comprising Analyzing the first data packet to obtain the demand information of the data flow; sending the demand information to the policy management function network element; receiving the message processing logic obtained by the policy management function network element according to the demand information.
  • the obtained message processing logic includes: sending the first data packet to the policy management function network element; receiving the message obtained by the policy management function network element according to the first data packet processing logic.
  • the processor 1602 is also configured to: determine the queue configuration of the forwarding port according to the data forwarding cycle of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device Or, receive the queue configuration rule sent by the policy management function network element; the queue configuration rule is used to indicate the data forwarding time of each message queue in the forwarding period of the forwarding port, and the duration of the data forwarding time is the data forwarding period of the forwarding device.
  • the above-mentioned network control function network element provided in the present disclosure can implement all the method steps corresponding to the implementation of the network control function network element in the above-mentioned method embodiments, and can achieve the same technical effect.
  • the same parts and beneficial effects in this embodiment as those in the method embodiment will be described in detail.
  • FIG. 17 is a schematic structural diagram of the network element with a policy management function provided by an embodiment of the present disclosure.
  • the policy management function network element 1700 includes: a transceiver 1701 , processor 1702 and memory 1703 .
  • the transceiver 1701 is used for receiving and sending data under the control of the processor 1702 .
  • the bus architecture may include any number of interconnected buses and bridges, specifically one or more processors represented by the processor 1702 and various circuits of the memory represented by the memory 1703 are linked together.
  • the bus architecture can also link together various other circuits such as peripherals, voltage regulators, and power management circuits, etc., which are well known in the art and therefore will not be further described herein.
  • the bus interface provides the interface.
  • the transceiver 1701 may be a plurality of components, including a transmitter and a receiver, providing a unit for communicating with various other devices over transmission media, including wireless channels, wired channels, optical cables, and other transmission media.
  • the processor 1702 is responsible for managing the bus architecture and general processing, and the memory 1703 can store data used by the processor 1702 when performing operations.
  • the processor 1702 is responsible for managing the bus architecture and general processing, and the memory 1703 can store data used by the processor 1702 when performing operations.
  • the processor 1702 may be a central processing unit (CPU), an application-specific integrated circuit (Application Specific Integrated Circuit, ASIC), a field-programmable gate array (Field-Programmable Gate Array, FPGA) or a complex programmable Programmable Logic Device (Complex Programmable Logic Device, CPLD), the processor can also adopt a multi-core architecture.
  • the processor 1702 calls the computer program stored in the memory 1703 to execute any method related to the terminal device provided by the embodiments of the present disclosure according to the obtained executable instructions, and the processor and the memory may also be arranged physically separately.
  • the processor 1702 is configured to read the computer program in the memory and perform the following operations: obtain the demand information of the data flow; determine the routing and forwarding rules according to the demand information and queue configuration rules, and the queue configuration rules are based on the The data forwarding cycle and the number of message queues supported by the forwarding port of the forwarding device are determined; the message processing logic of the data flow is determined according to the routing forwarding rules; the message processing logic is sent to the network control function network element, and the message processing logic uses For the forwarding of the corresponding data stream.
  • determining message processing logic according to routing and forwarding rules includes: determining queue information for processing data flows according to demand information and queue configuration rules; determining message processing logic according to routing forwarding rules and queue information.
  • the processor 1702 can also be used to read the computer program in the memory and perform the following operations: obtain the demand information of the data flow; obtain the routing forwarding rule according to the demand information and the queue configuration rule, and the queue configuration rule is It is determined according to the data forwarding period of the forwarding device and the number of message queues supported by the forwarding port of the forwarding device; the routing and forwarding rules are sent to the network element with the network control function, and the routing and forwarding rules are used to determine the message processing logic. For the forwarding of the corresponding data stream.
  • sending the routing and forwarding rules to the network control function network element including: determining the queue information according to the demand information and queue configuration rules; sending the queue information and routing forwarding rules to the network control function network element for the network control function network element Determine the message processing logic according to routing forwarding rules and queue information.
  • acquiring the requirement information of the data flow includes: receiving the requirement information of the data flow in the first data packet sent by the network element with the network control function.
  • acquiring the demand information of the data flow includes: receiving a first data packet sent by a network element with a network control function; parsing the first data packet to obtain the demand information of the data flow.
  • the processor is further configured to: transfer the data according to the forwarding device Send cycle, the number of queues supported by the forwarding port of the forwarding device, determine the queue configuration rules of the forwarding port; or receive the queue configuration rules sent by the network control function network element; wherein, the queue configuration rules are used to indicate that each message queue is in The data forwarding time in the forwarding period of the forwarding port, and the length of the data forwarding time is the data forwarding period of the forwarding device.
  • the network element with the policy management function provided in the present disclosure can implement all the method steps corresponding to the network element with the policy management function in the above method embodiments, and can achieve the same technical effect.
  • the same parts and beneficial effects in this embodiment as those in the method embodiment will be described in detail.
  • FIG. 18 is a schematic structural diagram of the forwarding device provided by the embodiment of the present disclosure.
  • the forwarding device 1800 includes: a transceiver 1801 , a processor 1802 and a memory 1803 .
  • the transceiver 1801 is used for receiving and sending data under the control of the processor 1802 .
  • the bus architecture may include any number of interconnected buses and bridges, specifically one or more processors represented by the processor 1802 and various circuits of the memory represented by the memory 1803 are linked together.
  • the bus architecture can also link together various other circuits such as peripherals, voltage regulators, and power management circuits, etc., which are well known in the art and therefore will not be further described herein.
  • the bus interface provides the interface.
  • the transceiver 1801 may be multiple elements, including a transmitter and a receiver, providing a unit for communicating with various other devices over transmission media, including wireless channels, wired channels, optical cables, and other transmission media.
  • the processor 1802 is responsible for managing the bus architecture and general processing, and the memory 1803 can store data used by the processor 1802 when performing operations.
  • the processor 1802 is responsible for managing the bus architecture and general processing, and the memory 1803 can store data used by the processor 1802 when performing operations.
  • the processor 1802 can be a central processing unit (central processing unit, CPU), an application specific integrated circuit (Application Specific Integrated Circuit, ASIC), a field programmable gate array (Field-Programmable Gate Array, FPGA) or a complex programmable Programmable Logic Device (Complex Programmable Logic Device, CPLD), the processor can also adopt a multi-core architecture.
  • the processor 1802 calls the computer program stored in the memory 1803 to execute any method related to the terminal device provided by the embodiments of the present disclosure according to the obtained executable instructions, and the processor and the memory may also be arranged physically separately.
  • the processor 1802 is configured to read the computer program in the memory and perform the following operations:
  • the target queue for forwarding the data flow to be processed based on the message processing logic; determine the forwarding time of the data flow to be processed based on the queue configuration rules of the forwarding device.
  • the message processing logic is network control
  • the functional network element is configured for the forwarding device; through the target queue, the pending data flow is forwarded at the forwarding time.
  • the processor is further configured to: send the first data packet to the network element with the network control function; and receive the message processing logic obtained by the network element with the network control function according to the first data packet.
  • the forwarding network device provided by the present disclosure can realize all the method steps corresponding to the forwarding device in the above method embodiments, and can achieve the same technical effect.
  • the same parts and beneficial effects as those of the method embodiment will be described in detail.
  • each function unit in each embodiment of the present disclosure Elements can be integrated into one processing unit, or each unit can exist separately physically, or two or more units can be integrated into one unit.
  • the above-mentioned integrated units can be implemented in the form of hardware or in the form of software functional units.
  • the above integrated units are realized in the form of software function units and sold or used as independent products, they can be stored in a processor-readable storage medium.
  • the technical solution of the present disclosure is essentially or part of the contribution to the prior art, or all or part of the technical solution can be embodied in the form of a software product, and the computer software product is stored in a storage medium , including several instructions for a computer device (which may be a personal computer, a server, or a network device, etc.) or a processor (processor) to execute all or part of the steps of the methods in various embodiments of the present disclosure.
  • the aforementioned storage media include: U disk, mobile hard disk, read-only memory (Read-Only Memory, ROM), random access memory (Random Access Memory, RAM), magnetic disk or optical disc and other media that can store program codes. .
  • An embodiment of the present disclosure provides a processor-readable storage medium, where a computer program is stored in the processor-readable storage medium, and the computer program is used to enable a processor to execute the method for energy saving of a network provided by an embodiment of the present disclosure, so that the processor can All the steps of the network energy-saving method implemented by the network device in the above method embodiment can be realized, and the same technical effect can be achieved, and the same parts and beneficial effects in this embodiment as in the method embodiment will not be described in detail here.
  • the processor-readable storage medium can be any available medium or data storage device that the processor can access, including but not limited to magnetic storage (such as floppy disk, hard disk, magnetic tape, magneto-optical disk (MO), etc.), optical storage (such as CD, DVD, BD, HVD, etc.), and semiconductor memory (such as ROM, EPROM, EEPROM, non-volatile memory (NAND FLASH), solid-state drive (SSD)), etc.
  • magnetic storage such as floppy disk, hard disk, magnetic tape, magneto-optical disk (MO), etc.
  • optical storage such as CD, DVD, BD, HVD, etc.
  • semiconductor memory such as ROM, EPROM, EEPROM, non-volatile memory (NAND FLASH), solid-state drive (SSD)
  • An embodiment of the present disclosure also provides a computer program product containing instructions, the computer program is stored in a storage medium, at least one processor can read the computer program from the storage medium, and at least one processor can implement the above-mentioned All the steps of the data scheduling method implemented by the network device in the method embodiment can achieve the same technical effect, so the parts and beneficial effects in this embodiment that are the same as those in the method embodiment will not be described in detail here.
  • An embodiment of the present disclosure also provides a communication system, including a network device and any one or more of the following: a terminal device, a core network, a centralized unit CU or a distributed unit DU.
  • the network device can execute all the steps in the above embodiments of the data scheduling method, and can achieve the same technical effect. Parts and beneficial effects in this embodiment that are the same as those in the method embodiment will not be described in detail here.
  • the embodiments of the present disclosure may be provided as methods, systems, or computer program products, therefore, the present disclosure may be implemented in an entirely hardware embodiment, an entirely software embodiment, or a combination of software and hardware aspects example form.
  • the present disclosure 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, optical storage, etc.) having computer-usable program code embodied therein.
  • each process and/or block in the signaling interaction diagram and/or block diagram, and a combination of procedures and/or blocks in the signaling interaction diagram and/or block diagram can be implemented by computer-executable instructions.
  • These computer-executable instructions can be provided to a general purpose computer, special purpose computer, embedded processor, or processor of other programmable data processing equipment to produce a machine, such that instructions executed by the processor of the computer or other programmable data processing equipment produce Used to implement a process or multiple means of a process and/or block diagram with a specified function in one or more blocks.
  • processor-executable instructions may also be stored in a processor-readable memory capable of directing a computer or other programmable data processing device to operate in a specific manner, such that the instructions stored in the processor-readable memory produce a manufacturing product, the instruction device implements the functions specified in one or more procedures in the signaling interaction schematic diagram and/or one or more blocks in the block diagram.
  • processor-executable instructions can also be loaded onto a computer or other programmable data processing device, causing a series of operational steps to be performed on the computer or other programmable device to produce a computer-implemented
  • the executed instructions provide steps for realizing the functions specified in one or more procedures of the signaling interaction diagram and/or one or more blocks of the block diagram.

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Data Exchanges In Wide-Area Networks (AREA)
  • Mobile Radio Communication Systems (AREA)

Abstract

本公开提供的一种数据调度方法、装置、设备及存储介质，网络控制功能网元获取数据流的报文处理逻辑；并为目标转发设备配置所述报文处理逻辑，用于所述目标转发设备基于所述报文处理逻辑，转发相应的数据流。由于报文处理逻辑是基于转发设备的转发端口的队列配置规则获得的，而队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量确定的，因而，在转发数据流时，每个数据流都会在特定的队列、按照特定的转发时间进行转发，可以准确地确定数据传输过程的时延，进而实现对确定性网络中端到端时延的控制。

Description

数据调度方法、装置、设备及存储介质
本公开要求于2022年2月15日提交中国专利局、申请号为202210139235.3、申请名称为“数据调度方法、装置、设备及存储介质”的中国专利申请的优先权，其全部内容通过引用结合在本公开中。
技术领域
本公开涉及通信技术领域，尤其涉及一种数据调度方法、装置、设备及存储介质。
背景技术
确定性网络(Deterministic Networking，DetNet)可以在第二层桥接和第三层路由段实现确定数据传输的路径，根据这些路径可以确定时延、丢包和抖动的最坏情况界限，从而控制并降低端到端时延。
相关技术中，发送端到接收端之间有多条路径，发送端会对每条路径的丢包、时延、抖动进行周期性的测量，按照最短时延、最小丢包或最小抖动等算法为数据流选择对应的发送路径，发送路径中包括至少一个转发设备。
相应的，转发设备在转发数据流时，会按照数据流的优先级将数据流插入相应的队列，从而尽量降低高优先级数据流的时延和抖动，而低优先级的数据流则排队等待或者被丢弃。然而，由于数据流的排队时延无法确定，也就无法确定发送路径上的时延，进而无法对时延进行控制。
发明内容
本公开提供一种数据调度方法、装置、设备及存储介质，用于保障确定性网络中的数据传输时延的确定性，从而实现对确定性网络中端到端时延的控制。
第一方面，本公开提供一种数据调度方法，应用于网络控制功能网元，数据调度方法包括：获取数据流的报文处理逻辑，报文处理逻辑是基于转发设备的转发端口的队列配置规则获得的，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量确定的；为目标转发设备配置报文处理逻辑，所述报文处理逻辑用于相应的数据流的转发。
可选的，获取数据流的报文处理逻辑，包括：接收转发设备发送的第一数据包；基于第一数据包和队列配置规则，获得报文处理逻辑。
可选的，基于第一数据包和队列配置规则，获得报文处理逻辑，包括：对第一数据包进行解析，获得数据流的需求信息；根据需求信息和队列配置规则，获得报文处理逻辑。
可选的，根据需求信息和队列配置规则，获得报文处理逻辑，包括：向策略管理 功能网元发送需求信息；接收策略管理功能网元根据需求信息和队列配置规则获得的路由转发规则；根据路由转发规则，获得报文处理逻辑。
可选的，基于第一数据包和队列配置规则，获得报文处理逻辑，包括：向策略管理功能网元发送第一数据包，用于策略管理功能网元根据第一数据包获得数据流的需求信息；接收策略管理功能网元根据需求信息和队列配置规则获得的路由转发规则；根据路由转发规则，获得报文处理逻辑。
可选的，根据路由转发规则，获得报文处理逻辑，包括：根据路由转发规则，确定数据流的队列信息，队列信息用于指示用于发送数据流的队列；根据队列信息和路由转发规则，获得报文处理逻辑。
可选的，根据路由转发规则，获得报文处理逻辑，包括：接收策略管理功能网元根据需求信息获得的队列信息；根据路由转发规则和队列信息，获得报文处理逻辑。
可选的，基于第一数据包和队列配置规则，获得的报文处理逻辑，包括：对第一数据包进行解析，获得数据流的需求信息；向策略管理功能网元发送需求信息；接收策略管理功能网元根据需求信息获得的报文处理逻辑。
可选的，基于第一数据包和队列配置规则，获得的报文处理逻辑，包括：向策略管理功能网元发送第一数据包；接收策略管理功能网元根据第一数据包获得的报文处理逻辑。
可选的，在获取数据流的报文处理逻辑之前，还包括：根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，确定转发端口的队列配置规则；或者，接收策略管理功能网元发送的队列配置规则；其中，队列配置规则用于指示各消息队列在转发端口的转发周期内的数据转发时间，数据转发时间的时长为转发设备的数据转发周期。
第二方面，本公开提供一种数据调度方法，应用于策略管理功能网元，数据调度方法包括：获取数据流的需求信息；根据需求信息和队列配置规则，确定路由转发规则，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；根据路由转发规则确定数据流的报文处理逻辑；向网络控制功能网元发送报文处理逻辑，报文处理逻辑用于相应的数据流的转发。
可选的，根据路由转发规则确定报文处理逻辑，包括：根据需求信息和队列配置规则，确定用于处理数据流的队列信息；根据路由转发规则和队列信息，确定报文处理逻辑。
第三方面，本公开提供一种数据调度方法，应用于策略管理功能网元，数据调度方法包括：获取数据流的需求信息；根据需求信息和队列配置规则，获得路由转发规则，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；向网络控制功能网元发送路由转发规则，路由转发规则用于确定报文处理逻辑，报文处理逻辑用于相应的数据流的转发。
可选的，向网络控制功能网元发送路由转发规则，包括：根据需求信息和队列配置规则，确定队列信息；向网络控制功能网元发送队列信息和路由转发规则，用于网络控制功能网元根据路由转发规则和队列信息，确定报文处理逻辑。
可选的，获取数据流的需求信息，包括：接收网络控制功能网元发送的第一数据 包中的数据流的需求信息。
可选的，获取数据流的需求信息，包括：接收网络控制功能网元发送的第一数据包；解析第一数据包，获得数据流的需求信息。
可选的，在获取数据流的需求信息之前，还包括：根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量，确定转发端口的队列配置规则；或者，接收网络控制功能网元发送的队列配置规则；其中，队列配置规则用于指示各消息队列在转发端口的转发周期内的数据转发时间，数据转发时间的时长为转发设备的数据转发周期。
第四方面，本公开实施例提供一种数据调度方法，应用于转发设备，数据调度方法包括：响应于接收到待处理数据流，基于报文处理逻辑确定用于转发待处理数据流的目标队列；基于转发设备的队列配置规则，确定待处理数据流的转发时间，报文处理逻辑是网络控制功能网元为转发设备配置的；通过目标队列，在转发时间转发待处理数据流。
可选的，该数据调度方法还包括：向网络控制功能网元发送第一数据包；接收网络控制功能网元根据第一数据包获得的报文处理逻辑。
第五方面，本公开实施例提供一种数据调度装置，应用于网络控制功能网元，数据调度装置包括：获取模块，用于获取数据流的报文处理逻辑，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量确定的；配置模块，用于为目标转发设备配置报文处理逻辑，用于相应的数据流的转发。
可选的，获取模块具体用于：接收转发设备发送的第一数据包；基于第一数据包和队列配置规则，获得报文处理逻辑。
可选的，获取模块具体用于：对第一数据包进行解析，获得数据流的需求信息；根据需求信息和队列配置规则，获得报文处理逻辑。
可选的，获取模块具体用于：向策略管理功能网元发送需求信息；接收策略管理功能网元根据需求信息和队列配置规则获得的路由转发规则；根据路由转发规则，获得报文处理逻辑。
可选的，获取模块具体用于：向策略管理功能网元发送第一数据包，用于策略管理功能网元根据第一数据包获得数据流的需求信息；接收策略管理功能网元根据需求信息和队列配置规则获得的路由转发规则；根据路由转发规则，获得报文处理逻辑。
可选的，获取模块具体用于：根据路由转发规则，确定数据流的队列信息，队列信息用于指示用于发送数据流的队列；根据队列信息和路由转发规则，获得报文处理逻辑。
可选的，获取模块具体用于：接收策略管理功能网元根据需求信息获得的队列信息；根据路由转发规则和队列信息，获得报文处理逻辑。
可选的，获取模块具体用于：对第一数据包进行解析，获得数据流的需求信息；向策略管理功能网元发送需求信息；接收策略管理功能网元根据需求信息获得的报文处理逻辑。
可选的，获取模块具体用于：向策略管理功能网元发送第一数据包；接收策略管理功能网元根据第一数据包获得的报文处理逻辑。
可选的，该数据调度装置还包括：确定模块，用于根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，确定转发端口的队列配置规则；或者，接收模块，用于接收策略管理功能网元发送的队列配置规则；其中，队列配置规则用于指示各消息队列在转发端口的转发周期内的数据转发时间，数据转发时间的时长为转发设备的数据转发周期。
第六方面，本公开实施例提供一种数据调度装置，应用于策略管理功能网元，数据调度装置包括：
获取模块，用于获取数据流的需求信息；确定模块，用于根据需求信息和队列配置规则，确定路由转发规则，根据路由转发规则确定数据流的报文处理逻辑，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；发送模块，用于向网络控制功能网元发送报文处理逻辑，报文处理逻辑用于相应的数据流的转发。
可选的，确定模块具体用于：根据需求信息和队列配置规则，确定用于处理数据流的队列信息；根据路由转发规则和队列信息，确定报文处理逻辑。
第七方面，本公开实施例提供一种数据调度装置，应用于策略管理功能网元，数据调度装置包括：获取模块，用于获取数据流的需求信息，根据需求信息和队列配置规则，获得路由转发规则，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；发送模块，用于向网络控制功能网元发送路由转发规则，路由转发规则用于确定报文处理逻辑，报文处理逻辑用于相应的数据流的转发。
可选的，发送模块具体用于：根据需求信息和队列配置规则，确定队列信息；向网络控制功能网元发送队列信息和路由转发规则，用于网络控制功能网元根据路由转发规则和队列信息，确定报文处理逻辑。
可选的，获取模块具体用于：接收网络控制功能网元发送的第一数据包中的数据流的需求信息。
可选的，获取模块具体用于：接收网络控制功能网元发送的第一数据包；解析第一数据包，获得数据流的需求信息。
可选的，该数据调度装置还包括：确定模块，用于根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量，确定转发端口的队列配置规则；或者，接收网络控制功能网元发送的队列配置规则；其中，队列配置规则用于指示各消息队列在转发端口的转发周期内的数据转发时间，数据转发时间的时长为转发设备的数据转发周期。
第八方面，本公开实施例提供一种数据调度装置，应用于转发设备，数据调度装置包括：确定模块，用于响应于接收到待处理数据流，基于报文处理逻辑确定用于转发待处理数据流的目标队列，基于转发设备的队列配置规则，确定待处理数据流的转发时间，报文处理逻辑是网络控制功能网元为转发设备配置的；转发模块，用于通过目标队列，在转发时间转发待处理数据流。
可选的，该数据调度装置还包括：发送模块，用于向网络控制功能网元发送第一数据包；接收模块，用于接收网络控制功能网元根据第一数据包获得的报文处理逻辑。
第九方面，本公开实施例提供一种网络控制功能网元，包括：存储器，用于存储计算机程序；收发机，用于在处理器的控制下收发数据；处理器，用于读取存储器中的计算机程序并执行以下操作：
获取数据流的报文处理逻辑，报文处理逻辑是基于转发设备的转发端口的队列配置规则获得的，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量确定的；为目标转发设备配置报文处理逻辑，用于相应的数据流的转发。
可选的，获取数据流的报文处理逻辑，包括：接收转发设备发送的第一数据包；基于第一数据包和队列配置规则，获得报文处理逻辑。
可选的，基于第一数据包和队列配置规则，获得报文处理逻辑，包括：对第一数据包进行解析，获得数据流的需求信息；根据需求信息和队列配置规则，获得报文处理逻辑。
可选的，根据需求信息和队列配置规则，获得报文处理逻辑，包括：向策略管理功能网元发送需求信息；接收策略管理功能网元根据需求信息和队列配置规则获得的路由转发规则；根据路由转发规则，获得报文处理逻辑。
可选的，基于第一数据包和队列配置规则，获得报文处理逻辑，包括：向策略管理功能网元发送第一数据包，用于策略管理功能网元根据第一数据包获得数据流的需求信息；接收策略管理功能网元根据需求信息和队列配置规则获得的路由转发规则；根据路由转发规则，获得报文处理逻辑。
可选的，根据路由转发规则，获得报文处理逻辑，包括：根据路由转发规则，确定数据流的队列信息，队列信息用于指示用于发送数据流的队列；根据队列信息和路由转发规则，获得报文处理逻辑。
可选的，根据路由转发规则，获得报文处理逻辑，包括：接收策略管理功能网元根据需求信息获得的队列信息；根据路由转发规则和队列信息，获得报文处理逻辑。
可选的，基于第一数据包和队列配置规则，获得的报文处理逻辑，包括：对第一数据包进行解析，获得数据流的需求信息；向策略管理功能网元发送需求信息；接收策略管理功能网元根据需求信息获得的报文处理逻辑。
可选的，基于第一数据包和队列配置规则，获得的报文处理逻辑，包括：向策略管理功能网元发送第一数据包；接收策略管理功能网元根据第一数据包获得的报文处理逻辑。
可选的，在获取数据流的报文处理逻辑之前，处理器还用于：根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，确定转发端口的队列配置规则；或者，接收策略管理功能网元发送的队列配置规则；队列配置规则用于指示各消息队列在转发端口的转发周期内的数据转发时间，数据转发时间的时长为转发设备的数据转发周期。
第十方面，本公开实施例提供一种策略管理功能网元，包括：
存储器，用于存储计算机程序；收发机，用于在处理器的控制下收发数据；处理器，用于读取存储器中的计算机程序并执行以下操作：获取数据流的需求信息；根据需求信息和队列配置规则，确定路由转发规则，队列配置规则是根据转发设备的数据 转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；根据路由转发规则确定数据流的报文处理逻辑；向网络控制功能网元发送报文处理逻辑，报文处理逻辑用于相应的数据流的转发。
可选的，根据路由转发规则确定报文处理逻辑，包括：根据需求信息和队列配置规则，确定用于处理数据流的队列信息；根据路由转发规则和队列信息，确定报文处理逻辑。
第十一方面，本公开实施例提供一种策略管理功能网元，包括：存储器，用于存储计算机程序；收发机，用于在处理器的控制下收发数据；处理器，用于读取存储器中的计算机程序并执行以下操作：获取数据流的需求信息；根据需求信息和队列配置规则，获得路由转发规则，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；向网络控制功能网元发送路由转发规则，路由转发规则用于确定报文处理逻辑，报文处理逻辑用于相应的数据流的转发。
可选的，向网络控制功能网元发送路由转发规则，包括：根据需求信息和队列配置规则，确定队列信息；向网络控制功能网元发送队列信息和路由转发规则，用于网络控制功能网元根据路由转发规则和队列信息，确定报文处理逻辑。
可选的，获取数据流的需求信息，包括：接收网络控制功能网元发送的第一数据包中的数据流的需求信息。
可选的，获取数据流的需求信息，包括：接收网络控制功能网元发送的第一数据包；解析第一数据包，获得数据流的需求信息。
可选的，在获取数据流的需求信息之前，处理器还用于：根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量，确定转发端口的队列配置规则；或者，接收网络控制功能网元发送的队列配置规则；其中，队列配置规则用于指示各消息队列在转发端口的转发周期内的数据转发时间，数据转发时间的时长为转发设备的数据转发周期。
第十二方面，本公开实施例提供一种转发设备，包括：存储器，用于存储计算机程序；收发机，用于在处理器的控制下收发数据；处理器，用于读取存储器中的计算机程序并执行以下操作：
响应于接收到待处理数据流，基于报文处理逻辑确定用于转发待处理数据流的目标队列；基于转发设备的队列配置规则，确定待处理数据流的转发时间，报文处理逻辑是网络控制功能网元为转发设备配置的；通过目标队列，在转发时间转发待处理数据流。
可选的，处理器还用于：向网络控制功能网元发送第一数据包；接收网络控制功能网元根据第一数据包获得的报文处理逻辑。
第十三方面，本公开实施例提供一种处理器可读存储介质，处理器可读存储介质存储有计算机程序，计算机程序用于使处理器执行第一方面、第二方面、第三方面和第四方面中任一方面的数据调度方法。
第十四方面，本公开实施例提供一种计算机程序产品，包括：计算机程序，计算机程序被处理器执行时实现如第一方面、第二方面、第三方面和第四方面中任一方面的数据调度方法。
本公开提供的数据调度方法、装置、设备及存储介质，网络控制功能网元获取数据流的报文处理逻辑；并为目标转发设备配置报文处理逻辑，用于目标转发设备基于报文处理逻辑，转发相应的数据流。由于报文处理逻辑是基于转发设备的转发端口的队列配置规则获得的，而队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量确定的，因而，在转发数据流时，每个数据流都会在特定的队列、按照特定的转发时间进行转发，可以准确地确定数据传输过程的时延，进而实现对确定性网络中端到端时延的控制。
应当理解，上述发明内容部分中所描述的内容并非旨在限定本公开的实施例的关键或重要特征，亦非用于限制本公开的范围。本公开的其它特征将通过以下的描述变得容易理解。
附图说明
为了更清楚地说明本公开或现有技术中的技术方案，下面将对实施例或现有技术描述中所需要使用的附图作一简单地介绍，显而易见地，下面描述中的附图是本公开的一些实施例，对于本领域普通技术人员来讲，在不付出创造性劳动性的前提下，还可以根据这些附图获得其他的附图。
图1为本公开实施例提供应用场景示意图；
图2为本公开一实施例提供的数据调度方法的流程示意图；
图3为本公开一实施例提供的报文处理逻辑配置方式的流程示意图一；
图4为本公开一实施例提供的报文处理逻辑配置方式的流程示意图二；
图5为本公开一实施例提供的报文处理逻辑配置方式的流程示意图三；
图6为本公开一实施例提供的报文处理逻辑配置方式的流程示意图四；
图7为本公开一实施例提供的报文处理逻辑配置方式的流程示意图五；
图8为本公开一实施例提供的报文处理逻辑配置方式的流程示意图六；
图9为本公开一实施例提供的报文处理逻辑配置方式的流程示意图七；
图10为本公开一实施例提供的报文处理逻辑配置方式的流程示意图八；
图11为本公开一实施例提供的报文处理逻辑配置方式的流程示意图九；
图12为本公开实施例提供的数据调度装置的结构示意图一；
图13为本公开实施例提供的数据调度装置的结构示意图二；
图14为本公开实施例提供的数据调度装置的结构示意图三；
图15为本公开实施例提供的数据调度装置的结构示意图四；
图16为本公开实施例提供的网络控制功能网元的结构示意图；
图17为本公开实施例提供的策略管理功能网元的结构示意图；
图18为本公开实施例提供的转发设备的结构示意图。
具体实施方式
本公开中术语“和/或”，描述关联对象的关联关系，表示可以存在三种关系，例如，A和/或B，可以表示：单独存在A，同时存在A和B，单独存在B这三种情况。字符“/”一般表示前后关联对象是一种“或”的关系。本公开实施例中术语“多个” 是指两个或两个以上，其它量词与之类似。
下面将结合本公开实施例中的附图，对本公开实施例中的技术方案进行清楚、完整地描述，显然，所描述的实施例仅仅是本公开一部分实施例，并不是全部的实施例。基于本公开中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本公开保护的范围。
首先，对本公开涉及到的名词的定义进行如下说明：
应用平面(Application Plane)：定义网络行为的应用程序和服务所在的平面。
控制平面(Control Plane)：决定一个或多个网络设备怎么转发数据包，并将这些决定以流表的方式下发给网络设备执行。
管理平面(Management Plane)：负责监控、配置和维护网络设备，例如，对网络设备的状态做出决策。管理平面主要与设备的操作平面进行交互。
转发平面(Forwarding Plane)：负责根据从控制平面接收到的指令处理数据路径中的数据包的功能模块。转发平面的操作包括但不限于转发、丢弃和更改数据包。
操作平面(Operational Plane)：负责管理所在网络设备的操作状态，例如，设备是处于活动状态还是非活动状态，可用端口的数量，每个端口的状态，等等。操作平面负责网络设备资源，如端口、内存等。
接下来，结合图1对本公开实施例的应用场景进行说明：
图1为本公开实施例提供应用场景示意图。如图1所示，该场景包括：网络控制功能网元、策略管理功能网元以及转发设备。
其中，网络控制功能网元位于控制平面，策略管理功能网元位于应用平面，转发设备位于转发平面。
在一些实施例中，对于转发设备的类型不做具体限定，例如，转发设备可以为基站等具备数据转发功能的网络设备，具体的，可以是全球移动通讯(Global System of Mobile communication，GSM)或者，码分多址(Code Division Multiple Access，CDMA)中的基站和/或基站控制器，也可以是宽带码分多址(Wideband Code Division Multiple Access，WCDMA)中的基站(NodeB，NB)和/或无线网络控制器(Radio Network Controller，RNC)，还可以是长期演进(Long Term Evolution，LTE)中的演进型基站(Evolutional NodeB，4G基站或eNodeB)，或者中继站或接入点，或者未来5G网络中的基站(5G基站)等。
需要说明的是，图1示例性地示出了一个网络控制功能网元、一个策略管理功能网元和一个转发设备的通信场景，可选地，该场景中还可以包括其他设备，本公开实施例对此不做限定。
应当理解的是，DetNet网络的目标是第二层桥接和第三层路由段实现确定传输路径，这些路径可以提供延迟、丢包和抖动的最坏情况界限，从而控制并降低端到端时延的技术。
虽然，目前的互联网工程任务组(Internet Engineering Task Force，IETF)对于DetNet数据流的处理方法是拟利用时间敏感网络(Time-Sensitive Networking，TSN)中的处理方法，但是，IETF目前还没有定义这些针对L2数据帧的处理技术如何被DetNet节点使用，若采用现有的IP转发机制，虽然配合使用资源预留及优先级调度， 但是由于对每个数据分组的行为缺乏控制，导致排队形成微突发。
相关技术中，由于端到端通常有多条路径，在发送数据时，发送端会对每条路径进行测量，为每条路径的丢包、延迟、抖动进行周期性的测量，通过周期累计，从而为每个路径建立端到端延迟、端到端丢包的预估计模型，在每个发送端进行分组发送时，调度模块按照延迟和丢包的预估计模型进行估计，按照最短延迟/最小丢包/抖动最小等算法选择其中一条路径，作为本分组的发送路径。
具体的，发送端对每个数据流进行服务质量(Quality of Service，QoS)等级分配，转发设备在接收分组时，通过查看其等级，并按照等级将分组插入相应的队列。转发设备在转发时，会优先处理高优先级的分组，如优先级一致，则按照进入的先后顺序进行处理。此时，各分组会按照优先级占用BUFFER资源。
在此过程中，由于转发设备中的BUFFER资源有限，如某个高优先级分组到来时，BUFFER已经被占满，交换机会选择最低优先级的分组丢弃，并将腾出来的BUFFER分配给新进来的高优先级的分组使用，尽量保证高优先级的分组的延迟低、抖动小。
然而，此种方法存在如下问题：
如果确定性数据流在使用链路时，若流量中有更高级别的数据流或者同样级别的数据流在共享链路和转发设备节点资源，那么该确定性数据流中分组的排队延迟则无法确定，从而端到端的延迟无法确定，同样分组的延迟抖动也会比较大。
另外，通过网络监测端到端延迟等参数，在进行路径选择时，进行延迟估计，以期望按照预期的端到端延迟到达接收端，但网络测量的参数是累计参数，代表过去某段时间的性能，而网络状况总是瞬间变化的，则这种估计值是不准确的，并且由于对每个数据分组的行为缺乏控制，导致排队形成微突发，甚至微突发迭代，从而使得确定性网络中的时延将无法得到确定，进而无法对时延进行控制。
有鉴于此，本公开实施例提供一种数据调度方法、装置、设备及存储介质，由网络控制功能网元获取数据流的报文处理逻辑；为目标转发设备配置报文处理逻辑，用于目标转发设备基于报文处理逻辑，转发相应的数据流。由于报文处理逻辑是基于转发设备的转发端口的队列配置规则获得的，而队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量确定的，因而，在转发数据流时，每个数据流都会在特定的队列、按照特定的转发时间进行转发，这就可以准确地确定数据传输过程的时延，进而实现对确定性网络中端到端时延的控制。
应理解的是，本公开实施例提供的技术方案可以适用于多种系统，尤其是5G系统。例如适用的系统可以是全球移动通讯(global system of mobile communication，GSM)系统、码分多址(code division multiple access，CDMA)系统、宽带码分多址(Wideband Code Division Multiple Access，WCDMA)通用分组无线业务(general packet radio service，GPRS)系统、长期演进(long term evolution，LTE)系统、LTE频分双工(frequency division duplex，FDD)系统、LTE时分双工(time division duplex，TDD)系统、高级长期演进(long term evolution advanced，LTE-A)系统、通用移动系统(universal mobile telecommunication system，UMTS)、全球互联微波接入(worldwide interoperability for microwave access，WiMAX)系统、5G新空口(New Radio,NR)系统等。这多种系统中均包括终端和网络设备。系统中还包括核心网部分，例如演进的分组系统(Evloved  Packet System,EPS)、5G系统(5GS)等。
应理解，本公开实施例所提供的方法和装置是基于同一申请构思的，由于方法和装置解决问题的原理相似，因此装置和方法的实施可以相互参见，重复之处不再赘述。
下面以具体地实施例对本公开的实施例的技术方案以及本公开的技术方案如何解决上述技术问题进行详细说明。下面这几个具体的实施例可以相互结合，对于相同或相似的概念或过程可能在某些实施例中不再赘述。
图2为本公开一实施例提供的数据调度方法的流程示意图。如图2所示，本公开实施例提供的数据调度方法包括如下步骤：
S201、网络控制功能网元获取数据流的报文处理逻辑。
其中，报文处理逻辑用于指示转发设备对该数据流对应的数据流进行转发。
在一些实施例中，报文处理逻辑是基于转发设备的转发端口的队列配置规则获得的，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量确定的，至于队列配置规则的获取方式，在后续实施例中示出。
其中，报文处理逻辑包括：匹配域(例如是，IP-六元组或IP-五元组)，数据流的优先级、动作域(例如是，用于转发数据流消息队列和出口)，至于报文处理逻辑的获取方式，在后续实施例中示出。
S202、网络控制功能网元为目标转发设备配置报文处理逻辑，用于目标转发设备基于报文处理逻辑，转发相应的数据流。
具体的，网络控制功能网元向转发设备发送配置请求，其中，该配置请求中携带有该报文处理逻辑，相应的，转发设备在接收到该配置请求后，获取其中携带的报文处理逻辑，并根据报文处理逻辑对每个转发端口进行配置。
可选的，当转发设备配置完成该报文处理逻辑之后，可以向网络控制功能网元发送配置响应，其中，配置响应用于指示报文处理逻辑配置完成。
S203、转发设备响应于接收到待处理数据流，基于报文处理逻辑确定用于转发待处理数据流的目标队列。
具体的，当转发设备收到待处理数据流时，首先根据配置的报文处理逻辑进行报文匹配，即若收到的待处理数据流的IP-六元组(或IP-五元组)和配置的某个报文处理逻辑中的匹配域是一致的，则基于该报文处理逻辑中的优先级、动作域，将待处理数据流放到该报文处理逻辑中指示的目标队列中，从而采用该目标队列实现对该待处理数据流的转发。
相应的，若没有报文处理逻辑中的匹配域与该待处理数据流一致，则丢弃该待处理数据流，或者将识别结果上报网络控制功能网元。
S204、转发设备基于转发设备的队列配置规则，确定待处理数据流的转发时间。
进一步的，根据队列配置规则，确定该目标队列对应的转发时间，以在该转发时间对该待处理数据流进行转发。
S205、转发设备通过目标队列，在转发时间转发待处理数据流。
需要说明的是，对于不能转发的确定性数据流，将其进行缓存，若在后续确定转发该DetNet流，则基于该报文处理逻辑中的优先级、动作域进行数据报文处理。
在一些实施例中，当接收到非DetNet流，也可以根据报文处理逻辑进行处理，但 非DetNet流的优先级要低于所有转发端口上的DetNet流的优先级，即当所在的队列中无DetNet流时，转发该非DetNet流，对于不能转发的非DetNet流，则采取丢弃的方式进行处理。
本公开提供的上述数据调度方法中，由于报文处理逻辑是基于转发设备的转发端口的队列配置规则获得的，而队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量确定的，因而，在转发数据流时，每个数据流都会在特定的队列、按照特定的转发时间进行转发，从而可以准确的确定数据传输过程的时延，进而实现对确定性网络中端到端时延的控制。
在一些实施例中，上述步骤S201具体包括如下步骤：
(1)接收转发设备发送的第一数据包。
(2)基于第一数据包和队列配置规则，获得报文处理逻辑。
其中，第一数据包为转发设备在配置完成队列配置规则后接收到的首包，该第一数据包中包括数据流的需求信息。
可以理解的是，报文通过获取首包，可以获取该首包中所包含的数据流的需求信息，从而根据需求信息为该数据流配置对应的报文处理逻辑，在后续收到数据流时，即可按照报文处理逻辑对该数据流进行相应处理。
需要说明的是，当通过第一数据包和队列配置规则获得报文处理逻辑时，有多种实施方式，接下来，结合附图对各种实施方式的具体方案进行详细说明：
在第一种实施方式中，图3为本公开一实施例提供的报文处理逻辑配置方式的流程示意图一。如图3所示，本公开实施例提供的报文处理逻辑配置方式包括如下步骤：
S301、基于转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，获得队列配置规则。
需要说明的是，对于获取队列配置规则的网元设备，本公开实施例不做具体限定。第一方面，可以由网络控制功能网元来获取转发设备的队列配置规则，第二方面，也可以由策略管理功能网元来获取转发设备的队列配置规则。
应理解，网络控制功能网元和策略管理功能网元中任一网元在获取到队列配置规则之后，可以向另一网元上报该队列配置规则。
需要说明的是，图3中以网络控制功能网元获取转发设备的队列配置规则为例示出，但不以此为限定。
可选的，在获得队列配置规则之后，可以将各转发设备的队列配置规则、转发周期和各消息队列的转发时间下发给对应的转发设备，用于转发设备对各个消息队列进行转发时间的划分。
具体的，当由策略管理功能网元获取队列配置规则时，策略管理功能网元可以先将队列配置规则发送给网络管理功能网元，由网络管理功能网元下发给转发设备进行配置。
其中，每个转发设备的转发端口可以包括多个消息队列，队列配置规则用于指示各消息队列的数据传输速率(例如是，最大传输速率、最小传输速率和平均传输速率等)、各消息队列转发数据流时的优先级，以及各消息队列在转发周期中对应的转发时间等。
具体的，在上述任一个网元获取队列配置规则时，首先基于网络拓扑，即转发设备的所在位置，确定该转发设备的转发端口所支持的消息队列的队列数量和转发端口的转发周期，同时获取转发端口的各消息队列的数据传输速率以及转发数据流时的优先级。
进一步的，根据转发周期的长时长和队列数量，将转发周期平均分配至每个消息队列，从而获得每个消息队列在转发周期中的转发时间，其中，每个消息队列对应的转发时间的时长是相同的。
更进一步的，基于各消息队列的数据传输速率、转发数据流时的优先级以及在转发周期中的转发时间，获得队列配置规则。
S302、转发设备向网络控制功能网元发送第一数据包。
其中，第一数据包为转发设备在配置完成队列配置规则后接收到的首包，该第一数据包中包括数据流的需求信息。
S303、网络控制功能网元对第一数据包进行解析，获得数据流的需求信息。
在一些实施例中，数据流的需求信息包括但不限于以下任意一种或多种：DetNet流特征、DetNet流服务需求、DetNet流标识等。
其中，DetNet流标识包括DetNet flow、源目的地地址、协议类型、端口号等信息；DetNet流服务需求包括端到端的最大时延、抖动、最小带宽、丢包率、最大数据包失序数量等信息；DetNet流特征包括间隔、最大/最小有效载荷大小、最大/最小时间段内的数据包数量等。
S304、网络控制功能网元向策略管理功能网元发送需求信息。
需要说明的是，对于发送需求信息的方式，本公开实施例不做具体限定，例如，网络控制功能网元可以向策略管理功能网元发送用户面建立请求，并在该用户面建立请求中携带该需求信息，至于其他方式，本公开不再一一赘述。
S305、策略管理功能网元根据需求信息和队列配置规则，确定路由转发规则。
其中，路由转发规则包括：至少部分DetNet流标识(用于鉴别流和生成后面的匹配项)、用于转发该数据流的转发路径上各转发设备的消息队列、下一跳、优先级、各消息队列对应的最大速率和最小速率等。
S306、策略管理功能网元向网络控制功能网元发送路由转发规则。
需要说明的是，对于发送路由转发规则的方式，本公开实施例也不做具体限定，例如，策略管理功能网元也可以向网络控制功能网元发送用户面建立请求，并在该用户面建立请求中携带该路由转发规则。
S307、网络控制功能网元根据路由转发规则确定队列信息，并根据队列信息和路由转发规则，获得报文处理逻辑。
其中，队列信息用于指示发送该数据流的转发设备的消息队列。
具体的，从路由转发规则中获取各转发设备的队列信息，从而根据队列信息和路由转发规则，生成报文处理逻辑。
S308、网络控制功能网元为目标转发设备配置报文处理逻辑，用于目标转发设备基于报文处理逻辑，转发相应的数据流。
需要说明的是，步骤S308以及转发设备转发数据流的方式，与图2所示实施例中 的方案相同，此处不再赘述。
在第二种实施方式中，图4为本公开一实施例提供的报文处理逻辑配置方式的流程示意图二。如图4所示，本公开实施例提供的报文处理逻辑配置方式包括如下步骤：
S401、基于转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，获得队列配置规则。
S402、转发设备向网络控制功能网元发送第一数据包。
S403、网络控制功能网元对第一数据包进行解析，获得数据流的需求信息。
S404、网络控制功能网元向策略管理功能网元发送需求信息。
需要说明的是，步骤S401～S404与图3所示实施例中的步骤S301～S304的方法与原理类似，具体实施方式可参考图3所示实施例，此处不再赘述。
S405、策略管理功能网元根据需求信息和队列配置规则，确定路由转发规则和队列信息。
在一种可选的实施方式中，可以由策略管理功能网元来确定队列信息，且其确定路由转发规则的方式，以及确定队列信息的方式与图3所示实施例中网络控制功能网元所执行的方式类似，此处不再赘述。
S406、策略管理功能网元向网络控制功能网元发送该路由转发规则和队列信息。
需要说明的是，对于发送路由转发规则和队列信息的方式，本公开实施例不做具体限定，例如，策略管理功能网元可以向网络控制功能网元发送用户面建立请求，并在该用户面建立请求中携带该路由转发规则和队列信息，至于其他方式，本公开不再一一赘述。
S407、网络控制功能网元根据路由转发规则和队列信息，确定报文处理逻辑。
S408、网络控制功能网元为目标转发设备配置报文处理逻辑，用于目标转发设备基于报文处理逻辑，转发相应的数据流。
需要说明的是，步骤S407～S408与图3所示实施例中的步骤S307～S308的方法与原理类似，具体实施方式可参考图3所示实施例，此处不再赘述。
在第三种实施方式中，还可以由策略管理功能网元来获取报文处理逻辑。图5为本公开一实施例提供的报文处理逻辑配置方式的流程示意图三。如图5所示，本公开实施例提供的报文处理逻辑配置方式包括如下步骤：
S501、基于转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，获得队列配置规则。
S502、转发设备向网络控制功能网元发送第一数据包。
S503、网络控制功能网元对第一数据包进行解析，获得数据流的需求信息。
S504、网络控制功能网元向策略管理功能网元发送需求信息。
需要说明的是，步骤S501～S504与图3所示实施例中的步骤S301～S304的方法与原理类似，具体实施方式可参考图3所示实施例，此处不再赘述。
S505、策略管理功能网元根据需求信息和队列配置规则，确定路由转发规则和队列信息，并根据队列信息和路由转发规则确定报文处理逻辑。
需要说明的是，可以由策略管理功能网元来确定队列信息和报文处理逻辑，且其确定路由转发规则的方式，以及确定队列信息和报文处理逻辑的方式与图3所示实施 例中网络控制功能网元所执行的方式类似，此处不再赘述。
S506、策略管理功能网元向网络控制功能网元发送报文处理逻辑。
需要说明的是，对于发送报文处理逻辑的方式，本公开实施例不做具体限定，例如，策略管理功能网元可以向网络控制功能网元发送用户面建立请求，并在该用户面建立请求中携带该报文处理逻辑，至于其他方式，本公开不再一一赘述。
S507、网络控制功能网元为目标转发设备配置报文处理逻辑，用于目标转发设备基于报文处理逻辑，转发相应的数据流。
需要说明的是，步骤S507与图3所示实施例中的步骤S308的方法与原理类似，具体实施方式可参考图3所示实施例，此处不再赘述。
在第四种实施方式中，图6为本公开一实施例提供的报文处理逻辑配置方式的流程示意图四。如图6所示，本公开实施例提供的报文处理逻辑配置方式包括如下步骤：
S601、基于转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，获得队列配置规则。
S602、转发设备向网络控制功能网元发送第一数据包。
需要说明的是，步骤S601～S602与图3所示实施例中的步骤S301～S302的方法与原理类似，具体实施方式可参考图3所示实施例，此处不再赘述。
S603、网络控制功能网元将第一数据包发送给策略管理功能网元。
本公开实施例中，网络控制功能对第一数据包不做解析，可以通过用户面建立请求，将第一数据包发送给策略管理功能网元。
可选的，若队列配置规则是由网络控制功能网元获取的，还可以通过用户面建立请求携带各消息队列的转发时间、转发周期和队列配置规则。
S604、策略管理功能网元对第一数据包进行解析，获得数据流的需求信息，并根据需求信息和队列配置规则，确定路由转发规则。
需要说明的是，策略管理功能网元解析第一数据包获取需求信息的方式，以及根据需求信息和队列配置规则，获得路由转发规则的方式与图3所示实施例中网络控制功能网元所执行的方案相同，此处不做赘述。
S605、策略管理功能网元向网络控制功能网元发送路由转发规则。
S606、网络控制功能网元根据路由转发规则确定队列信息，并根据队列信息和路由转发规则，获得报文处理逻辑。
S606、网络控制功能网元为目标转发设备配置报文处理逻辑，用于目标转发设备基于报文处理逻辑，转发相应的数据流。
需要说明的是，步骤S605～S606与图3所示实施例中的步骤S306～S308的方法与原理类似，具体实施方式可参考图3所示实施例，此处不再赘述。
在第五种实施方式中，图7为本公开一实施例提供的报文处理逻辑配置方式的流程示意图五。如图7所示，本公开实施例提供的报文处理逻辑配置方式包括如下步骤：
S701、基于转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，获得队列配置规则。
S702、转发设备向网络控制功能网元发送第一数据包。
S703、网络控制功能网元将第一数据包发送给策略管理功能网元。
S704、策略管理功能网元对第一数据包进行解析，获得数据流的需求信息，并根据需求信息和队列配置规则，确定路由转发规则和队列信息。
S705、策略管理功能网元向网络控制功能网元发送路由转发规则和队列信息。
S706、网络控制功能网元根据路由转发规则和队列信息，获得报文处理逻辑。
S707、网络控制功能网元为目标转发设备配置报文处理逻辑，用于目标转发设备基于报文处理逻辑，转发相应的数据流。
需要说明的是，在本公开实施例中，步骤S701～S702与图3所示实施例中的步骤S301～S302的方法与原理类似，步骤S703～S705与图4所示实施例中的步骤S405～S406的方法与原理类似，步骤S706～S707与图4所示实施例中的步骤S407～S408的方法与原理类似，具体实施方式可参考上述实施例，此处不再赘述。
在第六种实施方式中，图8为本公开一实施例提供的报文处理逻辑配置方式的流程示意图六。如图8所示，本公开实施例提供的报文处理逻辑配置方式包括如下步骤：
S801、基于转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，获得队列配置规则。
S802、转发设备向网络控制功能网元发送第一数据包。
S803、网络控制功能网元将第一数据包发送给策略管理功能网元。
S804、策略管理功能网元对第一数据包进行解析，获得数据流的需求信息。
S805、策略管理功能网元根据需求信息和队列配置规则，确定路由转发规则和队列信息，并根据路由转发规则和队列信息，获得报文处理逻辑。
S806、策略管理功能网元向网络控制功能网元发送报文处理逻辑。
S807、网络控制功能网元为目标转发设备配置报文处理逻辑，用于目标转发设备基于报文处理逻辑，转发相应的数据流。
需要说明的是，在本公开实施例中，步骤S801～S802与图3所示实施例中的步骤S301～S302的方法与原理类似，步骤S803～S805与图5所示实施例中的步骤S505～S506的方法与原理类似，步骤S806～S807与图5所示实施例中的步骤S506～S507的方法与原理类似，具体实施方式可参考上述实施例，此处不再赘述。
本公开实施例中，通过提供多种报文处理逻辑的获取方式，可以灵活的应用于多种网络架构中，解决不同网络架构中的确定性数据流的转发过程中，时延无法确定的问题。
在另一些实施例中，无需第一数据包，也可以获取数据流的需求信息，具体的，上述步骤S201具体包括如下方案：
(1)策略管理功能网元获取数据流的需求信息；
(2)策略管理功能网元根需求信息确定路由转发规则；
(3)策略管理功能网元或者网络控制功能网元中的至少一个网元，根据路由转发规则确定队列信息，根据队列信息和路由转发规则，获得报文处理逻辑。
具体的，当无需第一数据包来获得报文处理逻辑时，也有多种实施方式，接下来，结合附图对各种实施方式的具体方案进行详细说明：
在第一种实施方式中，图9为本公开一实施例提供的报文处理逻辑配置方式的流程示意图七。如图9所示，本公开实施例提供的报文处理逻辑配置方式包括如下步骤：
S901、基于转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，获得队列配置规则。
需要说明的是，对于获取队列配置规则的网元设备，本公开实施例不做具体限定。第一方面，可以由网络控制功能网元来获取转发设备的队列配置规则，第二方面，也可以由策略管理功能网元来获取转发设备的队列配置规则。
应理解，网络控制功能网元和策略管理功能网元中任一网元在获取到队列配置规则之后，可以向另一网元上报该队列配置规则。
可选的，在获得队列配置规则之后，可以将各转发设备的队列配置规则、转发周期和各消息队列的转发时间下发给对应的转发设备，用于转发设备对各个消息队列进行转发时间的划分。
具体的，当由策略管理功能网元获取队列配置规则时，策略管理功能网元可以先将队列配置规则发送给网络管理功能网元，由网络管理功能网元下发给转发设备进行配置。
其中，每个转发设备的转发端口可以包括多个消息队列，队列配置规则用于指示各消息队列的数据传输速率(例如是，最大传输速率、最小传输速率和平均传输速率等)、各消息队列转发数据流时的优先级，以及各消息队列在转发周期中对应的转发时间等。
具体的，在上述任一个网元获取队列配置规则时，首先基于网络拓扑，即转发设备的所在位置，确定该转发设备的转发端口所支持的消息队列的队列数量和转发端口的转发周期，同时获取转发端口的各消息队列的数据传输速率以及转发数据流时的优先级。
进一步的，根据转发周期的长时长和队列数量，将转发周期平均分配至每个消息队列，从而获得每个消息队列在转发周期中的转发时间，其中，每个消息队列对应的转发时间的时长是相同的。
更进一步的，基于各消息队列的数据传输速率、转发数据流时的优先级以及在转发周期中的转发时间，获得队列配置规则。
S902、策略管理功能网元获取数据流的需求信息，并根据需求信息，确定路由转发规则。
具体的，策略管理功能网元可以通过业务层和/或应用层，获得数据流的需求信息，至于具体获取方式，本公开实施例不做限定。
S903、策略管理功能网元向网络控制功能网元发送路由转发规则。
S904、网络控制功能网元根据路由转发规则确定队列信息，并根据队列信息和路由转发规则，获得报文处理逻辑。
需要说明的是，步骤S902～S904与图3所示实施例中的步骤S305～S307的方法与原理类似，具体实施方式可参考图3所示实施例，此处不再赘述。
S905、网络控制功能网元为目标转发设备配置报文处理逻辑，用于目标转发设备基于报文处理逻辑，转发相应的数据流。
具体的，网络控制功能网元向转发设备发送配置请求，其中，该配置请求中携带有该报文处理逻辑，相应的，转发设备在接收到该配置请求后，获取其中携带的报文 处理逻辑，并根据报文处理逻辑对每个转发端口进行配置。
可选的，当转发设备配置完成该报文处理逻辑之后，可以向网络控制功能网元发送配置响应，其中，配置响应用于指示报文处理逻辑配置完成。
可选的，网络控制功能网元在接收到转发设备发送的配置响应之后，还可以向策略管理功能网元发送用户面建立响应，该用户面建立响应用于指示转发设备的报文处理逻辑配置完成。
在第二种实施方式中，图10为本公开一实施例提供的报文处理逻辑配置方式的流程示意图八。如图10所示，本公开实施例提供的报文处理逻辑配置方式包括如下步骤：
S1001、基于转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，获得队列配置规则。
S1002、策略管理功能网元获取数据流的需求信息，并根据需求信息，确定路由转发规则和队列信息。
S1003、策略管理功能网元向网络控制功能网元发送路由转发规则和队列信息。
S1004、网络控制功能网元根据路由转发规则和队列信息，生成报文处理逻辑。
需要说明的是，步骤S1001与图3所示实施例中的步骤S301的方法与原理类似，步骤S1002～S1004与图4所示实施例中的步骤S405～S407的方法与原理类似，具体可参考上述实施例，此处不再赘述。
S1005、网络控制功能网元为目标转发设备配置报文处理逻辑，用于目标转发设备基于报文处理逻辑，转发相应的数据流。
具体的，网络控制功能网元向转发设备发送配置请求，其中，该配置请求中携带有该报文处理逻辑，相应的，转发设备在接收到该配置请求后，获取其中携带的报文处理逻辑，并根据报文处理逻辑对每个转发端口进行配置。
可选的，当转发设备配置完成该报文处理逻辑之后，可以向网络控制功能网元发送配置响应，其中，配置响应用于指示报文处理逻辑配置完成。
可选的，网络控制功能网元在接收到转发设备发送的配置响应之后，还可以向策略管理功能网元发送用户面建立响应，该用户面建立响应用于指示转发设备的报文处理逻辑配置完成。
在第三种实施方式中，图11为本公开一实施例提供的报文处理逻辑配置方式的流程示意图九。如图11所示，本公开实施例提供的报文处理逻辑配置方式包括如下步骤：
S1101、基于转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，获得队列配置规则。
S1102、策略管理功能网元获取数据流的需求信息，并根据需求信息，确定路由转发规则和队列信息，根据路由转发规则和队列信息，生成报文处理逻辑。
S1103、策略管理功能网元向网络控制功能网元发送报文处理逻辑。
需要说明的是，步骤S1101与图3所示实施例中的步骤S301的方法与原理类似，步骤S1102～S1003与图5所示实施例中的步骤S505～S506的方法与原理类似，具体可参考上述实施例，此处不再赘述。
S1104、网络控制功能网元为目标转发设备配置报文处理逻辑，用于目标转发设备基于报文处理逻辑，转发相应的数据流。
具体的，网络控制功能网元向转发设备发送配置请求，其中，该配置请求中携带有该报文处理逻辑，相应的，转发设备在接收到该配置请求后，获取其中携带的报文处理逻辑，并根据报文处理逻辑对每个转发端口进行配置。
可选的，当转发设备配置完成该报文处理逻辑之后，可以向网络控制功能网元发送配置响应，其中，配置响应用于指示报文处理逻辑配置完成。
可选的，网络控制功能网元在接收到转发设备发送的配置响应之后，还可以向策略管理功能网元发送用户面建立响应，该用户面建立响应用于指示转发设备的报文处理逻辑配置完成。
应该理解的是，虽然上述实施例中的流程图中的各个步骤按照箭头的指示依次显示，但是这些步骤并不是必然按照箭头指示的顺序依次执行。除非本文中有明确的说明，这些步骤的执行并没有严格的顺序限制，其可以以其他的顺序执行。而且，图中的至少一部分步骤可以包括多个子步骤或者多个阶段，这些子步骤或者阶段并不必然是在同一时刻执行完成，而是可以在不同的时刻执行，其执行顺序也不必然是依次进行，而是可以与其他步骤或者其他步骤的子步骤或者阶段的至少一部分轮流或者交替地执行。
本公开一实施例提供了一种数据调度装置，应用于网络控制功能网元，图12为本公开实施例提供的数据调度装置的结构示意图一。如图12所示，该数据调度装置1200包括：
获取模块1201，用于获取数据流的报文处理逻辑，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量确定的；
配置模块1202，用于为目标转发设备配置报文处理逻辑，用于相应的数据流的转发。
可选的，获取模块1201具体用于：接收转发设备发送的第一数据包；基于第一数据包和队列配置规则，获得报文处理逻辑。
可选的，获取模块1201具体用于：对第一数据包进行解析，获得数据流的需求信息；根据需求信息和队列配置规则，获得报文处理逻辑。
可选的，获取模块1201具体用于：向策略管理功能网元发送需求信息；接收策略管理功能网元根据需求信息和队列配置规则获得的路由转发规则；根据路由转发规则，获得报文处理逻辑。
可选的，获取模块1201具体用于：向策略管理功能网元发送第一数据包，用于策略管理功能网元根据第一数据包获得数据流的需求信息；接收策略管理功能网元根据需求信息和队列配置规则获得的路由转发规则；根据路由转发规则，获得报文处理逻辑。
可选的，获取模块1201具体用于：根据路由转发规则，确定数据流的队列信息，队列信息用于指示用于发送数据流的队列；根据队列信息和路由转发规则，获得报文处理逻辑。
可选的，获取模块1201具体用于：接收策略管理功能网元根据需求信息获得的队列信息；根据路由转发规则和队列信息，获得报文处理逻辑。
可选的，获取模块1201具体用于：对第一数据包进行解析，获得数据流的需求信 息；向策略管理功能网元发送需求信息；接收策略管理功能网元根据需求信息获得的报文处理逻辑。
可选的，获取模块1201具体用于：向策略管理功能网元发送第一数据包；接收策略管理功能网元根据第一数据包获得的报文处理逻辑。
可选的，该数据调度装置1200还包括：确定模块1203，用于根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，确定转发端口的队列配置规则；或者，接收模块1204，用于接收策略管理功能网元发送的队列配置规则；其中，队列配置规则用于指示各消息队列在转发端口的转发周期内的数据转发时间，数据转发时间的时长为转发设备的数据转发周期。
在此需要说明的是，本公开提供的上述数据调度装置1200，能够实现上述方法实施例中的网络控制功能网元对应的数据调度方法的步骤，且能够达到相同的技术效果，在此不再对本实施例中与方法实施例相同的部分及有益效果进行具体赘述。
本公开一实施例提供了一种数据调度装置，应用于策略管理功能网元，图13为本公开实施例提供的数据调度装置的结构示意图二。如图13所示，该数据调度装置1300包括：
获取模块1301，用于获取数据流的需求信息；确定模块1302，用于根据需求信息和队列配置规则，确定路由转发规则，根据路由转发规则确定数据流的报文处理逻辑，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；发送模块1303，用于向网络控制功能网元发送报文处理逻辑，报文处理逻辑用于相应的数据流的转发。
可选的，确定模块1302具体用于：根据需求信息和队列配置规则，确定用于处理数据流的队列信息；根据路由转发规则和队列信息，确定报文处理逻辑。
在此需要说明的是，本公开提供的上述数据调度装置1300，能够实现上述方法实施例中的策略管理功能网元对应的数据调度方法的步骤，且能够达到相同的技术效果，在此不再对本实施例中与方法实施例相同的部分及有益效果进行具体赘述。
本公开一实施例提供了一种数据调度装置，应用于策略管理功能网元，图14为本公开实施例提供的数据调度装置的结构示意图三。如图14所示，该数据调度装置1400包括：
获取模块1401，用于获取数据流的需求信息，根据需求信息和队列配置规则，获得路由转发规则，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；发送模块1402，用于向网络控制功能网元发送路由转发规则，路由转发规则用于确定报文处理逻辑，报文处理逻辑用于相应的数据流的转发。
可选的，发送模块1402具体用于：根据需求信息和队列配置规则，确定队列信息；向网络控制功能网元发送队列信息和路由转发规则，用于网络控制功能网元根据路由转发规则和队列信息，确定报文处理逻辑。
可选的，获取模块1401具体用于：接收网络控制功能网元发送的第一数据包中的数据流的需求信息。
可选的，获取模块1401具体用于：接收网络控制功能网元发送的第一数据包；解 析第一数据包，获得数据流的需求信息。
可选的，该数据调度装置1400还包括：确定模块1403，用于根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量，确定转发端口的队列配置规则；或者，接收网络控制功能网元发送的队列配置规则；其中，队列配置规则用于指示各消息队列在转发端口的转发周期内的数据转发时间，数据转发时间的时长为转发设备的数据转发周期。
在此需要说明的是，本公开提供的上述数据调度装置1400，能够实现上述方法实施例中的策略管理功能网元对应的数据调度方法的步骤，且能够达到相同的技术效果，在此不再对本实施例中与方法实施例相同的部分及有益效果进行具体赘述。
本公开一实施例提供了一种数据调度装置，应用于转发设备，图15为本公开实施例提供的数据调度装置的结构示意图四。如图15所示，该数据调度装置1500包括：
确定模块1501，用于响应于接收到待处理数据流，基于报文处理逻辑确定用于转发待处理数据流的目标队列，基于转发设备的队列配置规则，确定待处理数据流的转发时间，报文处理逻辑是网络控制功能网元为转发设备配置的；转发模块1502，用于通过目标队列，在转发时间转发待处理数据流。
可选的，该数据调度装置1500还包括：发送模块1503，用于向网络控制功能网元发送第一数据包；
接收模块1504，用于接收网络控制功能网元根据第一数据包获得的报文处理逻辑。
在此需要说明的是，本公开提供的上述数据调度装置1500，能够实现上述方法实施例中的转发设备对应的数据调度方法的步骤，且能够达到相同的技术效果，在此不再对本实施例中与方法实施例相同的部分及有益效果进行具体赘述。
本公开一实施例提供了一种网络控制功能网元，图16为本公开实施例提供的网络控制功能网元的结构示意图。如图16所示，该网络控制功能网元包括：收发机1601、处理器1602和存储器1603。
收发机1601，用于在处理器1602的控制下接收和发送数据。其中，在图16中，总线架构可以包括任意数量的互联的总线和桥，具体由处理器1602代表的一个或多个处理器和存储器1603代表的存储器的各种电路链接在一起。总线架构还可以将诸如外围设备、稳压器和功率管理电路等之类的各种其他电路链接在一起，这些都是本领域所公知的，因此，本文不再对其进行进一步描述。总线接口提供接口。收发机1601可以是多个元件，即包括发送机和接收机，提供用于在传输介质上与各种其他装置通信的单元，这些传输介质包括无线信道、有线信道、光缆等传输介质。处理器1602负责管理总线架构和通常的处理，存储器1603可以存储处理器1602在执行操作时所使用的数据。
处理器1602负责管理总线架构和通常的处理，存储器1603可以存储处理器1602在执行操作时所使用的数据。
可选的，处理器1602可以是中央处理器(central processing unit，CPU)、专用集成电路(Application Specific Integrated Circuit，ASIC)、现场可编程门阵列(Field－Programmable Gate Array，FPGA)或复杂可编程逻辑器件(Complex Programmable Logic Device，CPLD)，处理器也可以采用多核架构。处理器1602通过调用存储器1603存 储的计算机程序，用于按照获得的可执行指令执行本公开实施例提供的有关终端设备的任一方法，处理器与存储器也可以物理上分开布置。
具体的，处理器1602用于读取存储器中的计算机程序并执行以下操作：获取数据流的报文处理逻辑，报文处理逻辑是基于转发设备的转发端口的队列配置规则获得的，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量确定的；为目标转发设备配置报文处理逻辑，用于相应的数据流的转发。
可选的，获取数据流的报文处理逻辑，包括：接收转发设备发送的第一数据包；基于第一数据包和队列配置规则，获得报文处理逻辑。
可选的，基于第一数据包和队列配置规则，获得报文处理逻辑，包括：对第一数据包进行解析，获得数据流的需求信息；根据需求信息和队列配置规则，获得报文处理逻辑。
可选的，根据需求信息和队列配置规则，获得报文处理逻辑，包括：向策略管理功能网元发送需求信息；接收策略管理功能网元根据需求信息和队列配置规则获得的路由转发规则；根据路由转发规则，获得报文处理逻辑。
可选的，基于第一数据包和队列配置规则，获得报文处理逻辑，包括：向策略管理功能网元发送第一数据包，用于策略管理功能网元根据第一数据包获得数据流的需求信息；接收策略管理功能网元根据需求信息和队列配置规则获得的路由转发规则；根据路由转发规则，获得报文处理逻辑。
可选的，根据路由转发规则，获得报文处理逻辑，包括：根据路由转发规则，确定数据流的队列信息，队列信息用于指示用于发送数据流的队列；根据队列信息和路由转发规则，获得报文处理逻辑。
可选的，根据路由转发规则，获得报文处理逻辑，包括：接收策略管理功能网元根据需求信息获得的队列信息；根据路由转发规则和队列信息，获得报文处理逻辑。
可选的，基于第一数据包和队列配置规则，获得的报文处理逻辑，包括：
对第一数据包进行解析，获得数据流的需求信息；向策略管理功能网元发送需求信息；接收策略管理功能网元根据需求信息获得的报文处理逻辑。
可选的，基于第一数据包和队列配置规则，获得的报文处理逻辑，包括：向策略管理功能网元发送第一数据包；接收策略管理功能网元根据第一数据包获得的报文处理逻辑。
可选的，在获取数据流的报文处理逻辑之前，处理器1602还用于：根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，确定转发端口的队列配置规则；或者，接收策略管理功能网元发送的队列配置规则；队列配置规则用于指示各消息队列在转发端口的转发周期内的数据转发时间，数据转发时间的时长为转发设备的数据转发周期。
在此需要说明的是，本公开提供的上述网络控制功能网元，能够实现上述方法实施例中对应于网络控制功能网元所实现的所有方法步骤，且能够达到相同的技术效果，在此不再对本实施例中与方法实施例相同的部分及有益效果进行具体赘述。
本公开一实施例提供了一种策略管理功能网元，图17为本公开实施例提供的策略管理功能网元的结构示意图。如图17所示，该策略管理功能网元1700包括：收发机 1701、处理器1702和存储器1703。
收发机1701，用于在处理器1702的控制下接收和发送数据。其中，在图17中，总线架构可以包括任意数量的互联的总线和桥，具体由处理器1702代表的一个或多个处理器和存储器1703代表的存储器的各种电路链接在一起。总线架构还可以将诸如外围设备、稳压器和功率管理电路等之类的各种其他电路链接在一起，这些都是本领域所公知的，因此，本文不再对其进行进一步描述。总线接口提供接口。收发机1701可以是多个元件，即包括发送机和接收机，提供用于在传输介质上与各种其他装置通信的单元，这些传输介质包括无线信道、有线信道、光缆等传输介质。处理器1702负责管理总线架构和通常的处理，存储器1703可以存储处理器1702在执行操作时所使用的数据。
处理器1702负责管理总线架构和通常的处理，存储器1703可以存储处理器1702在执行操作时所使用的数据。
可选的，处理器1702可以是中央处埋器(central processing unit，CPU)、专用集成电路(Application Specific Integrated Circuit，ASIC)、现场可编程门阵列(Field－Programmable Gate Array，FPGA)或复杂可编程逻辑器件(Complex Programmable Logic Device，CPLD)，处理器也可以采用多核架构。处理器1702通过调用存储器1703存储的计算机程序，用于按照获得的可执行指令执行本公开实施例提供的有关终端设备的任一方法，处理器与存储器也可以物理上分开布置。
在一些实施例中，处理器1702用于读取存储器中的计算机程序并执行以下操作：获取数据流的需求信息；根据需求信息和队列配置规则，确定路由转发规则，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；根据路由转发规则确定数据流的报文处理逻辑；向网络控制功能网元发送报文处理逻辑，报文处理逻辑用于相应的数据流的转发。
可选的，根据路由转发规则确定报文处理逻辑，包括：根据需求信息和队列配置规则，确定用于处理数据流的队列信息；根据路由转发规则和队列信息，确定报文处理逻辑。
在另一些实施例中，处理器1702还可以用于读取存储器中的计算机程序并执行以下操作：获取数据流的需求信息；根据需求信息和队列配置规则，获得路由转发规则，队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；向网络控制功能网元发送路由转发规则，路由转发规则用于确定报文处理逻辑，报文处理逻辑用于相应的数据流的转发。
可选的，向网络控制功能网元发送路由转发规则，包括：根据需求信息和队列配置规则，确定队列信息；向网络控制功能网元发送队列信息和路由转发规则，用于网络控制功能网元根据路由转发规则和队列信息，确定报文处理逻辑。
可选的，获取数据流的需求信息，包括：接收网络控制功能网元发送的第一数据包中的数据流的需求信息。
可选的，获取数据流的需求信息，包括：接收网络控制功能网元发送的第一数据包；解析第一数据包，获得数据流的需求信息。
可选的，在获取数据流的需求信息之前，处理器还用于：根据转发设备的数据转 发周期、转发设备的转发端口所支持消息队列的队列数量，确定转发端口的队列配置规则；或者，接收网络控制功能网元发送的队列配置规则；其中，队列配置规则用于指示各消息队列在转发端口的转发周期内的数据转发时间，数据转发时间的时长为转发设备的数据转发周期。
在此需要说明的是，本公开提供的上述策略管理功能网元，能够实现上述方法实施例中对应于策略管理功能网元所实现的所有方法步骤，且能够达到相同的技术效果，在此不再对本实施例中与方法实施例相同的部分及有益效果进行具体赘述。
本公开一实施例提供了一种转发设备，图18为本公开实施例提供的转发设备的结构示意图。如图18所示，该转发设备1800包括：收发机1801、处理器1802和存储器1803。
收发机1801，用于在处理器1802的控制下接收和发送数据。其中，在图18中，总线架构可以包括任意数量的互联的总线和桥，具体由处理器1802代表的一个或多个处理器和存储器1803代表的存储器的各种电路链接在一起。总线架构还可以将诸如外围设备、稳压器和功率管理电路等之类的各种其他电路链接在一起，这些都是本领域所公知的，因此，本文不再对其进行进一步描述。总线接口提供接口。收发机1801可以是多个元件，即包括发送机和接收机，提供用于在传输介质上与各种其他装置通信的单元，这些传输介质包括无线信道、有线信道、光缆等传输介质。处理器1802负责管理总线架构和通常的处理，存储器1803可以存储处理器1802在执行操作时所使用的数据。
处理器1802负责管理总线架构和通常的处理，存储器1803可以存储处理器1802在执行操作时所使用的数据。
可选的，处理器1802可以是中央处埋器(central processing unit，CPU)、专用集成电路(Application Specific Integrated Circuit，ASIC)、现场可编程门阵列(Field－Programmable Gate Array，FPGA)或复杂可编程逻辑器件(Complex Programmable Logic Device，CPLD)，处理器也可以采用多核架构。处理器1802通过调用存储器1803存储的计算机程序，用于按照获得的可执行指令执行本公开实施例提供的有关终端设备的任一方法，处理器与存储器也可以物理上分开布置。
在一些实施例中，处理器1802用于读取存储器中的计算机程序并执行以下操作：
响应于接收到待处理数据流，基于报文处理逻辑确定用于转发待处理数据流的目标队列；基于转发设备的队列配置规则，确定待处理数据流的转发时间，报文处理逻辑是网络控制功能网元为转发设备配置的；通过目标队列，在转发时间转发待处理数据流。
可选的，处理器还用于：向网络控制功能网元发送第一数据包；接收网络控制功能网元根据第一数据包获得的报文处理逻辑。
在此需要说明的是，本公开提供的上述转发络设备，能够实现上述方法实施例中对应于转发设备所实现的所有方法步骤，且能够达到相同的技术效果，在此不再对本实施例中与方法实施例相同的部分及有益效果进行具体赘述。
需要说明的是，本公开实施例中对单元的划分是示意性的，仅仅为一种逻辑功能划分，实际实现时可以有另外的划分方式。另外，在本公开各个实施例中的各功能单 元可以集成在一个处理单元中，也可以是各个单元单独物理存在，也可以两个或两个以上单元集成在一个单元中。上述集成的单元既可以采用硬件的形式实现，也可以采用软件功能单元的形式实现。
上述集成的单元如果以软件功能单元的形式实现并作为独立的产品销售或使用时，可以存储在一个处理器可读取存储介质中。基于这样的理解，本公开的技术方案本质上或者说对现有技术做出贡献的部分或者该技术方案的全部或部分可以以软件产品的形式体现出来，该计算机软件产品存储在一个存储介质中，包括若干指令用于一台计算机设备(可以是个人计算机，服务器，或者网络设备等)或处理器(processor)执行本公开各个实施例方法的全部或部分步骤。而前述的存储介质包括：U盘、移动硬盘、只读存储器(Read-Only Memory，ROM)、随机存取存储器(Random Access Memory，RAM)、磁碟或者光盘等各种可以存储程序代码的介质。
本公开实施例提供了一种处理器可读存储介质，处理器可读存储介质存储有计算机程序，计算机程序用于使处理器执行本公开实施例提供的有关网络节能的方法，使得处理器能够实现上述方法实施例中网络设备所实现的所有网络节能方法的步骤，且能够达到相同的技术效果，在此不再对本实施例中与方法实施例相同的部分及有益效果进行具体赘述。其中，处理器可读存储介质可以是处理器能够存取的任何可用介质或数据存储设备，包括但不限于磁性存储器(例如软盘、硬盘、磁带、磁光盘(MO)等)、光学存储器(例如CD、DVD、BD、HVD等)、以及半导体存储器(例如ROM、EPROM、EEPROM、非易失性存储器(NAND FLASH)、固态硬盘(SSD))等。
本公开的一实施例还提供一种包含指令的计算机程序产品，计算机程序存储在存储介质中，至少一个处理器可以从存储介质中读取计算机程序，至少一个处理器执行计算机程序时可实现上述方法实施例中网络设备所实现的所有数据调度方法的步骤，且能够达到相同的技术效果，在此不再对本实施例中与方法实施例相同的部分及有益效果进行具体赘述。
本公开实施例还提供一种通信系统，包括网络设备和以下任意一种或多种：终端设备、核心网、集中单元CU或分布单元DU。其中，网络设备能够执行上述数据调度方法的实施例中的所有步骤，且能够达到相同的技术效果。在此不再对本实施例中与方法实施例相同的部分及有益效果进行具体赘述。
本领域内的技术人员应明白，本公开的实施例可提供为方法、系统、或计算机程序产品，因此，本公开可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且，本公开可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器和光学存储器等)上实施的计算机程序产品的形式。
本公开是参照根据本公开实施例的方法、装置、和计算机程序产品的信令交互示意图和/或方框图来描述的。应理解可由计算机可执行指令实现信令交互示意图和/或方框图中的每一流程和/或方框、以及信令交互示意图和/或方框图中的流程和/或方框的结合。可提供这些计算机可执行指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在信令交互示意图一个流程或多 个流程和/或方框图一个方框或多个方框中指定的功能的装置。这些处理器可执行指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的处理器可读存储器中，使得存储在该处理器可读存储器中的指令产生包括指令装置的制造品，该指令装置实现在信令交互示意图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。
这些处理器可执行指令也可装载到计算机或其他可编程数据处理设备上，使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在信令交互示意图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。
显然，本领域的技术人员可以对本公开进行各种改动和变型而不脱离本公开的精神和范围。这样，倘若本公开的这些修改和变型属于本公开权利要求及其等同技术的范围之内，则本公开也意图包含这些改动和变型在内。

Claims (30)

  1. 一种数据调度方法，其特征在于，应用于网络控制功能网元，所述数据调度方法包括：
    获取数据流的报文处理逻辑，所述报文处理逻辑是基于转发设备的转发端口的队列配置规则获得的，所述队列配置规则是根据转发设备的数据转发周期、转发端口所支持的消息队列的队列数量确定的；
    为目标转发设备配置所述报文处理逻辑，用于相应的数据流的转发。
  2. 根据权利要求1所述的数据调度方法，其特征在于，所述获取数据流的报文处理逻辑，包括：接收所述转发设备发送的第一数据包；
    基于所述第一数据包和所述队列配置规则，获得所述报文处理逻辑。
  3. 根据权利要求2所述的数据调度方法，其特征在于，所述基于所述第一数据包和所述队列配置规则，获得所述报文处理逻辑，包括：
    对所述第一数据包进行解析，获得所述数据流的需求信息；
    根据所述需求信息和所述队列配置规则，获得所述报文处理逻辑。
  4. 根据权利要求3所述的数据调度方法，其特征在于，所述根据所述需求信息和所述队列配置规则，获得所述报文处理逻辑，包括：
    向策略管理功能网元发送所述需求信息；接收所述策略管理功能网元根据所述需求信息和所述队列配置规则获得的路由转发规则；根据所述路由转发规则，获得所述报文处理逻辑。
  5. 根据权利要求2所述的数据调度方法，其特征在于，所述基于所述第一数据包和所述队列配置规则，获得所述报文处理逻辑，包括：
    向策略管理功能网元发送所述第一数据包，用于所述策略管理功能网元根据所述第一数据包获得所述数据流的需求信息；接收所述策略管理功能网元根据所述需求信息和所述队列配置规则获得的路由转发规则；根据所述路由转发规则，获得所述报文处理逻辑。
  6. 根据权利要求4或5所述的数据调度方法，其特征在于，所述根据所述路由转发规则，获得所述报文处理逻辑，包括：
    根据所述路由转发规则，确定所述数据流的队列信息，所述队列信息用于指示用于发送所述数据流的队列；根据所述队列信息和所述路由转发规则，获得所述报文处理逻辑。
  7. 根据权利要求4或5所述的数据调度方法，其特征在于，所述根据所述路由转发规则，获得所述报文处理逻辑，包括：
    接收所述策略管理功能网元根据所述需求信息获得的队列信息；根据所述路由转发规则和所述队列信息，获得所述报文处理逻辑。
  8. 根据权利要求2所述的数据调度方法，其特征在于，所述基于所述第一数据包和所述队列配置规则，获得的所述报文处理逻辑，包括：
    对所述第一数据包进行解析，获得所述数据流的需求信息；向策略管理功能网元发送所述需求信息；接收所述策略管理功能网元根据所述需求信息获得的所述报文处理逻辑。
  9. 根据权利要求2所述的数据调度方法，其特征在于，所述基于所述第一数据包和所述队列配置规则，获得的所述报文处理逻辑，包括：
    向策略管理功能网元发送所述第一数据包；接收所述策略管理功能网元根据所述第一数据包获得的所述报文处理逻辑。
  10. 根据权利要求1所述的数据调度方法，其特征在于，在获取数据流的报文处理逻辑之前，还包括：
    根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，确定所述转发端口的队列配置规则；或者，接收策略管理功能网元发送的所述队列配置规则；其中，所述队列配置规则用于指示各所述消息队列在所述转发端口的转发周期内的数据转发时间，所述数据转发时间的时长为所述转发设备的数据转发周期。
  11. 一种数据调度方法，其特征在于，应用于策略管理功能网元，所述数据调度方法包括：
    获取数据流的需求信息；
    根据所述需求信息和队列配置规则，确定路由转发规则，所述队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；
    根据所述路由转发规则确定所述数据流的报文处理逻辑；
    向网络控制功能网元发送所述报文处理逻辑，所述报文处理逻辑用于指示相应的数据流的转发。
  12. 根据权利要求11所述的数据调度方法，其特征在于，所述根据所述路由转发规则确定报文处理逻辑，包括：
    根据所述需求信息和队列配置规则，确定用于处理所述数据流的队列信息；根据所述路由转发规则和所述队列信息，确定所述报文处理逻辑。
  13. 一种数据调度方法，其特征在于，应用于策略管理功能网元，所述数据调度方法包括：
    获取数据流的需求信息；根据所述需求信息和队列配置规则，获得路由转发规则，所述队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；向网络控制功能网元发送所述路由转发规则，所述路由转发规则用于确定报文处理逻辑，所述报文处理逻辑用于相应的数据流的转发。
  14. 根据权利要求13所述的数据调度方法，其特征在于，所述向网络控制功能网元发送所述路由转发规则，包括：
    根据所述需求信息和队列配置规则，确定队列信息；向所述网络控制功能网元发送所述队列信息和所述路由转发规则，用于所述网络控制功能网元根据所述路由转发规则和所述队列信息，确定所述报文处理逻辑。
  15. 根据权利要求11至14中任一项所述的数据调度方法，其特征在于，所述获取数据流的需求信息，包括：接收所述网络控制功能网元发送的第一数据包中的数据流的需求信息。
  16. 根据权利要求11至14中任一项所述的数据调度方法，其特征在于，所述获取数据流的需求信息，包括：接收所述网络控制功能网元发送的第一数据包；解析所述第一数据包，获得所述数据流的需求信息。
  17. 根据权利要求11至14中任一项所述的数据调度方法，其特征在于，在获取数据流的需求信息之前，还包括：
    根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量，确定所述转发端口的队列配置规则；或者，接收所述网络控制功能网元发送的队列配置规则；其中，所述队列配置规则用于指示各所述消息队列在所述转发端口的转发周期内的数据转发时间，所述数据转发时间的时长为所述转发设备的数据转发周期。
  18. 一种数据调度方法，其特征在于，应用于转发设备，所述数据调度方法包括：
    响应于接收到待处理数据流，基于报文处理逻辑确定用于转发所述待处理数据流的目标队列；基于所述转发设备的队列配置规则，确定所述待处理数据流的转发时间，所述报文处理逻辑是网络控制功能网元为所述转发设备配置的；通过所述目标队列，在所述转发时间转发所述待处理数据流。
  19. 根据权利要求18所述的数据调度方法，其特征在于，还包括：向所述网络控制功能网元发送第一数据包；接收所述网络控制功能网元根据所述第一数据包获得的所述报文处理逻辑。
  20. 一种数据调度装置，其特征在于，应用于网络控制功能网元，所述数据调度装置包括：
    获取模块，用于获取数据流的报文处理逻辑，所述报文处理逻辑是基于转发设备的转发端口的队列配置规则获得的，所述队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量确定的；
    配置模块，用于为目标转发设备配置所述报文处理逻辑，用于相应的数据流的转发。
  21. 一种数据调度装置，其特征在于，应用于策略管理功能网元，所述数据调度装置包括：
    获取模块，用于获取数据流的需求信息；
    确定模块，用于根据所述需求信息和队列配置规则，确定路由转发规则，根据所述路由转发规则确定所述数据流的报文处理逻辑，所述队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；
    发送模块，用于向网络控制功能网元发送所述报文处理逻辑，所述报文处理逻辑用于相应的数据流的转发。
  22. 一种数据调度装置，其特征在于，应用于策略管理功能网元，所述数据调度装置包括：
    获取模块，用于获取数据流的需求信息，根据所述需求信息和队列配置规则，获得路由转发规则，所述队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；
    发送模块，用于向网络控制功能网元发送所述路由转发规则，所述路由转发规则用于确定报文处理逻辑，所述报文处理逻辑用于相应的数据流的转发。
  23. 根据权利要求22所述的数据调度装置，其特征在于，还包括：
    确定模块，用于根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量，确定所述转发端口的队列配置规则；或者，接收策略管理功能网 元发送的所述队列配置规则；其中，所述队列配置规则用于指示各所述消息队列在所述转发端口的转发周期内的数据转发时间，所述数据转发时间的时长为所述转发设备的数据转发周期。
  24. 一种数据调度装置，其特征在于，应用于转发设备，所述数据调度装置包括：
    确定模块，用于响应于接收到待处理数据流，基于报文处理逻辑确定用于转发所述待处理数据流的目标队列，基于所述转发设备的队列配置规则，确定所述待处理数据流的转发时间，所述报文处理逻辑是网络控制功能网元为所述转发设备配置的；
    转发模块，用于通过所述目标队列，在所述转发时间转发所述待处理数据流。
  25. 一种网络控制功能网元，其特征在于，包括：
    存储器，用于存储计算机程序；
    收发机，用于在处理器的控制下收发数据；
    处理器，用于读取所述存储器中的计算机程序并执行以下操作：
    获取数据流的报文处理逻辑，所述报文处理逻辑是基于转发设备的转发端口的队列配置规则获得的，所述队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持的消息队列的队列数量确定的；为目标转发设备配置所述报文处理逻辑，用于相应的数据流的转发。
  26. 一种策略管理功能网元，其特征在于，包括：
    存储器，用于存储计算机程序；
    收发机，用于在处理器的控制下收发数据；
    处理器，用于读取所述存储器中的计算机程序并执行以下操作：
    获取数据流的需求信息；根据所述需求信息和队列配置规则，确定路由转发规则，所述队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；根据所述路由转发规则确定所述数据流的报文处理逻辑；向网络控制功能网元发送所述报文处理逻辑，所述报文处理逻辑用于相应的数据流的转发。
  27. 一种策略管理功能网元，其特征在于，包括：
    存储器，用于存储计算机程序；
    收发机，用于在处理器的控制下收发数据；
    处理器，用于读取所述存储器中的计算机程序并执行以下操作：
    获取数据流的需求信息；根据所述需求信息和队列配置规则，获得路由转发规则，所述队列配置规则是根据转发设备的数据转发周期、转发设备的转发端口所支持消息队列的队列数量确定的；向网络控制功能网元发送所述路由转发规则，所述路由转发规则用于确定报文处理逻辑，所述报文处理逻辑用于相应的数据流的转发。
  28. 一种转发设备，其特征在于，包括：
    存储器，用于存储计算机程序；
    收发机，用于在处理器的控制下收发数据；
    处理器，用于读取所述存储器中的计算机程序并执行以下操作：响应于接收到待处理数据流，基于报文处理逻辑确定用于转发所述待处理数据流的目标队列；基于所述转发设备的队列配置规则，确定所述待处理数据流的转发时间，所述报文处理逻辑 是网络控制功能网元为所述转发设备配置的；通过所述目标队列，在所述转发时间转发所述待处理数据流。
  29. 一种处理器可读存储介质，其特征在于，所述处理器可读存储介质存储有计算机程序，所述计算机程序用于使处理器执行权利要求1至19中任一项所述的数据调度方法。
  30. 一种计算机程序产品，其特征在于，包括：计算机程序，所述计算机程序被处理器执行时实现如权利要求1至19中任一项所述的数据调度方法。
PCT/CN2023/076165 2022-02-15 2023-02-15 数据调度方法、装置、设备及存储介质 Ceased WO2023155802A1 (zh)

Priority Applications (3)

Application Number Priority Date Filing Date Title
JP2024547292A JP2025505462A (ja) 2022-02-15 2023-02-15 データのスケジューリング方法、装置、デバイス及び記憶媒体
KR1020247029076A KR20240144293A (ko) 2022-02-15 2023-02-15 데이터 스케줄링 방법, 장치, 기기 및 저장매체
EP23755804.4A EP4482115A4 (en) 2022-02-15 2023-02-15 DATA SCHEDULING METHOD, APPARATUS, DEVICE AND STORAGE MEDIUM

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
CN202210139235.3A CN116647894A (zh) 2022-02-15 2022-02-15 数据调度方法、装置、设备及存储介质
CN202210139235.3 2022-02-15

Publications (1)

Publication Number Publication Date
WO2023155802A1 true WO2023155802A1 (zh) 2023-08-24

Family

ID=87577563

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/CN2023/076165 Ceased WO2023155802A1 (zh) 2022-02-15 2023-02-15 数据调度方法、装置、设备及存储介质

Country Status (5)

Country Link
EP (1) EP4482115A4 (zh)
JP (1) JP2025505462A (zh)
KR (1) KR20240144293A (zh)
CN (1) CN116647894A (zh)
WO (1) WO2023155802A1 (zh)

Families Citing this family (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN120301792A (zh) * 2024-01-10 2025-07-11 华为技术有限公司 网络测量方法及相关设备
CN118802779B (zh) * 2024-03-26 2025-11-21 中国移动通信集团终端有限公司 数据转发的方法及装置、电子设备和存储介质

Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN111431822A (zh) * 2020-04-19 2020-07-17 汪勤思 一种确定性时延业务智能调度与控制实施方法
WO2021148152A1 (en) * 2020-01-23 2021-07-29 Nokia Solutions And Networks Oy Mechanism to control forwarding of deterministic data flow
WO2021180073A1 (zh) * 2020-03-09 2021-09-16 中国移动通信有限公司研究院 报文传输方法、装置、网络节点及存储介质
CN113711572A (zh) * 2021-07-15 2021-11-26 新华三技术有限公司 一种报文传输方法及装置

Family Cites Families (6)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
US7292578B1 (en) * 2001-06-19 2007-11-06 Cisco Technology, Inc. Flexible, high performance support for QoS on an arbitrary number of queues
CN106656864B (zh) * 2017-02-21 2020-04-28 中国联合网络通信集团有限公司 一种报文转发调度方法及装置
CN110138813B (zh) * 2018-02-02 2021-11-19 华为技术有限公司 一种传输数据的方法、通信装置及用户面功能实体
CN115988579A (zh) * 2019-01-10 2023-04-18 华为技术有限公司 实现业务连续性的方法、装置及系统
CN112532535B (zh) * 2019-09-17 2022-10-04 华为技术有限公司 一种用于优化网络拥塞的方法和装置
US12355673B2 (en) * 2020-11-27 2025-07-08 New H3C Technologies Co., Ltd. Packet forwarding method, packet forwarding apparatus and electronic device

Patent Citations (4)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
WO2021148152A1 (en) * 2020-01-23 2021-07-29 Nokia Solutions And Networks Oy Mechanism to control forwarding of deterministic data flow
WO2021180073A1 (zh) * 2020-03-09 2021-09-16 中国移动通信有限公司研究院 报文传输方法、装置、网络节点及存储介质
CN111431822A (zh) * 2020-04-19 2020-07-17 汪勤思 一种确定性时延业务智能调度与控制实施方法
CN113711572A (zh) * 2021-07-15 2021-11-26 新华三技术有限公司 一种报文传输方法及装置

Non-Patent Citations (1)

* Cited by examiner, † Cited by third party
Title
See also references of EP4482115A4

Also Published As

Publication number Publication date
CN116647894A (zh) 2023-08-25
EP4482115A1 (en) 2024-12-25
JP2025505462A (ja) 2025-02-26
EP4482115A4 (en) 2025-05-28
KR20240144293A (ko) 2024-10-02

Similar Documents

Publication Publication Date Title
CN109412964B (zh) 报文控制方法及网络装置
KR102620026B1 (ko) 패킷 처리 방법, 관련 기기 및 컴퓨터 저장 매체
EP4152703A1 (en) Network control method and device
CN112448885B (zh) 一种业务报文传输的方法及设备
CN113382442A (zh) 报文传输方法、装置、网络节点及存储介质
WO2017084487A1 (zh) 用于获得目标传输路径的方法和网络节点
CN114128228B (zh) 通过SRv6头传输MTNC-ID以实现5G传输
EP3817307A1 (en) Message processing method and device
CN105874752A (zh) 一种用于一个或多个时延段的源路由的系统和方法
CN113055293B (zh) 软件定义广域网中的选路方法及装置、通信系统
CN114128227B (zh) 在支持SRv6的数据面上传输MTNC-ID以实现5G传输
EP4432622A1 (en) Method and apparatus for constructing deterministic routing, and storage medium
WO2023155802A1 (zh) 数据调度方法、装置、设备及存储介质
WO2021089018A1 (zh) 一种通信方法、装置及系统
CN114401228A (zh) 一种端到端的跨广域确定性传输网络架构和方法
WO2013013642A1 (zh) 处理跨环业务的方法和相交节点
US11646978B2 (en) Data communication method and apparatus
Abbou et al. Towards SDN-based deterministic networking: Deterministic E2E delay case
WO2021026740A1 (zh) 流量均衡方法、网络设备及电子设备
CN111698787A (zh) 调度规则确定方法及其装置
US20190342227A1 (en) Load Sharing Method and Network Device
US12328264B2 (en) Method and apparatus for ensuring deterministic latency of network slice, storage medium, and product
CN112449382A (zh) 一种数据传输方法和服务器
WO2026066598A1 (zh) 业务处理通道建立方法、装置、设备及存储介质
CN116962218A (zh) 报文转发方法、装置、设备及存储介质

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 23755804

Country of ref document: EP

Kind code of ref document: A1

WWE Wipo information: entry into national phase

Ref document number: 2024547292

Country of ref document: JP

ENP Entry into the national phase

Ref document number: 20247029076

Country of ref document: KR

Kind code of ref document: A

WWE Wipo information: entry into national phase

Ref document number: 2023755804

Country of ref document: EP

NENP Non-entry into the national phase

Ref country code: DE

ENP Entry into the national phase

Ref document number: 2023755804

Country of ref document: EP

Effective date: 20240916

WWW Wipo information: withdrawn in national office

Ref document number: 2023755804

Country of ref document: EP