WO2015007100A1

WO2015007100A1 - Method and system for controlling communication traffic

Info

Publication number: WO2015007100A1
Application number: PCT/CN2014/073341
Authority: WO
Inventors: 胡加明
Original assignee: 苏州阔地网络科技有限公司
Priority date: 2013-07-15
Filing date: 2014-03-13
Publication date: 2015-01-22
Also published as: CN103414648A; CN103414648B

Abstract

The present invention provides a method and a system for controlling communication traffic. The method comprises the following steps: a communication party performing data flow communication with communication peers by using a communication party management server and a communication peer management server, if the communication party detects that arrival traffic exceeds a preset threshold, the communication party separately performing statistics on data traffic from each communication peer, sorting the data traffic from each communication peer according to a sorting policy, and determining, according to a sorting result and a comparison policy, communication peers on which communication processing needs to be performed; the communication party sending information of the communication peers on which communication processing needs to be performed to the communication party management server, and the communication party management server allocating emergency service data flow communication of these communication peers to an emergency processing server; and if the communication party sends an emergency service data flow request to the communication peers again, the communication party management server allocating a communication task to the emergency processing server.

Description

Communication flow control method and system

The invention belongs to the field of flow control, and in particular relates to a communication flow control method and system.

With the popularity of the network, more and more applications on the network will seize bandwidth. When the user experiences the network using the client software, the user experience will be greatly reduced once the network speed is reduced and the traffic is suddenly increased. Current flow control techniques are primarily based on unilateral restrictions. However, the above practices have little constraint on the far-end transmission behavior and cannot effectively limit local arrival traffic. Summary of the invention

The invention provides a communication flow control method and system to solve the above problems.

The invention provides a communication flow control method. The method includes the following steps: the communication party communicates with the communication peer through the communication party management server and the communication peer management server, and if the communication party monitors that the arrival traffic exceeds a preset threshold threshold, the communication party separately receives i Data traffic of each communication peer, and sorting the data traffic from each communication peer according to the sorting strategy, and determining the communication peer that needs to perform communication processing according to the sorting result and the comparison policy, and the communication party triggers through the communication party management server The communication peer management server formulates and executes a data flow control policy to control the transmission of the communication peer data stream; the communication party sends the communication peer information that needs to perform communication processing to the communication party management server, and the communication party management server pairs the communication pairs The emergency service data stream communication of the terminal is allocated to the emergency processing server; if the communication direction transmits the emergency service data flow request again, the communication party management server allocates the communication task to the emergency processing server.

The invention also provides a communication flow control system, which comprises a communication party, a communication party management server, a communication peer end, a communication peer management server and an emergency processing server. The emergency processing server is connected to the communication party, the communication party management server, the communication peer end, and the communication peer management server, the communication party is connected to the communication party management server, the communication peer is connected to the communication peer management server, and the communication party management server is connected to the communication peer management server. . The communication party performs data stream communication with the communication peer end through the communication party management server and the communication peer management server. If the communication party monitors that the arrival station traffic exceeds a preset threshold threshold, the communication party separately collects data from each communication peer end. Traffic, and sorting the data traffic from each communication peer according to the sequence policy, and determining the communication peer that needs to perform communication processing according to the sorting result and the comparison policy, and simultaneously, the communication party triggers the communication peer management server through the communication party management server. Develop and implement a data flow control policy to control the transmission of the communication peer data stream. The communication party sends the communication peer information that needs to perform communication processing to the communication party management server, The correspondent management server distributes the emergency service data stream communication of the communication peers to the emergency processing server. If the communication direction communication end transmits the emergency service data flow request again, the communication party management server allocates the communication task to the emergency processing server.

Compared with the prior art, according to the communication flow control method and system provided by the present invention, if the communication party monitors that the arrival traffic exceeds a preset threshold threshold, the communication party sorts the data traffic from each communication peer according to the sorting policy. The communication peer that needs to perform communication processing is determined according to the sorting result and the comparison policy. At the same time, the communication party triggers the communication peer management server to formulate and execute the data flow control policy through the communication party management server, and controls the transmission of the communication peer data stream. The correspondent management server distributes the emergency service data stream communication of the communication peer that needs to perform communication processing to the emergency processing server. In this way, the communication of the communication traffic of the communication party is realized. At the same time, it realizes the constraint on the sending behavior of the communication peer, and effectively limits the local arrival traffic. DRAWINGS

The drawings are intended to provide a further understanding of the invention, and are intended to be a part of the invention, and the invention is not to be construed as limiting the invention. In the drawing:

1 is a flow chart showing a communication flow control method according to a preferred embodiment of the present invention;

2 is a schematic diagram of a communication flow control system provided in accordance with a preferred embodiment of the present invention. detailed description

The invention will be described in detail below with reference to the drawings in conjunction with the embodiments. It should be noted that the embodiments in the present application and the features in the embodiments may be combined with each other without conflict.

1 is a flow chart showing a communication flow control method according to a preferred embodiment of the present invention. As shown in FIG. 1, the communication flow control method provided by the preferred embodiment of the present invention includes steps 101-103.

In step 101, the communication party performs data stream communication with the communication peer through the communication party management server and the communication peer management server. If the communication party monitors that the abortion exceeds a preset threshold threshold, the communication party separately counts. Data traffic from each communication peer, and sorting data traffic from each communication peer according to a sorting policy, and determining a communication peer that needs to perform communication processing according to the sorting result and the comparison policy, and simultaneously, the communication party is managed by the communication party The server triggers the communication peer management server to formulate and execute a data flow control policy to control the transmission of the communication peer data stream.

In this embodiment, the sorting strategy is: arranging the data traffic in descending order; or arranging the corresponding data traffic according to the priority of the communication peer. However, the present invention is not limited thereto.

In this embodiment, the communication party A uses the communication party management server and the communication peer management server to perform data stream communication with the communication peer D, the communication peer terminal, the communication peer end: F, and the communication peer end G as an example. Where, the communication peer 0, E, F, G When the data stream is sent to the correspondent party A, each carries its own identification information, so that the communication party A can facilitate the traffic statistics. In addition, the data stream includes an emergency service data stream and a non-emergency service data stream. The emergency service data flow includes, for example, a data query request or response, a data update request or response, a data deletion request, or a corresponding; the non-emergency service data flow includes, for example, a link probe message. Here, the data stream sent by the communication peer D to the correspondent party A includes, for example, an emergency service data stream and a non-emergency service data stream; the data stream sent by the communication peer E to the correspondent party A includes, for example, an emergency service data stream and a non-emergency service. The data stream sent by the communication peer F to the correspondent party A includes, for example, an emergency service data stream and a non-emergency service data stream; and the data stream sent by the communication peer G to the correspondent party A includes, for example, a non-emergency service data stream.

Here, if at a certain moment, the communication party A monitors that the arrival traffic exceeds a preset threshold threshold (for example, M), the communication party A separately counts the data traffic from the communication peers D, E, F, and G, According to the sorting strategy, the data traffic of the communication peers D, E, F, G is sorted. The data traffic from the communication peer D is, for example, M1, the data traffic from the communication peer E is, for example, M2, the data traffic from the communication peer F is, for example, M3, and the data traffic from the communication peer G is, for example, M4. Here, the sorting strategy is as follows: Arrange according to the order of data traffic from large to small. Thus, the ranking result is, for example: M:1>M3>M2>M4.

At this time, the communication peer that needs to perform communication processing is determined according to the sorting result and the comparison policy. The comparison policy is: comparing the first flow value and the threshold threshold in the sorting result, if the first flow value is greater than or equal to the threshold threshold, the communication peer corresponding to all the flow values in the sorting result needs to perform communication processing. If the first traffic value is less than the threshold threshold, compare the sum of the first traffic value and the second traffic value with a threshold threshold. If the threshold is greater than or equal to the threshold, the second traffic value and the subsequent traffic value correspond to The communication peer is a communication peer that needs to perform communication processing. If it is less than the threshold threshold, compare the sum of the first flow value, the second flow value, and the third flow value with a threshold threshold, and repeat the above process until it is determined that communication is required. Processing the communication peer.

Specifically, referring to the sort result obtained in the above example (ie, M1>M3>M2>M4), first compare the first flow value (for example, M1) and the threshold threshold (for example, M) in the sort result, if >1, Then continue to compare the sum of the first flow value and the second flow value (for example, M1+M3) and the threshold threshold (Μ: λ if ^1> 1+ 3, then continue to compare the first flow value, the second flow value, and the The sum of the three flow values (for example, M l- ί- Μ3+Μ2) and the threshold threshold ( Μ ), if Μ < Μ 1 + Μ 3 + Μ 2, the communication peer that needs to perform communication processing according to the comparison strategy is: The opposite end and the communication end G. In addition, if Μ>Μ1-;-Μ3+Μ2, continue to compare the first flow value, the second flow value, the third flow value, and the fourth flow value (for example, 1÷M3 +M2+M4) and the threshold threshold M until the communication peer that needs to be processed is determined. In addition, if M1>M, the communication peer that needs to be processed is: communication peer 0, communication peer £, communication pair End?, communication peer 0.

In the meantime, in the embodiment, the communication party triggers the communication peer management server to formulate and execute the data flow control policy through the communication party management server, and controls the transmission of the communication peer data stream. The data flow control policy is: determining a corresponding transmission time interval according to the ratio of the vacant bandwidth of the communication peer and the bandwidth comparison table. Here, the bandwidth ^ comparison table As shown in Table 1. However, the present invention is not intended to be effective. In actual use, it can be set as needed.

Specifically, when the communication party monitors that the arrival traffic exceeds a preset threshold threshold, the communication party triggers the communication peer management server through the communication management server. At this time, the communication peer management server separately counts the current bandwidth usage and the total bandwidth of each communication peer, and obtains the proportion of the vacant bandwidth of each communication peer (the proportion of the vacant bandwidth (the total bandwidth of the single communication peer - the single communication pair) The current bandwidth usage of the end) / the total bandwidth of the single communication peer), and then determine the transmission time interval of each communication peer according to the ratio of the vacant bandwidth of each communication peer and the bandwidth comparison table. Herein, the information determined by the communication peer management server is as follows: The transmission interval of the communication peer D is data transmitted every 2 seconds, and the transmission interval of the communication peer E is sent every 2 seconds, the communication pair The transmission interval of the terminal F is once every i seconds, and the transmission interval of the communication peer G is once every 3 seconds. In this way, the communication peer management server controls the data stream transmission of the communication peer D, the communication peer terminal, the communication peer F, and the communication peer G according to the above determined information. In this way, the constraint on the sending behavior of the communication peer is realized, thereby effectively limiting the local arrival traffic.

In step 102, the communication party sends the communication peer information that needs to perform communication processing to the communication party management server, and the communication party management server distributes the emergency service data stream communication of the communication peers to the emergency processing server.

For example, if the communication peer that needs to perform communication processing is determined to be the communication peer E and the communication peer G according to the sorting result and the comparison policy, the correspondent party A will communicate with the peer E and the communication peer. The information of G is sent to the correspondent management server. Wherein, the data stream sent by the communication peer E to the correspondent party A includes, for example, an emergency service data stream and a non-emergency service data stream, and the data stream sent by the communication peer G to the correspondent party A includes, for example, a non-emergency service data stream. The communication peer E and the communication peer G can normally send the non-emergency service data stream to the correspondent party A. For the emergency service data flow sent by the communication peer E to the correspondent party A, the communication party management server receives the emergency data stream of the communication peer E, and replaces the emergency service data stream with the identifier and IP address of the emergency processing server. The identity and IP address of the communication party, and the processed emergency service data stream is sent to the emergency response server. In this way, emergency allocation of emergency traffic data flow communication tasks is achieved.

In step 03, if the communication direction communication peer sends the emergency service data flow request again, the communication party management server allocates the communication task to the emergency processing server.

Specifically, if the communication direction communication peer transmits the emergency service data flow request again, the process of the communication party management server assigning the communication task to the emergency processing server is; the communication party management server receives To After the emergency service data flow request sent by the communication party, the communication party identifier and the IP address carried in the emergency service data flow request are replaced with the emergency processing server identifier and the IP address, and the processed emergency service is processed. The data stream request is sent to the communication peer end by the communication peer management server; the communication peer end sends the emergency service data stream response through the communication peer management server and the communication party management server or directly through the communication peer management server To the emergency processing server.

In addition, in this embodiment, if the communication party monitors that the arrival traffic is lower than the threshold threshold and exceeds the preset time, the communication party notifies the emergency processing server or directly notifies the emergency through the communication management server. The processing server sends the received emergency service data stream to the correspondent party.

Specifically, if the communication party monitors that the arrival traffic is lower than the threshold threshold and exceeds the preset interval, the communication party notifies the communication management server, and the communication management server notifies the emergency processing server to send the received emergency service data flow to the communication. square. The message sent by the communication management server to the emergency processing server carries the identifier of the communication party and the IP address information, so that the emergency processing server can add the identifier of the communication party and the IP address information to the emergency service data stream. Alternatively, if the communication party monitors that the arrival traffic is below the threshold threshold Ji for more than the preset time, the communication party directly notifies the emergency processing server to send the received emergency service data stream to the communication party. The message sent by the communication direction emergency processing server carries the identifier of the communication party and the IP address information, so that the emergency processing server can add the identifier of the communication party and the 1EP address information to the emergency service data stream or the emergency processing server pre-stores the information. If the communication party IP address is used, the communication direction may not carry the IP address information in the message sent by the emergency response server.

2 is a schematic diagram of a communication flow control system provided in accordance with a preferred embodiment of the present invention. As shown in FIG. 2, the communication flow control system provided by the preferred embodiment of the present invention includes communication parties A to C, a communication party management server 10, communication peers D to G, a communication peer management server 12, and an emergency processing server 14. . The emergency processing server 14 is connected to the communication party A to C, the communication party management server 10, the communication peer 1>~0, and the communication peer management server 12. The communication party A~C is connected to the communication party management server 10, the communication peers D to G are connected to the communication peer management server 12, and the communication party management server 10 is connected to the communication peer management server: 2.

In this embodiment, the communicating party (for example, the communicating party A) performs data stream communication with the communication peer end (for example, the communication peer end through the communication partner management server 10 and the communication peer management server 12, if the communicating party A monitors When the station traffic exceeds the preset threshold threshold, the communication party A separately counts the data traffic from each communication peer IX, and sorts the data traffic from each communication peer D~G according to the sorting strategy, and according to the sorting result and comparison. The policy determines the communication peer that needs to perform communication processing, and the communication party A triggers the communication peer management server 12 to formulate and execute the data flow control policy through the communication partner management server 10, and controls the communication peer i>-.G data stream. The communication party A transmits the communication peer information that needs to perform communication processing to the communication party management server 10, and the communication party management server 10 distributes the emergency service data stream communication of the communication peers to the emergency processing server 14. If the communication party A Send emergency services to the communication peer again The data stream request, the communication party management server 10 assigns the communication task to the emergency processing server 14. The specific operation process of the above system is the same as that described above, and therefore will not be described again.

In summary, according to the communication flow control method and system provided by the preferred embodiment of the present invention, if the communication party monitors that the arrival traffic exceeds a preset threshold threshold, the communication party performs data traffic from each communication peer according to the sorting policy. Sorting, and determining a communication peer that needs to perform communication processing according to the sorting result and the comparison policy. At the same time, the communication party triggers the communication peer management server to formulate and execute the data flow control policy through the communication party management server, and controls the data flow of the communication peer end. send. The correspondent management server distributes the emergency service data stream communication of the communication peer that needs to perform communication processing to the emergency processing server. In this way, the communication of the communication traffic of the communication party is realized. At the same time, it realizes the constraint on the sending behavior of the communication peer, and effectively limits the local arrival traffic.

The above is only the preferred embodiment of the present invention, and is not intended to limit the present invention, and various modifications and changes can be made to the present invention. Any modifications, equivalent substitutions, improvements, etc., made within the spirit and scope of the present invention are intended to be included within the scope of the present invention.

Claims

WO 2015/007100 +π ii! ^ + , PCT/CN2014/073341 Claims

1. A communication flow control method, characterized in that it includes the following steps:

The communicating party conducts data stream communication with the communicating peer through the communicating party management server and the communicating peer management server. If the communicating party monitors that the arrival traffic exceeds a preset threshold, the communicating party will separately count the traffic from each communicating peer. The data traffic from each communication peer is sorted according to the sorting strategy, and the communication peer that needs to be communicated is determined according to the sorting result and the comparison strategy. At the same time, the communicating party triggers the communication peer through the communicating party management server. The end management server formulates and executes data flow control policies to control the sending of data flows to the communication peer;

The communicating party sends the communication counterpart information that requires communication processing to the communicating party management server, and the communicating party management server allocates the emergency service data flow communication of the communication peers to the emergency processing server;

If the communication direction sends an emergency service data flow request to the communication counterpart again, the communication party management server allocates the communication task to the emergency processing server.

2. The method according to claim 1, characterized in that the # ordering strategy is: arranging the data traffic in order from large to small; or, arranging the corresponding data traffic in order according to the priority of the communication counterpart.

3. The method according to claim 〗, characterized in that the comparison strategy is: comparing the first flow value in the sorting result with the threshold threshold, and if the first flow value is greater than or equal to the threshold threshold, the sorting result is The communication counterpart corresponding to all the traffic values in is the communication counterpart that needs to perform communication processing; if the first traffic value is less than the threshold, compare the sum of the first traffic value and the second traffic value with the threshold, if it is greater than or is equal to the threshold, then the communication counterpart corresponding to the second traffic value and subsequent traffic values is the communication counterpart that needs to perform communication processing. If it is less than the threshold, compare the sum of the first traffic value, the second traffic value and the third traffic value. and threshold, repeat the above process until the communication peer that needs to perform communication processing is determined.

4. The method according to claim 1, characterized in that the data flow control strategy is: determining the corresponding sending time interval according to the proportion of spare bandwidth of the communication peer and the bandwidth time comparison table.

5. The method of claim 1, wherein the data flow includes an emergency service data flow and a non-emergency service data flow.

6. The method according to claim 1, characterized in that, if the communicating party monitors that the arrival traffic is lower than a threshold and exceeds a preset time, the communicating party notifies the communicating party through the communicating party management server. The emergency processing server may directly notify the emergency processing server to send the received emergency service data flow to the communicating party.

7. The method according to claim 1, characterized in that, if the communication direction sends an emergency service data flow request to the communication counterpart again, the communication party management server allocates the communication task to the emergency processing server The process is:

After receiving the emergency service data flow request sent by the communicating party, the communicating party management server replaces the communicating party identifier and IP address carried in the emergency service data flow request with the emergency processing server identifier and IP address WO 2015/007100 _{+π ii} ! ^ +, PCT/CN2014/073341

Rights request and send the processed emergency service data flow request to the communication peer through the communication peer management server;

The communication counterpart sends the emergency service data flow response to the emergency processing server through the communication counterpart management server and the communicating party management server or directly through the communication counterpart management server.

8. A communication flow control system, characterized in that it includes a communicating party, a communicating party management server, a communicating peer, a communicating peer managing server and an emergency processing server, and the emergency processing server is connected to the communicating party, the communicating party The communication party management server, the communication counterpart and the communication counterpart management server, the communication party is connected to the communication party management server, the communication counterpart is connected to the communication counterpart management server, the communication party management server Connect to the communication peer management server,

Wherein, the communicating party performs data flow communication with the communicating counterpart through the communicating party management server and the communicating counterpart management server. If the communicating party monitors that the arrival traffic exceeds a preset threshold, then the communicating party The communicating party separately counts the data traffic from each communication peer, sorts the data traffic from each communication peer according to the sorting strategy, and determines the communication peer that needs to perform communication processing based on the sorting results and comparison strategy. At the same time, the communicating party The communication counterparty management server triggers the communication counterparty management server to formulate and execute a data flow control policy to control the transmission of the communication counterparty data flow. The communicating party sends the communication counterparty information that needs to be communicated to the communication counterparty management server, so The communication party management server allocates the emergency service data flow communications of the communication peers to the emergency processing server,

9. The system according to claim 7, wherein the sorting strategy is: arranging the data traffic in order from large to small; or, arranging the corresponding data traffic in order according to the priority of the communication counterpart.

10. The system according to claim 7, wherein the comparison strategy is: comparing the first traffic value in the sorting result with a threshold, and if the first traffic value is greater than or equal to the threshold, the sorting result is The communication counterpart corresponding to all the traffic values in is the communication counterpart that needs to perform communication processing: If the first traffic value is less than the threshold threshold, compare the sum of the first traffic value and the second traffic value with the threshold gate. If it is greater than or equal to the threshold gate, then the communication peer corresponding to the second traffic value and the subsequent traffic value is the communication peer that needs to perform communication processing. If it is less than the threshold threshold, compare the first traffic value, the second traffic value and the third traffic value. The sum of the values and the threshold value are used to repeat the above process until the communication peer that needs to perform communication processing is determined.