CN114338499B - Data transmission method, device and electronic equipment - Google Patents
Data transmission method, device and electronic equipment Download PDFInfo
- Publication number
- CN114338499B CN114338499B CN202111649753.1A CN202111649753A CN114338499B CN 114338499 B CN114338499 B CN 114338499B CN 202111649753 A CN202111649753 A CN 202111649753A CN 114338499 B CN114338499 B CN 114338499B
- Authority
- CN
- China
- Prior art keywords
- message processing
- message
- priority
- route
- time delay
- 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.)
- Active
Links
- 238000000034 method Methods 0.000 title claims abstract description 57
- 230000005540 biological transmission Effects 0.000 title claims abstract description 52
- 238000012545 processing Methods 0.000 claims abstract description 243
- 230000008569 process Effects 0.000 claims description 5
- 238000012546 transfer Methods 0.000 claims description 3
- 239000012634 fragment Substances 0.000 claims 4
- 238000010586 diagram Methods 0.000 description 12
- 238000004891 communication Methods 0.000 description 4
- 238000013500 data storage Methods 0.000 description 3
- 230000006870 function Effects 0.000 description 3
- 230000005012 migration Effects 0.000 description 3
- 238000013508 migration Methods 0.000 description 3
- 230000003287 optical effect Effects 0.000 description 3
- 230000004044 response Effects 0.000 description 3
- 238000004364 calculation method Methods 0.000 description 2
- 230000008878 coupling Effects 0.000 description 2
- 238000010168 coupling process Methods 0.000 description 2
- 238000005859 coupling reaction Methods 0.000 description 2
- 230000000694 effects Effects 0.000 description 2
- 238000010295 mobile communication Methods 0.000 description 2
- 230000006978 adaptation Effects 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 239000004973 liquid crystal related substance Substances 0.000 description 1
- 238000012986 modification Methods 0.000 description 1
- 230000004048 modification Effects 0.000 description 1
- 230000006855 networking Effects 0.000 description 1
- 230000007704 transition Effects 0.000 description 1
Landscapes
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The invention discloses a data transmission method, a device thereof and electronic equipment. Wherein the method comprises the following steps: acquiring a message to be sent; traversing the message processing examples in the plurality of route linked lists according to the priority order until the target message processing example is retrieved, wherein the priorities of the plurality of route linked lists are different, and the message processing examples in each route linked list have the same priority; and sending the message to be sent by adopting the target message processing example. The invention solves the technical problem that the actual state of the operation cannot be fed back due to the poor actual operation capability of the message processing example.
Description
Technical Field
The invention relates to the technical field of RCS communication, in particular to a data transmission method, a device thereof and electronic equipment.
Background
The downlink message issued by the message access module of the 5G message center from the MaaP platform is generally distributed to the instances in the message processing cluster in an equilibrium manner according to the hash method of the message ID or the called number content, and the actual operation capability of the message processing instances is possibly deteriorated due to different physical environments of actual operation or the burden of other software in the shared physical machine occupying physical resources. At this time, the message processing instance cannot feed back the actual operation state to the message access module, and the message access module cannot allocate the downlink message of the MaaP platform according to the actual load condition of the operation environment of the message processing instance.
In view of the above problems, no effective solution has been proposed at present.
Disclosure of Invention
The embodiment of the invention provides a data transmission method, a device thereof and electronic equipment, which at least solve the technical problem that the actual running state cannot be fed back due to the fact that the actual running capacity of a message processing example is poor.
According to an aspect of an embodiment of the present invention, there is provided a data transmission method including: acquiring a message to be sent; traversing the message processing examples in the plurality of route linked lists according to the priority order until the target message processing example is retrieved, wherein the priorities of the plurality of route linked lists are different, and the message processing examples in each route linked list have the same priority; and sending the message to be sent by adopting the target message processing example.
Optionally, before traversing the message processing instance between the plurality of route linked lists in the order of priority, the method further comprises: obtaining delay information of each message processing instance in the message processing instance set, wherein the delay information is based on the physical machine load state and the network transmission capacity of the current message processing instance; and determining the priority of each message processing instance according to the time delay information, and distributing each message processing instance to a plurality of route linked lists according to the priority of each message processing instance.
Optionally, determining the priority of each message processing instance according to the delay information includes: determining a delay index of each message processing instance in the message processing instance set according to the delay information, wherein the delay index is used for quantifying the degree of message forwarding delay; determining a value range to which the time delay index belongs; the priority level corresponding to the value range is determined, and the priority level corresponding to the value range is used as the priority of each message processing instance.
Optionally, determining the delay indicator of each message processing instance in the set of message processing instances according to the delay information includes: determining the time delay average value of all messages in unit time and a preset maximum allowable time delay value of each message processing example; and determining a time delay index according to the time delay average value and the maximum allowable time delay value.
Optionally, traversing the message processing instances in the plurality of route links in a priority order, including: traversing the route chain tables in turn according to the order of the chain table priority from high to low, and determining a target message processing instance in the target route chain table in a polling mode under the condition of determining the target route chain table in the route chain tables.
Optionally, the method further comprises: after selecting the target message processing instance in the target route linked list, the target message processing instance is moved to the end of the target route linked list.
Optionally, the method further comprises: determining the load state of a physical machine where a target message processing instance is located; and adjusting the priority corresponding to the target message processing instance according to the load state, and distributing the target message processing instance to the corresponding route linked list according to the adjusted priority.
Optionally, traversing the message processing instances in the plurality of route links in order of priority until the target message processing instance is retrieved, including: and when the number of times that the current route link list in the plurality of route link lists is searched is greater than a preset threshold value and the number of messages to be sent is a plurality of, distributing the plurality of messages to be sent to message processing examples in the route link list of the next priority of the priorities corresponding to the current route link list according to a preset proportion.
According to another aspect of the embodiment of the present invention, there is also provided a data transmission apparatus, including: the acquisition module is used for acquiring the message to be sent; the retrieval module is used for traversing the message processing examples among the plurality of route linked lists according to the priority order until the target message processing example is retrieved, wherein the priorities of the plurality of route linked lists are different, and the message processing examples in each route linked list have the same priority; and the sending module is used for sending the message to be sent by adopting the target message processing example.
According to another aspect of the embodiment of the present invention, there is also provided an electronic device, including: a processor; a memory for storing processor-executable instructions; wherein the processor is configured to execute instructions to implement a data transmission method as described above.
According to another aspect of the embodiments of the present invention, there is also provided a computer-readable storage medium, which when executed by a processor of an electronic device, enables the electronic device to perform a data transmission method as described above.
In the embodiment of the invention, the message to be sent is obtained, and the message processing examples among the plurality of route linked lists are traversed according to the priority order until the target message processing example is retrieved, wherein the priorities of the plurality of route linked lists are different, the message processing examples in each route linked list have the same priority, and then the target message processing example is adopted to send the message to be sent, so that the purpose of distributing the message according to the actual load condition of the operation environment of the message processing example can be achieved, the technical effect of determining the priority degree of the route selected to the message processing example according to the service processing state of the message processing example is achieved, and the technical problem that the actual state cannot be fed back due to the fact that the actual operation capacity of the message processing example is poor is solved.
Drawings
The accompanying drawings, which are included to provide a further understanding of the application and are incorporated in and constitute a part of this specification, illustrate embodiments of the application and together with the description serve to explain the application and do not constitute a limitation on the application. In the drawings:
Fig. 1 is a block diagram of a hardware structure of a computer terminal showing a data transmission method according to an exemplary embodiment;
FIG. 2 is a flow chart diagram illustrating a method of data transmission according to an exemplary embodiment;
FIG. 3 is a schematic diagram of a system networking according to embodiment 1 of the present invention;
FIG. 4 is a schematic diagram of a route link table according to embodiment 1 of the present invention;
FIG. 5 is a flow chart of a route search according to embodiment 1 of the present invention;
fig. 6 is a schematic diagram of a latency of A2P message passing according to embodiment 1 of the present invention;
FIG. 7 is a schematic diagram of an example migration from high priority to low priority according to embodiment 1 of the present invention;
FIG. 8 is a schematic diagram of an example migration from low priority to high priority according to embodiment 1 of the present invention;
Fig. 9 is a block diagram of an apparatus of another data transmission method according to embodiment 2 of the present invention;
Fig. 10 is a block diagram of an apparatus of a terminal according to an embodiment of the present invention.
Detailed Description
In order that those skilled in the art will better understand the present invention, a technical solution in the embodiments of the present invention will be clearly and completely described below with reference to the accompanying drawings in which it is apparent that the described embodiments are only some embodiments of the present invention, not all embodiments. All other embodiments, which can be made by those skilled in the art based on the embodiments of the present invention without making any inventive effort, shall fall within the scope of the present invention.
It should be noted that the terms "first," "second," and the like in the description and the claims of the present invention and the above figures are used for distinguishing between similar objects and not necessarily for describing a particular sequential or chronological order. It is to be understood that the data so used may be interchanged where appropriate such that the embodiments of the invention described herein may be implemented in sequences other than those illustrated or otherwise described herein. Furthermore, the terms "comprises," "comprising," and "having," and any variations thereof, are intended to cover a non-exclusive inclusion, such that a process, method, system, article, or apparatus that comprises a list of steps or elements is not necessarily limited to those steps or elements expressly listed but may include other steps or elements not expressly listed or inherent to such process, method, article, or apparatus.
Example 1
The data transmission method provided by the embodiment of the application can be executed in a mobile terminal, a computer terminal or similar computing devices. Fig. 1 shows a block diagram of a hardware structure of a computer terminal (or electronic device) for implementing a data transmission method. As shown in fig. 1, the computer terminal 10 (or electronic device 10) may include one or more processors 102 (shown as 102a, 102b, … …,102 n) which may include, but are not limited to, a microprocessor MCU, a programmable logic device FPGA, or the like, a memory 104 for storing data, and a transmission module 106 for communication functions. In addition, the method may further include: a display, an input/output interface (I/O interface), a Universal Serial Bus (USB) port (which may be included as one of the ports of the I/O interface), a network interface, a power supply, and/or a camera. It will be appreciated by those of ordinary skill in the art that the configuration shown in fig. 1 is merely illustrative and is not intended to limit the configuration of the electronic device described above. For example, the computer terminal 10 may also include more or fewer components than shown in FIG. 1, or have a different configuration than shown in FIG. 1.
It should be noted that the one or more processors 102 and/or other data processing circuits described above may be referred to generally herein as "data processing circuits. The data processing circuit may be embodied in whole or in part in software, hardware, firmware, or any other combination. Furthermore, the data processing circuitry may be a single stand-alone processing module, or incorporated, in whole or in part, into any of the other elements in the computer terminal 10 (or electronic device). As referred to in embodiments of the application, the data processing circuit acts as a processor control (e.g., selection of the path of the variable resistor termination connected to the interface).
The memory 104 may be used to store software programs and modules of application software, such as program instructions/data storage devices corresponding to the data transmission method in the embodiment of the present application, and the processor 102 executes the software programs and modules stored in the memory 104, thereby executing various functional applications and data processing, that is, implementing the data transmission method of the application program. Memory 104 may include high-speed random access memory, and may also include non-volatile memory, such as one or more magnetic storage devices, flash memory, or other non-volatile solid-state memory. In some examples, the memory 104 may further include memory located remotely from the processor 102, which may be connected to the computer terminal 10 via a network. Examples of such networks include, but are not limited to, the internet, intranets, local area networks, mobile communication networks, and combinations thereof.
The transmission module 106 is used to receive or transmit data via a network. The specific examples of the network described above may include a wireless network provided by a communication provider of the computer terminal 10. In one example, the transmission device 106 includes a network adapter (Network Interface Controller, NIC) that can connect to other network devices through a base station to communicate with the internet. In one example, the transmission device 106 may be a Radio Frequency (RF) module for communicating with the internet wirelessly.
The display may be, for example, a touch screen type Liquid Crystal Display (LCD) that may enable a user to interact with a user interface of the computer terminal 10 (or electronic device).
It should be noted here that, in some alternative embodiments, the computer device (or the electronic device) shown in fig. 1 described above may include hardware elements (including circuits), software elements (including computer code stored on a computer readable medium), or a combination of both hardware elements and software elements. It should be noted that fig. 1 is only one example of a specific example, and is intended to illustrate the types of components that may be present in the computer device (or electronic device) described above.
In the above-mentioned operating environment, the present application provides a data transmission method as shown in fig. 2. It should be noted that the steps illustrated in the flowcharts of the figures may be performed in a computer system such as a set of computer executable instructions, and that although a logical order is illustrated in the flowcharts, in some cases the steps illustrated or described may be performed in an order other than that illustrated herein.
Fig. 2 is a flowchart of a data transmission method according to an embodiment of the present application, as shown in fig. 2, the method includes the steps of:
Step S202, obtaining a message to be sent;
Step S204, traversing the message processing examples among the plurality of route linked lists according to the priority order until the target message processing example is retrieved, wherein the priorities of the plurality of route linked lists are different, and the message processing examples in each route linked list have the same priority;
Step S206, the message to be sent is sent by adopting the target message processing example.
By adopting the method of the embodiment, the purpose of distributing the message according to the actual load condition of the operation environment of the message processing instance can be achieved, so that the technical effect that the priority degree of the route selected to the message processing instance can be determined according to the service processing state of the message processing instance is achieved, and the technical problem that the actual state cannot be fed back due to the fact that the actual operation capability of the message processing instance is poor is solved.
And, a plurality of message processing examples on the same priority routing chain table can be distributed with the message in an even way, and message processing examples with different priorities can be distributed with the message in proportion.
The message processing instance described above may be an instance in which a message processing module of a 5GMC (5G message center) is running. The message processing module is a core processing module in the 5GMC platform and is used for completing the functions of message storage and forwarding, message retransmission, message withdrawal, message domain selection, message scheduling and cross-domain routing.
Specifically, when the message access module interacts with the message processing module, each message processing module instance feeds back to the message access module that the current message transmission delay average reference value represents the physical machine load state and the network transmission capacity of the current message processing node, the message access module calculates the message transmission delay degree of the message processing instance, searches the route priority according to the message transmission delay degree, and obtains a route linked list according to the route priority; and the message processing instance nodes with low message forwarding delay degree are placed in the routing chain table with high priority, and the message processing instance nodes with high message forwarding delay degree are placed in the routing chain table with low priority.
In step S202 of the data transmission method, a message to be transmitted is acquired. For example, as shown in fig. 3, the A2P message issued by the MaaP platform is distributed to the instances of the multiple message processing modules through message access, and the message processing instances select the terminal access instance registered by the destination mobile phone terminal. The A2P message is to go through a message processing instance, a network between message processing and terminal access, a terminal access instance, a network between terminal access and mobile phone terminal, and then to the mobile phone terminal.
In step S204 of the data transmission method, a plurality of route links may be traversed sequentially according to the order of the priority of the links from high to low, and in the case of determining a target route link in the plurality of route links, a polling manner is adopted in the target route link to determine a target message processing instance.
When the message access module distributes MaaP A2P messages sent by the platform, the route linked lists traversed according to the order of the priority from high to low are selected in a polling mode by a plurality of examples in the linked list with the same priority until a message processing example is obtained, and the A2P messages are sent.
Specifically, as shown in fig. 4, the data storage structure in which the routing chain table is configured in the message access module stores the routing priority relationship of the message processing instance. There are multiple route linked lists, each representing a route priority, with instance nodes of the same priority placed on the same linked list. When selecting a route, the route linked list with high priority is arranged in the previous instance in the priority search linked list, if the route instance linked list with high priority does not search the node, the next instance linked list with low priority is skipped until the search is completed.
In the searching flow chart shown in fig. 5, the left flow chart firstly selects the route linked list according to the principle of priority from high to low, and the selected route linked list carries out the process shown in the right flow chart to further search for example nodes.
In order to ensure that the route linked list with low priority can be searched by a small probability designated proportion, when a message route is searched, after the number of times that a certain priority route linked list is searched exceeds a designated configuration number, a search counter of the route linked list is cleared, and the route of the message is searched from the linked list with the next low priority. If the last route link list is searched, there is no link list with the next lower priority, and the message route is re-searched from the highest priority route link list.
In a possible implementation manner, the data transmission method of this embodiment further includes: after selecting the target message processing instance in the target route linked list, the target message processing instance is moved to the end of the target route linked list. If a certain example node is searched on the example linked list with the selected priority, the node is transferred to the end of the linked list with the same priority, and load sharing is realized.
In one possible implementation, before traversing the message processing instance between the plurality of route linked lists in the order of priority, the method of this embodiment further includes: obtaining delay information of each message processing instance in the message processing instance set, wherein the delay information is based on the physical machine load state and the network transmission capacity of the current message processing instance; and determining the priority of each message processing instance according to the time delay information, and distributing each message processing instance to a plurality of route linked lists according to the priority of each message processing instance. The network transfer capability may include a transmission speed and a transmission quality.
Illustratively, as shown in FIG. 6, the time delay between the time elapsed during the instance forwarding of the message and the time elapsed for the message to be sent to the receipt of the message is used to evaluate.
Wherein, define:
message transfer delay: tdt=a (tdi1+tdi2) +b TDr
TDi1: representing the time consumed for forwarding an A2P message within an instance: the time difference between the point in time the message processing instance receives the A2P message and the time the message was sent to the network.
TDi2: representing the time spent forwarding the A2P response piece message within the instance: the time difference between the point in time the message processing instance receives the A2P response piece message and the time the response piece was sent to the network.
TDr: indicating the time required to receive the receipt after the message was sent: the message processing instance receives the receipt time difference of the A2P unicast message after sending the A2P unicast message.
Coefficient a: the weight calculation ratio of TDi is shown in the range of 0.00-1.00.
Coefficient B: the weight calculation ratio of TDr is shown in the range of 0.00-1.00.
In one possible embodiment, determining the priority of each message processing instance based on the latency information includes: determining a delay index of each message processing instance in the message processing instance set according to the delay information, wherein the delay index is used for quantifying the degree of message forwarding delay; determining a value range to which the time delay index belongs; the priority level corresponding to the value range is determined, and the priority level corresponding to the value range is used as the priority of each message processing instance.
In the above embodiment, determining the delay indicator of each message processing instance in the set of message processing instances according to the delay information may include: determining the time delay average value of all messages in unit time and a preset maximum allowable time delay value of each message processing example; and determining a time delay index according to the time delay average value and the maximum allowable time delay value.
Illustratively, determining the message forwarding delay degree of the message processing instance includes: the message processing instance calculates the TDt value for each A2P and first receipt procedure, calculates the TDt average AvgTDt for all messages in a unit time period, and then informs the message access of AvgTDt value. If the message access configures the possible maximum range MaxTDt of the TDt, the calculated delay percentage (AvgTDt/MaxTDt) is 100, which is the message forwarding delay degree of the message processing example, the minimum value is 1, and the maximum value is 100.
Then dividing equal segments in numbers of 1-100 according to the number of route priority configuration, searching the corresponding position of the digital segment where the message forwarding delay degree value falls, and obtaining the corresponding route priority, wherein the lower the number is, the higher the priority is. For example, 2 route priority levels, the digital segments from level 1 to level 2 are divided according to 1-50, 51-100, if the calculated message forwarding delay degree value is 20, the corresponding priority level is 1, and if the calculated message forwarding delay degree value is 70, the corresponding priority level is 2.
In a possible implementation manner, the data transmission method of this embodiment further includes: determining the load state of a physical machine where a target message processing instance is located; and adjusting the priority corresponding to the target message processing instance according to the load state, and distributing the target message processing instance to the corresponding route linked list according to the adjusted priority.
Illustratively, the corresponding route link list is found according to the route priority calculated by the message processing instance, if the route link list already contains the message processing instance, no transition processing is needed, and if the route link list does not contain the message processing instance, the node of the message processing instance is moved from the old link list to the new route link list.
From the high priority list, a low priority list is embedded, and as shown in fig. 7, 2 priority route lists are configured. Assume that the message forwarding delay level of the current message processing example 2 is 46, which is placed on the chain table 1. The message access module receives the A2P message from the MaaP platform, the routing priority searches the instance node in the chain table 1, the chain table 1 comprises the node of the message processing instance 2, and the traffic of the A2P is distributed to the message processing instance 2. When the physical device of the example 2 runs other software and is burdened, the message forwarding capability of the physical device is weakened, the physical device feeds back AvgTDt to the message access module, the message forwarding delay degree is calculated to be 56, and the priority range of the linked list 2 corresponds to the message forwarding delay degree, then the node of the example 2 is moved to the back of the linked list 2, and a small amount of downlink messages are distributed to the example 2.
The migration from the low priority list to the high priority list, as shown in fig. 8, configures a2 priority route list. Assume that the message forwarding delay level for the current message processing instance 2 is 52, placed on linked list 2. The message access module receives the A2P message from MaaP platform, the message route flow is distributed to the nodes of other message processing examples corresponding to the linked list 1 preferentially, and a small amount of flow is distributed to the message processing example 2 of the linked list 2. When the physical device of the message processing example 2 runs with reduced load, the physical device feeds back AvgTDt to the message access module, the message forwarding delay degree is calculated to be 47, and the priority range of the linked list 1 corresponds to the calculated message forwarding delay degree, and then the node of the example 2 is moved to the back of the linked list 1. Example 2 can be enabled to obtain more downstream message traffic.
In step S204 of the data transmission method, when the number of times that the current route link table of the plurality of route link tables is retrieved is greater than a preset threshold and the number of messages to be sent is a plurality of, the plurality of messages to be sent may be allocated to the message processing instance in the route link table of the next priority level of the priorities corresponding to the current route link table according to a preset proportion. In order to ensure that a message processing instance on a low-priority route linked list can acquire a small amount of message traffic, searching on a high-priority route linked list for designated times, and then searching on the low-priority route linked list according to an allocated proportion.
Example 2
According to an embodiment of the present application, there is further provided an apparatus for implementing the above data transmission method, and fig. 9 is a block diagram of a data transmission apparatus according to an embodiment of the present application, as shown in fig. 9, where the data transmission apparatus includes: the acquisition module 32, the retrieval module 34 and the transmission module 36 are described below.
An acquisition module 32, configured to acquire a message to be sent;
A retrieving module 34, configured to traverse message processing instances among the plurality of route linked lists according to a priority order until the target message processing instance is retrieved, where the priorities of the plurality of route linked lists are different, and the message processing instances in each route linked list have the same priority;
A sending module 36, configured to send a message to be sent using the target message processing instance.
Here, the above-mentioned obtaining module 32, retrieving module 34 and transmitting module 36 correspond to steps S202 to S206 in embodiment 1, and the three modules are the same as the examples and application scenarios implemented by the corresponding steps, but are not limited to those disclosed in embodiment 1.
Example 3
The embodiment of the application can provide the electronic equipment, and the electronic equipment can be any one computer terminal equipment in a computer terminal group.
Alternatively, in this embodiment, the electronic device may be located in at least one network device of a plurality of network devices of the computer network.
Alternatively, fig. 10 is a block diagram of an electronic device, according to an example embodiment. As shown in fig. 10, the electronic device may include: one or more (only one is shown) processors 41, a memory 42 for storing processor-executable instructions; wherein the processor is configured to execute instructions to implement the data transmission method of any of the above.
The memory may be used to store software programs and modules, such as program instructions/modules corresponding to the data transmission method and apparatus in the embodiments of the present application, and the processor executes the software programs and modules stored in the memory, thereby executing various functional applications and data processing, that is, implementing the data transmission method described above. The memory may include high-speed random access memory, and may also include non-volatile memory, such as one or more magnetic storage devices, flash memory, or other non-volatile solid-state memory. In some examples, the memory may further include memory remotely located relative to the processor, which may be connected to the computer terminal via a network. Examples of such networks include, but are not limited to, the internet, intranets, local area networks, mobile communication networks, and combinations thereof.
The processor may call the information and the application program stored in the memory through the transmission device to perform the following steps: acquiring a message to be sent; traversing the message processing examples in the plurality of route linked lists according to the priority order until the target message processing example is retrieved, wherein the priorities of the plurality of route linked lists are different, and the message processing examples in each route linked list have the same priority; and sending the message to be sent by adopting the target message processing example.
Optionally, the above processor may further execute program code for: before traversing message processing examples among a plurality of route linked lists according to a priority order, obtaining delay information of each message processing example in a message processing example set, wherein the delay information is based on a physical machine load state and network transmission capacity of the current message processing; and determining the priority of each message processing instance according to the time delay information, and distributing each message processing instance to a plurality of route linked lists according to the priority of each message processing instance.
Optionally, the above processor may further execute program code for: determining the priority of each message processing instance according to the time delay information, including: determining a delay index of each message processing instance in the message processing instance set according to the delay information, wherein the delay index is used for quantifying the degree of message forwarding delay; determining a value range to which the time delay index belongs; the priority level corresponding to the value range is determined, and the priority level corresponding to the value range is used as the priority of each message processing instance.
Optionally, the above processor may further execute program code for: determining a delay indicator for each message processing instance in the set of message processing instances based on the delay information, comprising: determining the time delay average value of all messages in unit time and a preset maximum allowable time delay value of each message processing example; and determining a time delay index according to the time delay average value and the maximum allowable time delay value.
Optionally, the above processor may further execute program code for: traversing message processing instances in a plurality of route linked lists in a priority order, comprising: traversing the route chain tables in turn according to the order of the chain table priority from high to low, and determining a target message processing instance in the target route chain table in a polling mode under the condition of determining the target route chain table in the route chain tables.
Optionally, the above processor may further execute program code for: after selecting the target message processing instance in the target route linked list, the target message processing instance is moved to the end of the target route linked list.
Optionally, the above processor may further execute program code for: determining the load state of a physical machine where a target message processing instance is located; and adjusting the priority corresponding to the target message processing instance according to the load state, and distributing the target message processing instance to the corresponding route linked list according to the adjusted priority.
Optionally, the above processor may further execute program code for: traversing the message processing instances in the plurality of route linked lists in order of priority until the target message processing instance is retrieved, comprising: and when the number of times that the current route link list in the plurality of route link lists is searched is greater than a preset threshold value and the number of messages to be sent is a plurality of, distributing the plurality of messages to be sent to message processing examples in the route link list of the next priority of the priorities corresponding to the current route link list according to a preset proportion.
Those of ordinary skill in the art will appreciate that the configuration shown in fig. 10 is merely illustrative. Fig. 10 is not limited to the structure of the electronic device described above. For example, more or fewer components (e.g., network interfaces, display devices, etc.) than shown in FIG. 10 may also be included, or have a different configuration than shown in FIG. 10.
Those of ordinary skill in the art will appreciate that all or part of the steps in the various methods of the above embodiments may be implemented by a program for instructing a terminal device to execute in association with hardware, the program may be stored in a computer readable storage medium, and the storage medium may include: flash disk, read-Only Memory (ROM), random-access Memory (Random Access Memory, RAM), magnetic disk or optical disk, etc.
Example 4
In an exemplary embodiment, there is also provided a computer-readable storage medium including instructions that, when executed by a processor of a terminal, enable the terminal to perform the data transmission method of any one of the above. Alternatively, the computer readable storage medium may be a non-transitory computer readable storage medium, for example, a ROM, a Random Access Memory (RAM), a CD-ROM, a magnetic tape, a floppy disk, an optical data storage device, and the like.
Alternatively, in the present embodiment, the computer-readable storage medium described above may be used to store the program code executed by the data transmission method provided in the above embodiment 1.
Alternatively, in this embodiment, the above-mentioned computer-readable storage medium may be located in any one of the computer terminals in the computer terminal group in the computer network, or in any one of the mobile terminals in the mobile terminal group.
Optionally, in the present embodiment, the computer readable storage medium is configured to store program code for performing the steps of: acquiring a message to be sent; traversing the message processing examples in the plurality of route linked lists according to the priority order until the target message processing example is retrieved, wherein the priorities of the plurality of route linked lists are different, and the message processing examples in each route linked list have the same priority; and sending the message to be sent by adopting the target message processing example.
Optionally, in the present embodiment, the computer readable storage medium is configured to store program code for performing the steps of: before traversing message processing examples among a plurality of route linked lists according to a priority order, obtaining delay information of each message processing example in a message processing example set, wherein the delay information is based on a physical machine load state and network transmission capacity of the current message processing; and determining the priority of each message processing instance according to the time delay information, and distributing each message processing instance to a plurality of route linked lists according to the priority of each message processing instance.
Optionally, in the present embodiment, the computer readable storage medium is configured to store program code for performing the steps of: determining the priority of each message processing instance according to the time delay information, including: determining a delay index of each message processing instance in the message processing instance set according to the delay information, wherein the delay index is used for quantifying the degree of message forwarding delay; determining a value range to which the time delay index belongs; the priority level corresponding to the value range is determined, and the priority level corresponding to the value range is used as the priority of each message processing instance.
Optionally, in the present embodiment, the computer readable storage medium is configured to store program code for performing the steps of: determining a delay indicator for each message processing instance in the set of message processing instances based on the delay information, comprising: determining the time delay average value of all messages in unit time and a preset maximum allowable time delay value of each message processing example; and determining a time delay index according to the time delay average value and the maximum allowable time delay value.
Optionally, in the present embodiment, the computer readable storage medium is configured to store program code for performing the steps of: traversing message processing instances in a plurality of route linked lists in a priority order, comprising: traversing the route chain tables in turn according to the order of the chain table priority from high to low, and determining a target message processing instance in the target route chain table in a polling mode under the condition of determining the target route chain table in the route chain tables.
Optionally, in the present embodiment, the computer readable storage medium is configured to store program code for performing the steps of: after selecting the target message processing instance in the target route linked list, the target message processing instance is moved to the end of the target route linked list.
Optionally, in the present embodiment, the computer readable storage medium is configured to store program code for performing the steps of: determining the load state of a physical machine where a target message processing instance is located; and adjusting the priority corresponding to the target message processing instance according to the load state, and distributing the target message processing instance to the corresponding route linked list according to the adjusted priority.
Optionally, in the present embodiment, the computer readable storage medium is configured to store program code for performing the steps of: traversing the message processing instances in the plurality of route linked lists in order of priority until the target message processing instance is retrieved, comprising: and when the number of times that the current route link list in the plurality of route link lists is searched is greater than a preset threshold value and the number of messages to be sent is a plurality of, distributing the plurality of messages to be sent to message processing examples in the route link list of the next priority of the priorities corresponding to the current route link list according to a preset proportion.
The foregoing embodiment numbers of the present invention are merely for the purpose of description, and do not represent the advantages or disadvantages of the embodiments.
In the foregoing embodiments of the present invention, the descriptions of the embodiments are emphasized, and for a portion of this disclosure that is not described in detail in this embodiment, reference is made to the related descriptions of other embodiments.
In the several embodiments provided in the present application, it should be understood that the disclosed technology may be implemented in other manners. The above-described embodiments of the apparatus are merely exemplary, and the division of the units, for example, may be a logic function division, and may be implemented in another manner, for example, a plurality of units or components may be combined or may be integrated into another system, or some features may be omitted, or not performed. Alternatively, the coupling or direct coupling or communication connection shown or discussed with each other may be through some interfaces, units or modules, or may be in electrical or other forms.
The units described as separate parts may or may not be physically separate, and parts displayed as units may or may not be physical units, may be located in one place, or may be distributed on a plurality of units. Some or all of the units may be selected according to actual needs to achieve the purpose of the solution of this embodiment.
In addition, each functional unit in the embodiments of the present invention may be integrated in one processing unit, or each unit may exist alone physically, or two or more units may be integrated in one unit. The integrated units may be implemented in hardware or in software functional units.
The integrated units, if implemented in the form of software functional units and sold or used as stand-alone products, may be stored in a computer readable storage medium. Based on such understanding, the technical solution of the present invention may be embodied essentially or in part or all of the technical solution or in part in the form of a software product stored in a storage medium, including instructions for causing a computer device (which may be a personal computer, a server, or a network device, etc.) to perform all or part of the steps of the method according to the embodiments of the present invention. And the aforementioned storage medium includes: a usb disk, a Read-Only Memory (ROM), a random access Memory (RAM, random Access Memory), a removable hard disk, a magnetic disk, or an optical disk, or other various media capable of storing program codes.
The foregoing is merely a preferred embodiment of the present invention and it should be noted that modifications and adaptations to those skilled in the art may be made without departing from the principles of the present invention, which are intended to be comprehended within the scope of the present invention.
Claims (8)
1. A data transmission method, comprising:
acquiring a message to be sent;
Traversing the message processing examples in the plurality of route linked lists according to the priority order until the target message processing example is retrieved, wherein the priorities of the plurality of route linked lists are different, and the message processing examples in each route linked list have the same priority;
The message to be sent is sent by adopting the target message processing example,
Wherein a plurality of message processing instances on the routing chain table with the same priority can be used for distributing the message to be sent in an equalizing way, and the message processing instances with different priorities can be used for distributing the message to be sent in proportion;
Before traversing the message processing instances between the plurality of route linked lists in the order of priority, the method further comprises:
Obtaining delay information of each message processing instance in a message processing instance set, wherein the delay information is based on the physical machine load state and network transmission capacity of the current message processing;
Determining the priority of each message processing instance according to the time delay information, and distributing each message processing instance to the plurality of route linked lists according to the priority of each message processing instance;
determining the priority of each message processing instance according to the time delay information, including:
determining a time delay index of each message processing instance in the message processing instance set according to the time delay information, wherein the time delay index is used for quantifying the degree of message forwarding time delay;
Determining a value range to which the time delay index belongs;
Determining a priority level corresponding to the value range, and taking the priority level corresponding to the value range as the priority of each message processing instance;
determining a delay indicator for each message processing instance in the set of message processing instances according to the delay information, including:
Determining the time delay average value of all messages in unit time and a preset maximum allowable time delay value of each message processing example;
Determining the time delay index according to the time delay average value and the maximum allowable time delay value;
The message to be sent is A2P, and determining the message forwarding delay degree of the message processing example comprises the following steps: the message processing example calculates TDt of each A2P, the TDt adopts time elapsed in the process of forwarding the A2P by the message processing example and time delay of the A2P when the A2P sends out to the receipt of the A2P receipt are evaluated, and calculates TDt average AvgTDt of all messages in a unit time period, then informs AvgTDt value to message access, the message access configures a possible maximum range MaxTDt of the TDt, calculates time delay percentage (AvgTDt/MaxTDt) 100 as message forwarding time delay degree of the message processing example, the minimum value is 1, the maximum value is 100, fragments with equal quantity are divided in numbers of 1-100 according to the number of configuration of the routing priority, searches for corresponding positions of the digital fragments where the value of the message forwarding time delay degree falls, and obtains corresponding routing priority, and the priority is higher when the number is smaller.
2. The method of claim 1, wherein traversing message handling instances in a plurality of route links in a priority order comprises:
traversing the route link lists in turn according to the order of the priority of the link list from high to low, and determining the target message processing instance in the target route link list in a polling mode under the condition of determining the target route link list in the route link lists.
3. The method according to claim 2, wherein the method further comprises:
And after the target message processing instance is selected in the target route linked list, the target message processing instance is moved to the tail end of the target route linked list.
4. The method according to claim 1, wherein the method further comprises:
determining the load state of a physical machine where the target message processing instance is located; and adjusting the priority corresponding to the target message processing instance according to the load state, and distributing the target message processing instance to a corresponding route linked list according to the adjusted priority.
5. The method of claim 1, wherein traversing message processing instances in the plurality of route links in a priority order until a target message processing instance is retrieved comprises:
And distributing the plurality of messages to be sent to message processing examples in the route link list of the next priority of the priorities corresponding to the current route link list according to a preset proportion under the condition that the number of times of searching the current route link list in the plurality of route link lists is larger than a preset threshold and the number of the messages to be sent is a plurality of.
6. A data transmission apparatus, comprising:
The acquisition module is configured to acquire a message to be sent, and acquire delay information of each message processing instance in a set of message processing instances, where the delay information is based on a physical machine load state and network transfer capability where current message processing is located, determine a priority of each message processing instance according to the delay information, and allocate each message processing instance to a plurality of route linked lists according to the priority of each message processing instance, where determining the priority of each message processing instance according to the delay information includes: determining a time delay index of each message processing instance in the message processing instance set according to the time delay information, wherein the time delay index is used for quantifying the degree of message forwarding time delay, determining a value range to which the time delay index belongs, determining a priority level corresponding to the value range, taking the priority level corresponding to the value range as the priority of each message processing instance, and determining the time delay index of each message processing instance in the message processing instance set according to the time delay information, wherein the time delay index comprises the following steps: determining a delay average value of all messages in unit time of each message processing example and a preconfigured maximum allowable delay value, determining the delay index according to the delay average value and the maximum allowable delay value, wherein the message to be sent is A2P, and determining the message forwarding delay degree of the message processing example comprises the following steps: the message processing example calculates TDt of each A2P, the TDt adopts the time elapsed in the process of forwarding the A2P by the message processing example and the time delay between the time when the A2P sends out to the time when the A2P receipt is received to be evaluated, calculates TDt average AvgTDt of all messages in a unit time period, then informs AvgTDt value to message access, configures the maximum possible range MaxTDt of the TDt for the message access, calculates the time delay percentage (AvgTDt/MaxTDt) 100 as the message forwarding time delay degree of the message processing example, has the minimum value of 1 and the maximum value of 100, divides fragments with equal quantity in numbers of 1-100 according to the number of configuration of the routing priority, searches for the corresponding position of the digital fragment where the value of the time delay degree of the message forwarding falls, and obtains the corresponding routing priority, and the priority is higher when the number is smaller;
the retrieval module is used for traversing the message processing examples among the plurality of route linked lists according to the priority order until the target message processing example is retrieved, wherein the priorities of the plurality of route linked lists are different, and the message processing examples in each route linked list have the same priority;
And the sending module is used for sending the message to be sent by adopting the target message processing examples, wherein a plurality of message processing examples on the route linked list with the same priority can be used for distributing the message to be sent in an equalizing way, and the message processing examples with different priorities can be used for distributing the message to be sent in proportion.
7. An electronic device, comprising:
A processor;
A memory for storing the processor-executable instructions;
Wherein the processor is configured to execute the instructions to implement the data transmission method of any one of claims 1 to 5.
8. A computer readable storage medium, characterized in that instructions in the computer readable storage medium, when executed by a processor of an electronic device, enable the electronic device to perform the data transmission method of any one of claims 1 to 5.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111649753.1A CN114338499B (en) | 2021-12-29 | 2021-12-29 | Data transmission method, device and electronic equipment |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202111649753.1A CN114338499B (en) | 2021-12-29 | 2021-12-29 | Data transmission method, device and electronic equipment |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN114338499A CN114338499A (en) | 2022-04-12 |
| CN114338499B true CN114338499B (en) | 2024-05-14 |
Family
ID=81018258
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202111649753.1A Active CN114338499B (en) | 2021-12-29 | 2021-12-29 | Data transmission method, device and electronic equipment |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN114338499B (en) |
Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US5872769A (en) * | 1995-07-19 | 1999-02-16 | Fujitsu Network Communications, Inc. | Linked list structures for multiple levels of control in an ATM switch |
| EP3029898A2 (en) * | 2013-07-31 | 2016-06-08 | ZTE Corporation | Virtual output queue authorization management method and device, and computer storage medium |
| CN106776401A (en) * | 2016-11-23 | 2017-05-31 | 东软集团股份有限公司 | Method for message transmission and device |
| CN108989284A (en) * | 2018-06-07 | 2018-12-11 | 深圳震有科技股份有限公司 | A kind of service trigger method, storage medium and application server |
| CN110740162A (en) * | 2019-08-30 | 2020-01-31 | 上海连尚网络科技有限公司 | Communication link establishing method, device, electronic equipment and medium |
| CN111124355A (en) * | 2019-12-12 | 2020-05-08 | 东软集团股份有限公司 | Information processing method and device, readable storage medium and electronic equipment |
-
2021
- 2021-12-29 CN CN202111649753.1A patent/CN114338499B/en active Active
Patent Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US5872769A (en) * | 1995-07-19 | 1999-02-16 | Fujitsu Network Communications, Inc. | Linked list structures for multiple levels of control in an ATM switch |
| EP3029898A2 (en) * | 2013-07-31 | 2016-06-08 | ZTE Corporation | Virtual output queue authorization management method and device, and computer storage medium |
| CN106776401A (en) * | 2016-11-23 | 2017-05-31 | 东软集团股份有限公司 | Method for message transmission and device |
| CN108989284A (en) * | 2018-06-07 | 2018-12-11 | 深圳震有科技股份有限公司 | A kind of service trigger method, storage medium and application server |
| CN110740162A (en) * | 2019-08-30 | 2020-01-31 | 上海连尚网络科技有限公司 | Communication link establishing method, device, electronic equipment and medium |
| CN111124355A (en) * | 2019-12-12 | 2020-05-08 | 东软集团股份有限公司 | Information processing method and device, readable storage medium and electronic equipment |
Non-Patent Citations (1)
| Title |
|---|
| 一种基于优先级队列的集群动态反馈调度算法;柳少锋;董剑;吴智博;;智能计算机与应用(第04期);正文第2节 * |
Also Published As
| Publication number | Publication date |
|---|---|
| CN114338499A (en) | 2022-04-12 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN111342941B (en) | Configuration method and equipment of feedback control channel | |
| CN108306971B (en) | A method and system for sending an acquisition request of a data resource | |
| US20230318752A1 (en) | Transmission method, terminal and network device | |
| US20150222515A1 (en) | Management and orchestration server | |
| US20180198857A1 (en) | Connection control device, connection control system, and non-transitory computer readable medium | |
| CN109802997B (en) | Node equipment selection method and related equipment thereof | |
| CN109076357A (en) | Application method, relevant device and system are migrated in mobile limbic system | |
| CN101715228A (en) | Wireless communication system, management server, wireless terminal, and network selection method | |
| CN109286957B (en) | Switching method and device of return link, electronic equipment and storage medium | |
| CN111884875A (en) | Offline device determination method and device | |
| CN116800788A (en) | Energy storage system data transmission method and device, electronic equipment and storage medium | |
| US11734077B2 (en) | Evaluation device, evaluation method and evaluation program | |
| EP3015991B1 (en) | Push-type information transmission device, push-type information transmission method, and program | |
| CN105814850B (en) | Route method, node and the communication system of data packet | |
| CN114338499B (en) | Data transmission method, device and electronic equipment | |
| EP2689571B1 (en) | Replicating data | |
| CN120128525A (en) | Multi-transmission path cooperative control method, device, medium and equipment | |
| CN110401596B (en) | Message transmission method and device, electronic equipment and readable storage medium | |
| CN120075144A (en) | Data processing method and device, nonvolatile storage medium and electronic equipment | |
| EP3797538B1 (en) | Increasing number of connected user equipments on radio access network apparatus | |
| CN103914477B (en) | A kind of data processing method and device | |
| US11503506B2 (en) | Base station device, wireless communication control method, and recording medium having base station control program stored therein | |
| US8699347B2 (en) | Communication apparatus, communication system, communication method, and a computer-readable medium | |
| US11575601B2 (en) | Network device and packet processing method using same | |
| CN108737223B (en) | Health consultation method, device, platform and storage medium based on load balancing |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |