CN115733803A - Data current limiting method and device, electronic equipment and storage medium - Google Patents

Abstract

The application provides a data current limiting method, a data current limiting device, electronic equipment and a storage medium, and relates to the technical field of cloud computing, wherein the method comprises the following steps: responding to a multimedia communication related request aiming at a video and audio service platform, and acquiring type information and characteristic information of a request method in the multimedia communication related request; determining a first current limiting strategy corresponding to the multimedia communication related request according to the type information and the characteristic information; and correspondingly processing the multimedia communication related request according to the first current limiting strategy. In this embodiment, the current limiting policy is determined according to the type information and the characteristic information of the request method in the multimedia communication related request, and the multimedia communication related request is correspondingly processed through the current limiting policy, so as to ensure high availability, stability and security of the video and audio service platform. And according to the type information and the characteristic information of the request method, a fine-grained and differentiated current limiting strategy can be determined so as to guarantee the service quality of the video and audio service platform.

Description

Data current limiting method, device, electronic equipment and storage medium

technical field

The present application relates to the technical field of cloud computing, and in particular to a data current limiting method, device, electronic equipment and storage medium.

Background technique

At present, in security-related fields such as city brain, urban governance, and smart transportation, as the scale of connected video and audio collection equipment continues to expand, in order to facilitate unified management and scheduling of video and audio service platforms in a centralized manner, not only needs to be able to meet The stable access of a large number of video and audio acquisition devices under different delivery and deployment scenarios (public cloud and private cloud) must also be able to realize concurrent live broadcast, control, and device management of cameras on the video and audio service platform.

Based on the above background, major video security manufacturers and cloud vendors have launched a large number of video and audio service platforms for access control of video and audio acquisition equipment. However, the existing video and audio service platforms pay more attention to the integrity of video and audio protocol support , and the diversity of manufacturers' fragmented support, there is less consideration for the high availability, stability and security of the entire audio-visual service platform, and these factors will become more serious and prominent as the usage of the audio-visual service platform grows day by day . Therefore, a solution is needed to ensure the high availability, stability and security of the AV service platform.

Contents of the invention

Embodiments of the present application provide a data current limiting method, device, electronic equipment, and storage medium to ensure high availability, stability, and security of an audio-visual service platform.

In the first aspect, the embodiment of the present application provides a method for data current limiting, the method includes:

Responding to the multimedia communication-related request for the audio-visual service platform, obtaining the type information and characteristic information of the request method in the multimedia communication-related request;

According to the type information and the feature information, determine the first current limiting policy corresponding to the multimedia communication related request;

According to the first current limiting strategy, corresponding processing is performed on multimedia communication-related requests.

In the second aspect, the embodiment of the present application provides a data current limiting device, which includes:

An acquisition module, configured to acquire the type information and feature information of the request method in the multimedia communication related request in response to the multimedia communication related request for the video and audio service platform;

A determining module, configured to determine a first current limiting strategy corresponding to a multimedia communication-related request according to type information and feature information;

The current limiting module is configured to process corresponding requests related to multimedia communication according to the first current limiting policy.

In a third aspect, an embodiment of the present application provides an electronic device, including a memory, a processor, and a computer program stored on the memory, and the processor implements the method described in any one of the above when executing the computer program.

In a fourth aspect, an embodiment of the present application provides a computer-readable storage medium, where a computer program is stored in the computer-readable storage medium, and when the computer program is executed by a processor, the method described in any one of the foregoing is implemented.

Compared with the prior art, the present application has the following advantages:

The present application provides a data current limiting method, device, electronic equipment and storage medium, in response to a multimedia communication-related request for an audio-visual service platform, to obtain the type information and characteristic information of the request method in the multimedia communication-related request; according to the type Information and characteristic information, determine the first current limiting policy corresponding to the request related to multimedia communication; according to the first current limiting policy, perform corresponding processing on the request related to multimedia communication. In this embodiment, the current limiting strategy is determined according to the type information and characteristic information of the request method in the multimedia communication-related request, and the multimedia communication-related request is processed correspondingly through the current limiting strategy, so as to ensure the high availability of the video and audio service platform, Stability and security. Moreover, according to the type information and feature information of the request method, a fine-grained and differentiated traffic limiting strategy can be determined to ensure the service quality of the video and audio service platform.

The above description is only an overview of the technical solution of the present application. In order to understand the technical means of the present application more clearly, it can be implemented according to the contents of the description, and in order to make the above and other purposes, features and advantages of the present application more obvious and understandable, Specific embodiments of the present application are enumerated below.

Description of drawings

In the drawings, unless otherwise specified, the same reference numerals designate the same or similar parts or elements throughout the several drawings. The drawings are not necessarily drawn to scale. It should be understood that these drawings only depict some implementations according to the application, and should not be considered as limiting the scope of the application.

FIG. 1 is a schematic diagram of an application scenario of the data current limiting method provided by the present application;

FIG. 2 is a flowchart of a data current limiting method according to an embodiment of the present application;

Fig. 3 is a flowchart of analyzing SIP request and response messages according to an embodiment of the present application;

FIG. 4 is a flowchart of a data current limiting method according to an embodiment of the present application;

FIG. 5 is a structural block diagram of a data current limiting device according to an embodiment of the present application; and

FIG. 6 is a block diagram of an electronic device used to implement an embodiment of the present application.

Detailed ways

In the following, only some exemplary embodiments are briefly described. As those skilled in the art would realize, the described embodiments may be modified in various different ways, all without departing from the spirit or scope of the present application. Accordingly, the drawings and descriptions are to be regarded as illustrative in nature, and not restrictive.

In order to facilitate understanding of the technical solutions of the embodiments of the present application, the related technologies of the embodiments of the present application are described below. The following related technologies may be optionally combined with the technical solutions of the embodiments of the present application as optional solutions, and all of them belong to the protection scope of the embodiments of the present application.

The video service platform itself carries the service functions of structured data and unstructured data such as real-time live broadcast, video playback, video download, device registration, event subscription, and device control. Compared with general web servers, the stability and availability of services have higher requirements. However, the capacity of the entire platform and network is limited. It must not only meet the different service processing and transmission request traffic of a large number of connected devices, but also be able to resist malicious attack traffic that is likely to appear after being exposed to the public network. In view of this, the video service platform urgently needs a flow-limiting scheme that conforms to its communication protocol and service characteristics, and can take timely flow-limiting measures when the access request is about to cause or has already caused the entire video-audio service platform (network bandwidth) to approach the capacity threshold , so as to realize the protection of the video service platform and ensure the overall availability and service quality of the video service platform.

In the related technology, the server in the video and audio service platform carries a custom response header in the response header of the response message to indicate that the server is overloaded, and then the client sends the message through retransmission and timeout according to the explicit overload indication information. Wait and other means to reduce the client's request pressure on the video and audio service platform. However, this solution depends on the support of the client, and the client needs to be customized. Moreover, this solution relies on the server to return additional overload indication information. On the one hand, the protocol stack of the existing server needs to be changed; on the other hand, since the server needs to respond to each request, it can ensure that each client can Understand the load of the server. The server is likely to reply to each response message when it is already overloaded. This will further aggravate network congestion, consume network bandwidth, and further reduce the overall throughput of the video service platform. In addition, there are security and fairness problems in the practical application of this scheme, because the scheme relies on the active control of the client. For some clients that do not parse the response header, or the "malicious" attackers that can be ignored directly, the scheme cannot Limiting traffic will cause the "malicious" attacker's client to seize the server resources and network bandwidth that the "legitimate" client could have occupied.

In view of this, an embodiment of the present application provides a data current limiting method, and FIG. 1 is a schematic diagram of an application scenario of the data current limiting method provided in this application. As shown in FIG. 1 , the data current limiting method provided in this embodiment can be implemented in the form of a current limiting system. The current limiting system can be deployed in a server alone, or in the server of the video and audio service platform. In this embodiment, the video and audio service platform is the GB28181 platform, and the GB28181 platform refers to the access platform of the image acquisition equipment that supports the GB28181 standard. Standard, the main content includes the Session Initiation Protocol (Session Initiation Protocol, SIP) responsible for transmission control signaling and the Realtime Transport Protocol (RealtimeTransport Protocol, RTP)/Realtime Transport Control Protocol (Realtime Transport Control Protocol, RTCP) responsible for streaming media transmission . The GB28181 platform can include a server cluster composed of multiple SIP servers (it can also be a SIP server), and a streaming media server cluster (it can also be a streaming media server).

Wherein, the current limiting system includes: a SIP request analysis module, a data collection and analysis module, a SIP response analysis module and a current limiting decision module.

The SIP request parsing module is used to receive the SIP request sent by the client ("external SIP request" as shown in Figure 1), parse the SIP request, and obtain the client identification, type information and characteristics of the request method in the SIP request Messages, SIP transactions and SIP conversations. Wherein, the request method in the SIP request may include a session request and a non-session request. The type information of the session request may include: a session establishment request INVITE, used to establish an audio and video session connection; a session confirmation request ACK, used to confirm the INVITE request; a session end request BYE, used to disconnect the session connection established by the INVITE request; Playback control request INFO, used for playback control of historical video and audio. The type information of non-session requests can include: Subscription class request SUBSCRIBE, which is used to subscribe events to the event source and directory owner to subscribe to the directory; notification class request NOTIFY, which is used for the event source to notify the event observer of the event occurrence, and the directory owner Notify catalog recipients of catalog changes; message type request MESSAGE, used to realize front-end equipment control, alarm event notification and distribution, equipment information query, equipment status information submission, audio and video file retrieval; registration type request REGISTER, used for equipment registration and deregistration.

The SIP response analysis module is used to receive the SIP response message of the historical SIP request returned by the GB28181 platform, extract the status code, SIP transaction and SIP dialogue in the response message, and return the SIP response message to the client.

The data collection and analysis module is used to form a SIP request/response data collection closed loop according to the SIP request and the response message returned by the GB28181 platform, including: SIP transactions, SIP conversations, successful registration/semi-registration/deregistration client identification, multi-response association, etc. Raw data, as well as characteristic information such as bandwidth usage, instantaneous query rate per second (Queries-per-second, QPS), request/response delay, etc. obtained through analysis. These data are stored in the database and provided to the current limiting decision-making module.

The current-limiting decision-making module is used to comprehensively determine whether to take current-limiting measures for the current SIP request based on the SIP request information, the bandwidth resource usage extracted from the database, SIP transactions, SIP conversations, and various threshold information pre-configured by users, and what measures to take. A traffic-limiting strategy is used to deal with it accordingly, that is, to intercept SIP requests or release SIP requests to the SIP server. The streaming media server is used to send the video and audio data to the client according to the video and audio data acquisition request sent by the SIP server. Among them, a SIP transaction consists of a single SIP request and all response messages of this request, these response messages include 0 to N intermediate responses (for example, the status code is 1xx, etc.), and a final response (for example, the status code is 2xx , 3xx, 4xx, 5xx or 6xx, etc.). The value of the branch field in the Via header field in the request and response message headers of the same transaction is the same. A SIP conversation is related to a series of transactions between a SIP server and a client for establishing a session and terminating a session. For example, for a certain device, multiple request methods such as INVITE, ACK, and BYE are usually involved, but they all belong to one dialog. The same dialog can be uniquely identified by three values: the session identifier Call-ID value in the request and response headers, the tag value in the From header field, and the tag value in the To header field.

In this embodiment, the current limiting policy is determined according to the type information and feature information of the request method in the SIP request, and the SIP request is processed accordingly through the current limiting policy, so as to protect the GB28181 platform and avoid performance degradation and denial of service (Deny -Of-Service, DOS) risk, to ensure that the resources of the GB28181 platform are fully utilized. Moreover, according to the type information and feature information of the request method, a fine-grained and differentiated current limiting strategy can be determined, and the overload control of the SIP server can be realized in advance by intercepting the request.

Moreover, in this embodiment, by intercepting the request on the server side, there is no need for the client to adjust or customize to adapt to the custom header of the server. Since it is an independent current limiting system, the existing server does not need to be modified. By intercepting requests, the client implicitly perceives that the server is overloaded (for example, the client perceives a request timeout), rather than explicitly responding to each request, which will not increase network congestion and server resource consumption. For the access of clients of "malicious" attackers, the current limiting system can prevent a large number of attackers from registering because it can intercept and limit the SIP requests of unknown clients, thereby solving the problems of security and fairness.

An embodiment of the present application provides a method for limiting data traffic. The method in this embodiment can be applied to a computing device, and the computing device may include: a server and the like. As shown in Figure 2, it is a flowchart of a data current limiting method according to an embodiment of the present application. The method includes:

Step S201, in response to a multimedia communication-related request for an audio-visual service platform, acquire type information and feature information of a request method in a multimedia communication-related request.

Step S202, according to the type information and feature information, determine a first traffic limiting policy corresponding to a request related to multimedia communication.

Step S203, according to the first current limiting policy, corresponding processing is performed on the request related to the multimedia communication.

Wherein, the execution subject may be a server. The multimedia communication-related request indicates a communication-related request using a multimedia communication protocol, for example, a SIP request and the like.

After receiving the multimedia communication-related request, the server in the video-audio service platform parses the multimedia communication-related request to obtain the type information and feature information of the request method in the multimedia communication-related request. The format of multimedia communication-related requests includes request line, request header and request body. The server can get the type information of the request method by parsing the request line, and can get the characteristic information of the request method by parsing the request header and the request body. The characteristic information includes the value of the preset field in the request header and the request body, and the request header and the request body of different request methods The value of the preset field in may vary.

According to the type information and feature information of the request method, determine the first current limiting policy corresponding to the multimedia communication related request, the first current limiting policy may include intercepting the multimedia communication related request, or releasing the multimedia communication related request to the video and audio service platform. If it is released to the video and audio service platform, the server of the video and audio service platform returns a response message corresponding to the multimedia communication-related request to the client.

This application provides a data current limiting method, in response to a multimedia communication-related request for an audio-visual service platform, to obtain the type information and feature information of the request method in the multimedia communication-related request; according to the type information and feature information, determine the multimedia communication A first current limiting policy corresponding to the relevant request; according to the first current limiting policy, corresponding processing is performed on the multimedia communication related request. In this embodiment, the current limiting strategy is determined according to the type information and characteristic information of the request method in the multimedia communication-related request, and the multimedia communication-related request is processed correspondingly through the current limiting strategy, so as to ensure the high availability of the video and audio service platform, Stability and security. Moreover, according to the type information and feature information of the request method, a fine-grained and differentiated traffic limiting strategy can be determined to ensure the service quality of the video and audio service platform.

Wherein, the specific implementation of step S202 is shown in the following embodiments:

In an implementation manner, according to the type information and feature information, determining the first current limiting policy corresponding to the multimedia communication-related request includes: pre-obtaining the response message of the historical multimedia communication-related request; if according to the type information, feature information and response message , if it is determined that the multimedia communication-related request has an association relationship with the historical multimedia communication-related request, then the first current limiting policy is determined to allow the multimedia communication-related request.

In practical applications, pre-obtain the response messages of historical multimedia communication-related requests, establish a database, store status codes and header field data obtained by parsing the response messages of historical multimedia communication-related requests, and analyze multimedia communication-related requests , the type information and characteristic information of the request method that can be obtained according to the analysis result. Comparing the type information and feature information of the request method with the status code and header field data of the response message, it can be determined whether the current multimedia communication-related request is associated with the historical multimedia communication-related request, that is, whether it is an intermediate state request. For example, if the tag value of the TO field analyzed in the request header of the request method related to the current multimedia communication is the same as the tag value of the TO field in the header field data of the response message, the method is an intermediate request. If the request related to multimedia communication is an intermediate state request, release the request related to multimedia communication to the video and audio service platform.

For example, a SIP dialogue process (for example, from the beginning of viewing the live stream of the camera to the end of viewing) usually needs to involve multiple request/response transactions between the SIP client (for example, the camera) and the SIP server. Comparing the data in the database with the data parsed from the response message in the database, it is possible to identify and maintain the dialogues and transactions to which each SIP request belongs, avoiding interception of intermediate requests in SIP dialogues and transactions, resulting in partially successful requests eventually being all Ineffective, resulting in a waste of machine hardware resources and network resources.

In an implementation manner, the multimedia communication-related request includes a session request in the session initiation protocol SIP request, and according to the type information and feature information, determining the first flow-limiting policy corresponding to the multimedia communication-related request includes:

If the type information of the request method is a session confirmation request, determine the video encoding type according to the characteristic information, and the characteristic information includes the value of the preset field in the request header and the request body of the request method; if the type information of the request method is a session establishment request, then According to the type information, determine the video coding type; according to the video coding type, determine the allocated bandwidth of the session establishment request or the session confirmation request, if the allocated bandwidth exceeds the pre-configured bandwidth threshold, the first flow limiting strategy is determined as intercepting the session class request.

Wherein, the request method in the SIP request may include a session request and a non-session request. Session requests may include: session establishment request INVITE, session confirmation request ACK, session end request BYE and playback control request INFO. Non-session requests may include: subscription request SUBSCRIBE, notification request NOTIFY, message request MESSAGE and registration request REGISTER.

Pre-configure the total bandwidth of the video and audio service platform, the bandwidth threshold of the video and audio service platform, the query rate threshold per second corresponding to each type of non-session request, and the upper limit of the delay fluctuation of the request response according to the user's configuration instructions. wait. If the request method is determined as session confirmation request ACK according to the data parsed in the request line of the SIP request, and the video encoding type is determined according to the value of the preset field parsed from the request header and request body of the ACK request, and the video encoding type Determine the allocated bandwidth, if the allocated bandwidth exceeds the pre-configured bandwidth threshold, the SIP request will be intercepted. If it is an INVITE request, the video encoding type is determined according to the type information, and then the allocated bandwidth is determined. Wherein, the allocated bandwidth includes at least one of actual allocated bandwidth or pre-allocated bandwidth; the pre-configured bandwidth threshold includes at least one of pre-configured current limiting bandwidth threshold or pre-configured total bandwidth.

In an example, if it is an ACK request, the feature information is the payload type content of the a field. According to the payload type content, the actual transmitted video stream coding type can be determined, and the allocated bandwidth can be determined according to the video coding type. Change the pre-allocated bandwidth to the actual allocated bandwidth. For example, if the actual video encoding type is H265, then the pre-allocated bandwidth is reduced by 4 Mbps, and the actual allocated bandwidth is increased by 2 Mbps. If it is an INVITE request, the default subsequent video encoding type is H264, the resolution is 1080P, and the newly added system pre-allocated bandwidth is 4Mbps.

Optionally, if the actual allocated bandwidth of the session establishment request exceeds the pre-configured current limiting bandwidth threshold, the first current limiting policy is determined as intercepting the session establishment request.

Optionally, if the sum of the actual allocated bandwidth and the pre-allocated bandwidth of the session confirmation request exceeds the total amount of pre-configured bandwidth, the first traffic limiting policy is determined as intercepting the session confirmation request.

In an implementation manner, the method further includes:

If the allocated bandwidth does not exceed the pre-configured bandwidth threshold, and the average processing delay of the session establishment request or session confirmation request within the preset time period exceeds the preset time threshold, the first traffic limiting policy is determined to intercept the session request.

Wherein, the time threshold may be a preconfigured upper limit of delay fluctuation of request response. If the allocated bandwidth of the session establishment request or session confirmation request does not exceed the pre-configured bandwidth threshold, and the average processing delay of the session establishment request or session confirmation request within the preset time period does not exceed the upper limit of delay fluctuation, the first flow limit The policy is determined to allow the session request.

In an implementation manner, the multimedia communication-related request includes a non-session request in a SIP request, and the method further includes:

Non-session requests include multiple types of request methods. If it is determined according to the type information that the query rates per second corresponding to multiple types of request methods exceed the corresponding query rate threshold, the first flow limiting strategy is determined to intercept non-session requests. ask.

Among them, non-session requests include multiple types of request methods: subscription request SUBSCRIBE, notification request NOTIFY, message request MESSAGE and registration request REGISTER. Configure corresponding query rate thresholds for each type of request method in advance. If the query rate per second corresponding to a request method exceeds the corresponding query rate threshold, the first flow limiting strategy is determined to intercept the non-session request.

In an implementation manner, the method further includes:

If it is determined according to the type information that the query rates per second corresponding to the multiple types of request methods do not exceed the corresponding query rate threshold, and the average processing delay corresponding to the multiple types of request methods within the preset time period exceeds the preset time threshold, the first traffic limiting policy is determined as intercepting non-session requests.

Wherein, for any type of request method, if the query rate per second does not exceed the corresponding query rate threshold and the average processing delay within the preset time period exceeds the preconfigured upper limit of delay fluctuation, the request method is blocked.

Optionally, if it is determined according to the type information that the query rates per second corresponding to the multiple types of request methods do not exceed the corresponding query rate threshold, and the average processing time corresponding to the multiple types of request methods within the preset time period is If the delay does not exceed the preset time threshold, the first traffic limiting policy is determined to allow the non-session request.

In addition, the current overload information of the video and audio service platform can also be considered as a factor when determining the current limiting strategy, see the following embodiments for details:

In one implementation, according to the first current limiting strategy, corresponding processing is performed on multimedia communication-related requests, including: if the first current limiting strategy is to intercept multimedia communication-related requests, then determine the overload degree information; information and overload degree information to determine a second current limiting policy corresponding to the request related to multimedia communication; according to the second current limiting policy, corresponding processing is performed on the request related to multimedia communication.

In practical applications, if the first current limiting strategy is to intercept multimedia communication-related requests, then further determine the second current limiting strategy according to the type information of the request method and the overload degree information of the video and audio service platform, and finally determine the second current limiting strategy according to the second current limiting strategy. It is determined whether to intercept or release the request related to the multimedia communication. Wherein, different types of request methods may correspond to different second current limiting policies.

Wherein, the specific implementation manner of determining the overload degree information is shown in the following embodiments:

In an implementation manner, the multimedia communication-related request includes a session request in the SIP request, and determines the overload degree information, including:

If the allocated bandwidth requested by the session class exceeds the pre-configured bandwidth threshold, the overload degree information is determined as serious overload.

In practical applications, if the request is for a session and the actual allocated bandwidth exceeds the current-limiting bandwidth threshold, the overload degree information is determined as severe overload, otherwise the overload degree information is determined as general overload.

In one implementation, the method further includes:

If the type information is any one of session establishment request, session confirmation request and playback control request, and the overload degree information is severe overload, the second current limiting policy is determined as intercepting session type requests.

In one example, for a session request, if the overload level information is general overload, then the ACK request is determined to require current limiting; if the overload level information is severe overload, then the ACK request, INVITE request, and INFO request are all determined to require current limiting ; For BYE requests, the overload level information is general overload or severe overload, and there is no need for current limiting.

In an implementation manner, the multimedia communication-related request includes a non-session request in the SIP request, and determining the overload degree information includes:

If the query rate per second of non-session requests exceeds a corresponding query rate threshold, and the average processing delay of non-session requests exceeds a preset time threshold, the overload degree information is determined as severe overload.

In practical applications, for non-session requests, if the query rate per second exceeds the query rate threshold and the average processing delay exceeds the preconfigured upper limit of delay fluctuation, the overload level information is determined to be seriously overloaded; if the query rate per second exceeds the query rate threshold, but the average processing delay does not exceed the preconfigured upper limit of delay fluctuation, and the overload degree information is determined as general overload; if the query rate per second does not exceed the query rate threshold, but the average processing delay exceeds the preconfigured upper limit of delay fluctuation, The overload degree information is determined as a general overload.

In one implementation, the method further includes:

If the type information is any one of a subscription request, a notification request, and a message request, and the overload degree information is severe overload, the second current limiting strategy is determined as intercepting non-session requests.

In one implementation, the multimedia communication-related request includes a non-session request in the Session Initiation Protocol SIP request, and according to the type information, feature information, and overload degree information, determine the second current limiting policy corresponding to the multimedia communication-related request, including:

If the type information is a registration request or a message request, then according to the characteristic information and overload degree information respectively corresponding to the registration request or the message request, determine the second current limiting strategy as intercepting or releasing non-session requests.

In one example, for a non-session request, if it is a REGISTER request, if the overload level information is general overload, it is determined according to the characteristic information that the request is in the initial registration stage, and it is determined that current limiting is required; if the overload level information is severe overload, then According to the characteristic information (the value of the Expires header, greater than 0 indicates the request of the registration process, and equal to 0 indicates the request of the cancellation process. Extract the Authorization header, if it exists, it indicates the initial stage of registration, otherwise it is the final stage) to determine that the request is in the final registration stage, It is determined that current limiting is required; in general overload or severe overload, logout requests do not need current limiting. If it is a SUBSCRIBE request, current limiting is required for general overload or severe overload. If it is a NOTIFY request, severe overload requires current limiting. If it is a MESSAGE request, when it is generally overloaded, the characteristic information is obtained by parsing the request body, that is, the command type is Control and Query, and the current limit is required; in severe overload, all requests of the command type (Control, Query, Notify, and Response) need Limiting. Among them, the need to limit the flow refers to intercepting the request; otherwise, the request is released.

In a specific embodiment, the multimedia communication-related request and response messages are analyzed to obtain the type information and feature information of the request method. Specifically, the request related to multimedia communication can be a SIP request, and parsing the SIP request includes: parsing the request line of the SIP request, extracting the request method of the SIP request, thereby obtaining the type information of the request method; parsing the SIP request header, and extracting the public SIP Header field data: extract the client identification information from the From header field; extract the session identifier Call ID header, extract the tag value in the From header field and the tag value in the To header field. For some request methods, extract specific SIP header field data: For REGISTER requests, determine the REGISTER type, specifically, extract the value of the Expires header of the registration validity period, greater than 0 means registration, and equal to 0 means logout. Determine the stage of the registration process: extract the Authorization header, if it exists, it indicates the initial stage of the registration process, otherwise it is the final stage. For the SUBSCRIBE request, determine the subscription operation type, specifically, extract the value of the Expires header, if it is greater than 0, it means to establish a subscription, and if it is equal to 0, it means to cancel the subscription. For the extracted request methods, some request methods need to parse the SIP request body and extract specific fields from it. For example, for the ACK method, parse the payload type content of the a field in the SDP request to determine the video stream encoding actually transmitted Type; for the MESSAGE request, analyze the monitoring and alarming network system control description protocol (Monitoring and Alarming Network System Control Description Protocol, MANSCDP) combined with the request body in the Extensible Markup Language (XML) format, and extract the root element name and command type CmdType Element value, thereby determining the MESSAGE command type and subtype. Parsing the response message of the historical SIP request includes: parsing the status line of the response message, extracting the status code of the response message; parsing the response message header, extracting the public header field data; extracting the Call ID header, and extracting the tag value from the From header field and To header field to extract the tag value.

In a specific embodiment, a flow chart of analyzing SIP request and response messages is shown in FIG. 3 . The analysis process includes:

Step S301, judging whether the received request sent by the client is a SIP request, if yes, execute step S302; if not, then execute step S312 if it is a historical SIP response message.

Step S302, adding a client request record to the database.

Specifically, add a new request record in the database according to the client SIP ID and SIP conversation information (the value of the session identifier Call ID and the Tag value of the From header). The request record includes the type information of the request method of the SIP request, the request timestamp, and each The feature information of the request method, taking REGISTER as an example, includes registration or cancellation, initial stage registration or final stage registration.

Step S303, the database stores the feature information of the request method.

Step S304, judging whether the SIP request is a session request, if yes, execute step S305, otherwise execute step S311.

Step S305, judging whether the SIP request is an INVITE request in a session request, if yes, execute step S306, otherwise execute step S307.

Step S306, the default subsequent video encoding is H264, the resolution is 1080P, and the newly added video and audio service platform pre-allocates a bandwidth of 4 Mbps.

Step S307, judging whether the SIP request is an ACK request in the session request, if yes, execute step S308, otherwise execute step S309.

Step S308, if it is an ACK request in the session type request, convert the pre-allocated bandwidth to the actual allocated bandwidth according to the actual video stream encoding type obtained by parsing the SIP request, if the actual video stream encoding type is H265, then the pre-allocated bandwidth is reduced 4Mbps, the actual allocated bandwidth increases by xMbps.

Step S309, judging whether the SIP request is a BYE request in the session request, if yes, execute step S310, otherwise end.

In step S310, the actual allocated bandwidth is reduced by x Mbps, and the value of x depends on the encoding type of the video stream of the previously sent ACK request in the SIP session.

Step S311, if it is a non-session request, calculate the QPS corresponding to the non-session request.

Step S312, if the current processing is the response message of the SIP request, update the corresponding SIP request processing result (response status code) and SIP dialogue information (Tag value of To header field).

Step S313, calculating and storing the actual processing delay of the currently requested video and audio service platform.

Step S314, updating the statistical information of the processing delay of requests of the same type, including: the average number and the median of the delay.

In a specific embodiment, a flow chart of the method for data current limiting is shown in FIG. 4 . The method includes:

Step S401, judging whether the received multimedia communication-related request is an illegal request, and a non-registration request from an unknown SIP client or dialogue will be determined to be an illegal request. If it is an illegal request, execute step S406, otherwise execute step S402.

Step S402, if it is not an illegal request, determine the possibility of current limitation.

Step S403, judging whether current limiting may be required, if yes, execute step S404; otherwise, execute step S407.

Step S404, judging the degree of system overload. The overload level information includes severe overload or normal overload.

Step S405, judging whether the request needs current limiting under the current overload level, if yes, execute step S406, otherwise execute step S407.

Step S406, intercepting the request.

Step S407, release the request.

Corresponding to the application scenario and method of the method provided in the embodiment of the present application, the embodiment of the present application further provides a data rate limiting device. As shown in Figure 5, it is a structural block diagram of a data current limiting device according to an embodiment of the present application, and the device includes:

The obtaining module 501 is used to obtain the type information and feature information of the request method in the multimedia communication related request in response to the multimedia communication related request for the video and audio service platform;

A determination module 502, configured to determine a first current limiting policy corresponding to a multimedia communication-related request according to the type information and feature information;

The current limiting module 503 is configured to process corresponding requests related to multimedia communication according to the first current limiting policy.

The present application provides a data current limiting device, in response to a multimedia communication-related request for an audio-visual service platform, obtain the type information and characteristic information of the request method in the multimedia communication-related request; determine the multimedia communication according to the type information and characteristic information A first current limiting policy corresponding to the relevant request; according to the first current limiting policy, corresponding processing is performed on the multimedia communication related request. In this embodiment, the current limiting strategy is determined according to the type information and characteristic information of the request method in the multimedia communication-related request, and the multimedia communication-related request is processed correspondingly through the current limiting strategy, so as to ensure the high availability of the video and audio service platform, Stability and security. Moreover, according to the type information and feature information of the request method, a fine-grained and differentiated traffic limiting strategy can be determined to ensure the service quality of the video and audio service platform.

In one implementation, the determination module 502 is configured to:

Obtaining in advance a response message to a request related to historical multimedia communication;

If it is determined according to the type information, feature information, and response message that the multimedia communication-related request has an association relationship with the historical multimedia communication-related request, the first current limiting policy is determined to allow the multimedia communication-related request.

In one implementation, the multimedia communication-related request includes a session request in the session initiation protocol SIP request, and the determining module 502 is configured to:

If the type information of the request method is a session confirmation request, determine the video encoding type according to the characteristic information, and the characteristic information includes the value of the request header and the preset field in the request body of the request method;

If the type information of the request method is a session establishment request, then determine the video encoding type according to the type information;

According to the video coding type, determine the allocated bandwidth of the session establishment request or the session confirmation request, and if the allocated bandwidth exceeds the pre-configured bandwidth threshold, determine the first flow limiting policy as intercepting the session type request.

In one implementation, the device is also used to:

If it is determined according to the characteristic information that the allocated bandwidth of the session establishment request or session confirmation request does not exceed the preconfigured bandwidth threshold, and the average processing delay of the session establishment request or session confirmation request within the preset time period exceeds the preset time threshold, then the second A flow-limiting policy is determined to intercept session-type requests.

In an implementation manner, the multimedia communication-related request includes a non-session request in the SIP request, and the device is further used for:

Non-session requests include multiple types of request methods. If it is determined according to the type information that the query rates per second corresponding to multiple types of request methods exceed the corresponding query rate threshold, the first flow limiting strategy is determined to intercept non-session requests. ask.

In one implementation, the device is also used to:

If it is determined according to the type information that the query rates per second corresponding to the multiple types of request methods do not exceed the corresponding query rate threshold, and the average processing delay corresponding to the multiple types of request methods within the preset time period exceeds the preset time threshold, the first traffic limiting strategy is determined as intercepting non-session requests.

In an implementation manner, the current limiting module 503 is configured to:

If the first current limiting strategy is to intercept multimedia communication-related requests, then determine the overload degree information;

According to the type information, feature information and overload degree information, determine a second current limiting strategy corresponding to the request related to multimedia communication;

According to the second current limiting strategy, corresponding processing is performed on multimedia communication-related requests.

In an implementation manner, the multimedia communication-related request includes a session request in the SIP request, and when the device determines the overload degree information, it is used to:

If the allocated bandwidth requested by the session class exceeds the pre-configured bandwidth threshold, the overload degree information is determined as serious overload.

In one implementation, the device is also used to:

If the type information is any one of session establishment request, session confirmation request and playback control request, and the overload degree information is severe overload, the second current limiting policy is determined as intercepting session type requests.

In an implementation manner, the multimedia communication-related request includes a non-session request in the SIP request, and when the device determines the overload degree information, it is used to:

If the query rate per second of non-session requests exceeds a corresponding query rate threshold, and the average processing delay of non-session requests exceeds a preset time threshold, the overload degree information is determined as severe overload.

In one implementation, the device is also used to:

If the type information is any one of a subscription request, a notification request, and a message request, and the overload degree information is severe overload, the second current limiting strategy is determined as intercepting non-session requests.

In one implementation, the multimedia communication-related request includes a non-session request in the Session Initiation Protocol SIP request, and the device determines the second current limiting policy corresponding to the multimedia communication-related request according to the type information, characteristic information, and overload degree information , for:

If the type information is a registration request or a message request, then according to the characteristic information and overload degree information respectively corresponding to the registration request or the message request, determine the second current limiting strategy as intercepting or releasing non-session requests.

The functions of each module in each device in the embodiment of the present application can refer to the corresponding description in the above method, and have corresponding beneficial effects, and will not be repeated here.

FIG. 6 is a block diagram of an electronic device used to implement an embodiment of the present application. As shown in FIG. 6 , the electronic device includes: a memory 610 and a processor 620 , and the memory 610 stores computer programs that can run on the processor 620 . When the processor 620 executes the computer program, the methods in the foregoing embodiments are implemented. The number of memory 610 and processor 620 may be one or more.

This electronic device also includes:

The communication interface 630 is used for communicating with external devices for interactive data transmission.

If the memory 610, the processor 620, and the communication interface 630 are independently implemented, the memory 610, the processor 620, and the communication interface 630 may be connected to each other through a bus to complete mutual communication. The bus may be an Industry Standard Architecture (Industry Standard Architecture, ISA) bus, a Peripheral Component Interconnect (PCI) bus, or an Extended Industry Standard Architecture (Extended Industry Standard Architecture, EISA) bus, etc. The bus can be divided into address bus, data bus, control bus and so on. For ease of representation, only one thick line is used in FIG. 6 , but it does not mean that there is only one bus or one type of bus.

Optionally, in a specific implementation, if the memory 610, the processor 620, and the communication interface 630 are integrated on one chip, the memory 610, the processor 620, and the communication interface 630 may communicate with each other through an internal interface.

The embodiment of the present application provides a computer-readable storage medium, which stores a computer program, and implements the method provided in the embodiment of the present application when the program is executed by a processor.

The embodiment of the present application also provides a chip, the chip includes a processor, configured to call and execute instructions stored in the memory from the memory, so that the communication device installed with the chip executes the method provided in the embodiment of the present application.

The embodiment of the present application also provides a chip, including: an input interface, an output interface, a processor, and a memory, the input interface, the output interface, the processor, and the memory are connected through an internal connection path, and the processor is used to execute the code in the memory , when the code is executed, the processor is used to execute the method provided by the embodiment of the application.

It should be understood that the above-mentioned processor may be a central processing unit (Central Processing Unit, CPU), and may also be other general-purpose processors, a digital signal processor (Digital Signal Processor, DSP), an application specific integrated circuit (Application Specific Integrated Circuit, ASIC), Field Programmable Gate Array (Field Programmable Gate Array, FPGA) or other programmable logic devices, discrete gate or transistor logic devices, discrete hardware components, etc. A general purpose processor may be a microprocessor or any conventional processor or the like. It should be noted that the processor may be a processor supporting Advanced RISC Machines (ARM) architecture.

Further, optionally, the foregoing memory may include a read-only memory and a random access memory. The memory can be either volatile memory or nonvolatile memory, or can include both volatile and nonvolatile memory. Among them, the non-volatile memory can include read-only memory (Read-Only Memory, ROM), programmable read-only memory (Programmable ROM, PROM), erasable programmable read-only memory (Erasable PROM, EPROM), electrically programmable Erase Programmable Read-Only Memory (Electrically EPROM, EEPROM) or Flash. Volatile memory can include Random Access Memory (RAM), which acts as external cache memory. By way of illustration and not limitation, many forms of RAM are available. For example, static random access memory (Static RAM, SRAM), dynamic random access memory (Dynamic Random Access Memory, DRAM), synchronous dynamic random access memory (Synchronous DRAM, SDRAM), double data rate synchronous dynamic random access memory (Double Data RateSDRAM, DDR SDRAM), Enhanced Synchronous Dynamic Random Access Memory (Enhanced SDRAM, ESDRAM), Synchronous Link Dynamic Random Access Memory (Sync link DRAM, SLDRAM) and Direct Memory Bus Random Access Memory (DirectRambus RAM, DR RAM).

In the above embodiments, all or part of them may be implemented by software, hardware, firmware or any combination thereof. When implemented using software, it may be implemented in whole or in part in the form of a computer program product. A computer program product includes one or more computer instructions. When the computer program instructions are loaded and executed on the computer, the processes or functions according to the present application are produced in whole or in part. A computer can be a general purpose computer, special purpose computer, computer network, or other programmable device. Computer instructions may be stored in, or transmitted from, one computer-readable storage medium to another computer-readable storage medium.

In the description of this specification, descriptions referring to the terms "one embodiment", "some embodiments", "example", "specific examples", or "some examples" mean that specific features described in connection with the embodiment or example , structure, material or characteristic is included in at least one embodiment or example of the present application. Furthermore, the described specific features, structures, materials or characteristics may be combined in any suitable manner in any one or more embodiments or examples. In addition, those skilled in the art can combine and combine different embodiments or examples and features of different embodiments or examples described in this specification without conflicting with each other.

In addition, the terms "first" and "second" are used for descriptive purposes only, and cannot be interpreted as indicating or implying relative importance or implicitly specifying the quantity of indicated technical features. Thus, the features defined as "first" and "second" may explicitly or implicitly include at least one of these features. In the description of the present application, "plurality" means two or more, unless otherwise specifically defined.

Any process or method described in a flowchart or otherwise described herein may be understood as representing a module, segment, or code comprising one or more executable instructions for implementing a specific logical function or step of the process part. Also, the scope of preferred embodiments of the present application includes additional implementations in which functions may be performed out of the order shown or discussed, including substantially concurrently or in reverse order as the functions involved are involved.

The logic and/or steps described in the flowcharts or otherwise described herein, for example, can be considered as a sequenced listing of executable instructions for implementing logical functions, which can be embodied in any computer-readable medium , for use with an instruction execution system, apparatus, or device (such as a computer-based system, a system including a processor, or other system that can fetch instructions from an instruction execution system, apparatus, or device and execute instructions), or in conjunction with such an instruction execution system, device or equipment.

It should be understood that each part of the present application may be realized by hardware, software, firmware or a combination thereof. In the above described embodiments, various steps or methods may be implemented by software or firmware stored in memory and executed by a suitable instruction execution system. All or part of the steps of the method in the above embodiments can be completed by instructing related hardware through a program. The program can be stored in a computer-readable storage medium. When the program is executed, it includes one of the steps of the method embodiment or its combination.

In addition, each functional unit in each embodiment of the present application may be integrated into one processing module, each unit may exist separately physically, or two or more units may be integrated into one module. The above-mentioned integrated modules can be implemented in the form of hardware or in the form of software function modules. If the above-mentioned integrated modules are implemented in the form of software function modules and sold or used as independent products, they can also be stored in a computer-readable storage medium. The storage medium may be a read-only memory, a magnetic disk or an optical disk, and the like.

The above is only an exemplary embodiment of the application, but the scope of protection of the application is not limited thereto, and any skilled person familiar with the technical field can easily think of its various changes within the technical scope of the application Or replacement, all of these should be covered within the scope of protection of this application. Therefore, the protection scope of the present application should be based on the protection scope of the claims.

Claims (14)

1. A data current limiting method, characterized in that the method comprises: Responding to the multimedia communication-related request for the audio-visual service platform, acquiring type information and feature information of the request method in the multimedia communication-related request; determining a first current limiting policy corresponding to the multimedia communication-related request according to the type information and the feature information; According to the first current limiting strategy, corresponding processing is performed on the multimedia communication-related request. 2. The method according to claim 1, wherein said determining the first current limiting policy corresponding to the multimedia communication-related request according to the type information and the feature information comprises: Obtaining in advance a response message to a request related to historical multimedia communication; If it is determined according to the type information, the feature information, and the response message that the multimedia communication-related request has an association relationship with the historical multimedia communication-related request, determine the first current limiting policy as allowing the Multimedia communication related requests. 3. The method according to claim 1, wherein the multimedia communication-related request comprises a session class request in a Session Initiation Protocol (SIP) request, and the multimedia communication is determined according to the type information and the characteristic information. The first traffic-limiting policy corresponding to communication-related requests includes: If the type information of the request method is a session confirmation request, determine the video encoding type according to the feature information, and the feature information includes the value of the request header and the preset field in the request body of the request method; If the type information of the request method is a session establishment request, then determine the video encoding type according to the type information; According to the video encoding type, determine the allocated bandwidth of the session establishment request or the session confirmation request, and if the allocated bandwidth exceeds a pre-configured bandwidth threshold, determine the first current limiting policy as intercepting the session class request. 4. method according to claim 3, is characterized in that, described method also comprises: If the allocated bandwidth does not exceed the preconfigured bandwidth threshold, and the average processing delay of the session establishment request or the session confirmation request within the preset time period exceeds the preset time threshold, the first traffic limiting policy Determined to intercept the session class request. 5. The method according to claim 1, wherein the multimedia communication-related request comprises a non-session class request in a Session Initiation Protocol (SIP) request, and the method further comprises: The non-session request includes multiple types of request methods, and if it is determined according to the type information that the query rates per second corresponding to the multiple types of request methods exceed the corresponding query rate threshold, set the first limit to The flow policy is determined to intercept the non-session type request. 6. The method according to claim 5, further comprising: If it is determined according to the type information that the query rates per second corresponding to the multiple types of request methods do not exceed the corresponding query rate threshold, and the average processing time corresponding to the multiple types of request methods within the preset time period If the delay exceeds the preset time threshold, the first traffic limiting policy is determined to intercept the non-session request. 7. The method according to claim 1, wherein the corresponding processing of the multimedia communication-related request according to the first current limiting strategy comprises: If the first current limiting strategy is to intercept the multimedia communication related request, then determine the overload degree information; determining a second current limiting policy corresponding to the multimedia communication-related request according to the type information, the characteristic information, and the overload degree information; According to the second current limiting strategy, corresponding processing is performed on the multimedia communication-related request. 8. The method according to claim 7, wherein the multimedia communication-related request comprises a session class request in a Session Initiation Protocol (SIP) request, and the determination of the overload degree information comprises: If the allocated bandwidth requested by the session class exceeds a preconfigured bandwidth threshold, the overload degree information is determined as serious overload. 9. The method of claim 8, further comprising: If the type information is any one of the session establishment request, the session confirmation request, and the playback control request, and the overload degree information is severe overload, then determine the second current limiting policy as intercepting the session class request. 10. The method according to claim 7, wherein the multimedia communication-related request comprises a non-session request in a Session Initiation Protocol (SIP) request, and the determination of the overload degree information comprises: If the query rate per second of the non-session request exceeds a corresponding query rate threshold, and the average processing delay of the non-session request exceeds a preset time threshold, the overload degree information is determined as severe overload. 11. The method of claim 10, further comprising: If the type information is any one of subscription type request, notification type request and message type request, and the overload degree information is serious overload, then determine the second current limiting strategy as intercepting the non-conversation type ask. 12. The method according to claim 7, wherein the multimedia communication-related request comprises a non-session request in a Session Initiation Protocol (SIP) request, and according to the type information, the feature information and the overload Degree information, determining a second current limiting policy corresponding to the multimedia communication-related request, including: If the type information is a registration type request or a message type request, then according to the feature information and overload degree information corresponding to the registration type request or the message type request respectively, determine the second current limiting strategy as intercepting or releasing the non-session class request. 13. A data current limiting device, characterized in that the device comprises: An acquisition module, configured to acquire the type information and feature information of the request method in the multimedia communication-related request in response to the multimedia communication-related request for the audio-visual service platform; A determining module, configured to determine a first current limiting policy corresponding to the multimedia communication-related request according to the type information and the characteristic information; A current limiting module, configured to process the multimedia communication-related request according to the first current limiting strategy. 14. An electronic device, characterized in that it comprises a memory, a processor, and a computer program stored on the memory, and the processor implements the method according to any one of claims 1-12 when executing the computer program .

Images