TWI671708B - Flow rate control method and device - Google Patents

Abstract

The invention discloses a method and a device for controlling flow velocity. It includes determining that the resource occupancy of the node to be controlled is greater than a preset occupancy threshold, and obtaining the number of resources occupied by each transaction dimension of the node to be controlled at the current moment to ensure the availability of the system, and effectively avoids resource constraints. Invalid flow rate control at the time; for the first transaction dimension of each transaction dimension, if it is determined that the number of resources occupied by the first transaction dimension at the current moment is greater than its current threshold, the received transaction of the first transaction dimension is performed Fast failure handling, so as to achieve smooth transition control of the pipeline that may fail, in which the current threshold of the first transaction dimension is obtained based on its historical threshold, thereby ensuring the dynamic update of the threshold and more in line with the characteristics of actual transactions.

Description

Method and device for controlling flow velocity

The invention belongs to the field of communication technology, and in particular, relates to a method and a device for controlling flow velocity.

In gateways and decentralized Internet trading systems, flow rate control is often required. In the prior art, when performing flow rate control, in order to ensure that the internal system does not endure too much pressure from the outside, a node that occupies too many resources is usually used as a fault node, and the fault node is isolated.

However, it is difficult to deal with the conditions under which the isolated fault node meets the recovery, and its recovery transactions often cause large fluctuations in the system. Therefore, there is an urgent need for a more effective flow rate control method for solving the technical problem of isolating a faulty node in the prior art, which makes subsequent recovery difficult.

Embodiments of the present invention provide a method and a device for controlling a flow rate, which are used to solve a technical problem of isolating a faulty node in the prior art, thereby making subsequent recovery difficult.

A flow rate control method provided by an embodiment of the present invention includes: after determining that a resource occupancy rate of a node to be controlled is greater than a preset occupancy threshold, obtaining the number of resources occupied by each transaction dimension of the node to be controlled at the current moment; For the first transaction dimension of each transaction dimension, if it is determined that the number of resources occupied by the first transaction dimension at the current moment is greater than the current threshold of the first transaction dimension, the transaction of the first transaction dimension will be received Fast failure processing is performed; the current threshold of the first transaction dimension is obtained according to the historical threshold of the first transaction dimension; the first transaction dimension is any one of the transaction dimensions of the respective transaction dimensions.

Preferably, if it is determined that the number of resources occupied by the first transaction dimension at the current time is less than or equal to the current threshold of the first transaction dimension, the received transaction of the first transaction dimension is processed.

Preferably, the current threshold value of the first transaction dimension is obtained according to the historical threshold value of the first transaction dimension and includes: determining the current threshold value of the first transaction dimension by the following formula: F _t = αX _t + (1- α ) F _{t -1}

Among them, F _{t is} the current threshold value of the first transaction dimension, F _{t -1 is} the historical threshold value of the first transaction dimension at a moment before the current time, and X _{t is} the number of resources currently occupied by the first transaction dimension. α is the weight value of the first transaction dimension.

Preferably, each transaction dimension of the node to be controlled is obtained by: acquiring each message corresponding to the node to be controlled; and according to the service element included in the each message, The service elements contained in each are determined as the target service elements; the types contained in each target service element are combined to obtain each transaction dimension of the node to be controlled.

An embodiment of the present invention provides a flow rate control device. The device includes: an acquisition module for determining that a resource occupancy rate of a node to be controlled is greater than a preset occupancy threshold value, and acquiring each transaction dimension of the node to be controlled at the current moment. Number of resources; a processing module for the first transaction dimension of each transaction dimension, if it is determined that the number of resources occupied by the first transaction dimension at the current moment is greater than the current threshold of the first transaction dimension, Fast fail processing of the received transaction of the first transaction dimension; the current threshold value of the first transaction dimension is obtained according to the historical threshold value of the first transaction dimension; the first transaction dimension is any of the respective transaction dimensions A transaction dimension.

Preferably, the processing module is further configured to: if it is determined that the number of resources occupied by the first transaction dimension at the current time is less than or equal to the current threshold value of the first transaction dimension, The transaction is processed.

Preferably, the processing module is specifically configured to determine the current threshold value of the first transaction dimension by the following formula: F _t = αX _t + (1- α ) F _{t -1}

Among them, F _{t is} the current threshold value of the first transaction dimension, F _{t -1 is} the historical threshold value of the first transaction dimension at a moment before the current time, and X _{t is} the number of resources currently occupied by the first transaction dimension. α is the weight value of the first transaction dimension.

Preferably, the processing module is further configured to obtain each transaction dimension of the node to be controlled by: obtaining each message corresponding to the node to be controlled; and according to the service elements contained in each message, all the messages are The included service element is determined as the target service element; The types included in each target service element are combined to obtain each transaction dimension of the node to be controlled.

An embodiment of the present invention provides a flow rate control device. The device includes a processor and a memory. The memory is used to store a software program. The processor is used to read the software program stored in the memory to execute: determine a node to be controlled. After the resource occupancy rate is greater than a preset occupancy threshold, the number of resources occupied by each transaction dimension of the node to be controlled at the current moment is obtained. For the first transaction dimension of each transaction dimension, if it is determined that the first transaction dimension is If the number of resources occupied at the current moment is greater than the current threshold of the first transaction dimension, the transaction of the received first transaction dimension is quickly failed to be processed; the current threshold of the first transaction dimension is based on the first transaction dimension Obtained from the historical threshold; the first transaction dimension is any one of the transaction dimensions.

Optionally, the processor is further configured to: if it is determined that the number of resources occupied by the first transaction dimension at the current moment is less than or equal to the current threshold value of the first transaction dimension, the received transaction of the first transaction dimension is For processing.

Optionally, the processor is specifically configured to determine the current threshold value of the first transaction dimension by the following formula: F _t = αX _t + (1- α ) F _{t -1}

Among them, F _{t is} the current threshold value of the first transaction dimension, F _{t -1 is} the historical threshold value of the first transaction dimension at a moment before the current time, and X _{t is} the number of resources currently occupied by the first transaction dimension. α is the weight value of the first transaction dimension.

Optionally, the processor is further configured to obtain each transaction dimension of the node to be controlled in the following manner: Obtaining each message corresponding to the node to be controlled; determining the service elements included in each message as target service elements according to the service elements included in each message; and combining the types contained in each target service element, Obtain the various transaction dimensions of the node to be controlled.

An embodiment of the present invention also provides a computer storage medium. A software program is stored in the storage medium, and the software program, when read and executed by one or more processors, can implement the flow rate control method provided by any of the above designs.

An embodiment of the present invention also provides a computer program product containing instructions, which when run on a computer, causes the computer to execute the flow rate control method described in the above aspects.

In the foregoing embodiment of the present invention, after determining that the resource occupancy rate of the node to be controlled is greater than a preset occupancy threshold, the number of resources occupied by each transaction dimension of the node to be controlled at the current moment is obtained; For the first transaction dimension, if it is determined that the number of resources occupied by the first transaction dimension at the current moment is greater than the current threshold value of the first transaction dimension, the received transaction of the first transaction dimension is quickly failed; The current threshold of a transaction dimension is obtained according to the historical threshold of the first transaction dimension. In an embodiment of the present invention, on the one hand, by comparing the resource occupancy rate of a node to be controlled with a preset occupancy rate threshold, When the rate is greater than the preset occupancy threshold, performing subsequent flow rate control operations not only ensures the availability of the system, but also effectively avoids invalid flow rate control when resources are not tight and saves processing resources; on the other hand, for each Any transaction dimension in the transaction dimension, if the number of resources occupied is greater than the threshold, it indicates that the transaction dimension The pipeline may fail, this time received the transaction dimension fast transaction processing failure, thereby achieving resource constraints In the case of smooth transition control of the pipeline that may fail, rather than complete isolation, by sacrificing a part of the transaction that could not be successful, the failure of the pipeline of the transaction dimension is avoided, so that after the transaction dimension returns to normal, Automatic recovery is performed gently; in particular, the current threshold value of the first transaction dimension is obtained based on the historical threshold value of the first transaction dimension, thereby ensuring that the threshold is dynamically updated and more in line with the characteristics of actual transactions.

101-102‧‧‧step

201‧‧‧Get Module

202‧‧‧Processing Module

300‧‧‧ Flow control device

301‧‧‧Memory

302‧‧‧Processor

In order to explain the technical solutions in the embodiments of the present invention more clearly, the drawings used in the description of the embodiments will be briefly introduced below. Obviously, the drawings in the following description are only some embodiments of the present invention. Those of ordinary skill in the art can also obtain other drawings according to these drawings without paying creative labor.

FIG. 1 is a schematic flowchart of a flow velocity control method according to an embodiment of the present invention.

FIG. 2 is a schematic structural diagram of a flow rate control device according to an embodiment of the present invention.

FIG. 3 is a schematic structural diagram of another flow rate control device according to an embodiment of the present invention.

In order to make the objectives, technical solutions, and advantages of the present invention clearer, the present invention will be described in further detail below with reference to the accompanying drawings. Obviously, the described embodiments are only part of the embodiments of the present invention, but not all of the embodiments. Based on the embodiments of the present invention, all other embodiments obtained by a person of ordinary skill in the art without creative efforts shall fall within the protection scope of the present invention.

The flow velocity control method in the embodiment of the present invention can be applied to various architectures, and is particularly applicable to the cloud migration architecture of the TSM platform. TSM platform is divided into access layer, application layer and service layer. According to the characteristics of the system architecture, the flow rate control method in the embodiment of the present invention can be applied to the access layer and the application layer. Specifically, because the TSM system needs to exchange information with many external institutions, if there are some external institutions that are slow to process, then in this case, a flow rate control method needs to be adopted to prevent sudden failures of some institutions from crowding out the transaction processing of other institutions Resources to ensure the stability of internal application systems.

FIG. 1 is a schematic flowchart of a flow velocity control method according to an embodiment of the present invention. As shown in FIG. 1, the method includes: Step 101, after determining that the resource occupancy rate of a node to be controlled is greater than a preset occupancy threshold, obtaining the number of resources occupied by each transaction dimension of the node to be controlled at the current moment; step 102 For the first transaction dimension of each transaction dimension, if it is determined that the number of resources occupied by the first transaction dimension at the current moment is greater than the current threshold value of the first transaction dimension, the received The transaction undergoes rapid failure processing; the current threshold value of the first transaction dimension is obtained according to the historical threshold value of the first transaction dimension; the first transaction dimension is any one of the transaction dimensions of the respective transaction dimensions.

Specifically, in the embodiment of the present invention, in step 101, different nodes may correspond to different preset occupancy thresholds. Taking the to-be-controlled node in the embodiment of the present invention as an example, the preset occupancy threshold of the to-be-controlled node can be set by those skilled in the art based on experience, and further, it can be based on the response speed of all subsequent application nodes of the to-be-controlled node and the to-be-controlled node. Processing power to determine a preset occupancy threshold.

In the embodiment of the present invention, by comparing the resource occupancy of the node to be controlled with a preset occupancy threshold, and performing a subsequent flow rate control operation when the resource occupancy is greater than the preset occupancy threshold, not only the system is ensured Availability, and effectively avoid resources Ineffective flow rate control when not stressed, saving processing resources.

In the embodiment of the present invention, for the node to be controlled, it is necessary to first define each transaction dimension of the node to be controlled. Specifically, each transaction dimension of the node to be controlled is obtained by: obtaining each message corresponding to the node to be controlled; According to the service elements contained in each message, the service elements contained in each message are determined as the target service elements; the types contained in each of the target service elements are combined to obtain the various transaction dimensions of the node to be controlled.

For example, suppose the target service elements of the node to be controlled are service element A and service element B. The number of types contained in service element A is three, which are type A1, type A2, type A3, and service element. The number of types contained in B is two, namely type B1 and type B2, and the transaction dimensions of the nodes to be controlled are six, namely {A1, B1}, {A2, B1}, {A3, B1 }, {A1, B2}, {A2, B2}, {A3, B2}, as shown in Table 1, show the transaction dimensions of the nodes to be controlled.

It can be known from the above that if the target service element of the node to be controlled is a service element A and service element B, the number of types contained in service element A is M, and the number of types contained in service element B is N, then the transaction dimension of the node to be controlled is M * N.

In the embodiment of the present invention, after each transaction dimension of the node to be controlled is determined in the foregoing manner, a reference value may be set for each transaction dimension. The reference value can be set by a person skilled in the art based on experience, or the reference value can also be determined according to the total number of nodes to be controlled and the number of transaction dimensions. Specifically, if the total number of resources of the node to be controlled is S and the number of transaction dimensions is k, S / k is rounded down to obtain X, and the reference value of each transaction dimension of the node to be controlled is set. Is X.

In the embodiment of the present invention, if the weight values of each service dimension are α 1, α 2, α 3, ..., α k, then the number of resources that can be allocated for each dimension is X * α 1, X * α 2, X * α 3, ..., X * α k, that is, the thresholds of each service dimension at the initial moment can be X * α 1, X * α 2, X * α 3, ..., X * α k.

In the embodiment of the present invention, unallocated excess resources can be used as dynamically allocated resources. The characteristic of dynamic allocation of resources is that no specific pipeline / service is allocated at first. When a pipeline / service obtains thread resources, it is not idle. Threads, you can allocate dynamic resources to it.

Taking the first transaction dimension in each service dimension as an example, the first transaction dimension may correspond to different thresholds at different times, and the current threshold value of the first transaction dimension is obtained based on the historical threshold value of the first transaction dimension. It should be noted that according to the foregoing, if it is at the initial time, the threshold value of the first transaction dimension can be obtained according to the reference value and the weight value. At this time, there is no historical time, and it can be assumed that the historical threshold is 0.

Specifically, the current threshold value of the first transaction dimension can be determined by the following formula: F _t = αX _t + (1- α ) F _{t -1} ...... Formula (1)

Among them, F _{t is} the current threshold value of the first transaction dimension, F _{t -1 is} the historical threshold value of the first transaction dimension at a moment before the current time, and X _{t is} the number of resources currently occupied by the first transaction dimension. α is the weight value of the first transaction dimension. The number of resources currently occupied by the first transaction dimension can be obtained by the transaction volume currently processed by the first transaction dimension.

Optionally, the current threshold of the first transaction dimension can also be determined by the following formula: F _t = αX _t + α (1- α ) X _{t -1} + α (1- α ) ² X _{t -2} + ... ( 1- α ) ^{t -1} X ₁ … Formula (2)

Among them, F _{t is} the current threshold value of the first transaction dimension, X _{t is} the number of resources currently occupied by the first transaction dimension, and is the number of resources occupied by the first transaction dimension at a moment before the current moment, as The number of resources occupied by the first transaction dimension in the first two moments of the current moment, and X _{1 is} the number of resources occupied by the first transaction dimension at the initial moment.

In step 102, if the number of occupied resources is greater than the threshold value, it may indicate that the pipeline of the first transaction dimension may be faulty. At this time, the received transaction of the first transaction dimension may be quickly failed to process, thereby realizing resource-constrained Under circumstances, smooth transition control of pipelines that may fail, rather than complete isolation, is to avoid the failure of pipelines in the transaction dimension by sacrificing a part of the transaction that could not be successful.

Further, at a subsequent time, if it is determined that the number of resources occupied by the first transaction dimension at the current time is less than or equal to the current threshold of the first transaction dimension, it means that the first transaction dimension has returned to normal. The transactions in the first transaction dimension are processed normally instead of fast failure processing, so that the transaction flow can be restored smoothly.

In the embodiment of the present invention, since the current threshold is obtained based on the historical threshold, the threshold is continuously updated, which is more in line with the characteristics of actual transactions. For example, a certain back-end pipeline processes transactions slowly. Be sure to orient it to ensure its intersection Easy to deal with; but when resources are tight, it ca n’t affect other pipelines with large transaction volume. Limiting the back-end pipeline's transactions to a limited extent will not only ensure transaction processing, but also control its transaction volume. This processing method is more gentle than directly isolating the transactions of this pipeline, and can dynamically restore its transaction flow.

In the embodiment of the present invention, each transaction dimension can be monitored according to a set period. The specific monitoring information may include the arrival time of each transaction, the processing time, success / timeout / quick failure, and the transaction dimension to which it belongs. Number of transactions processed; thresholds currently used for each transaction dimension. The arrival time and transaction dimension of each transaction are used to determine the transaction volume data of a certain transaction dimension. The comparison of the transaction data being processed with the threshold value is used to determine whether limited control is required. Other information can provide an alarm function, which is convenient to manually check the processing capabilities of each pipeline, clear performance data, and facilitate communication with external system interface personnel. Through the above-mentioned feather-weighted parallel monitoring sampling, the accuracy and punctuality of performance data is guaranteed, and the sampling period of monitoring information can be accurate to the second level.

Compared with the general flow control module, the above flow rate control method provides more fine-grained control capabilities; compared with the fine-grained flow control model, no complicated configuration parameters are required, and it is more in line with reality. The self-adjusting algorithm in formula (1) or formula (2) can ensure the adaptability of the system. When the transaction distribution changes, there is no need to manually reconfigure the parameters, which reduces the operation and maintenance time and operation maintenance. Difficulty. In addition, by setting the threshold update speed, the threshold update capability at the second level can be guaranteed. Compared with manually configured thresholds, the embodiments of the present invention are more reasonable and credible.

In view of the above method flow, an embodiment of the present invention further provides a flow rate control device, and the specific content of the device can be implemented by referring to the above method.

FIG. 2 is a schematic structural diagram of a flow rate control device according to an embodiment of the present invention. As shown in FIG. 2, the device includes an acquisition module 201 for determining that the resource occupancy rate of the node to be controlled is greater than a preset occupancy threshold, and acquiring the resources occupied by each transaction dimension of the node to be controlled at the current moment. Processing module 202, for the first transaction dimension of each transaction dimension, if it is determined that the number of resources occupied by the first transaction dimension at the current moment is greater than the current threshold of the first transaction dimension, it will receive The transaction of the first transaction dimension is quickly failed; the current threshold of the first transaction dimension is obtained according to the historical threshold of the first transaction dimension; the first transaction dimension is any transaction in each of the transaction dimensions Dimensions.

Preferably, the processing module is further configured to: if it is determined that the number of resources occupied by the first transaction dimension at the current time is less than or equal to the current threshold value of the first transaction dimension, The transaction is processed.

Preferably, the processing module is specifically configured to determine the current threshold value of the first transaction dimension by the following formula: F _t = αX _t + (1- α ) F _{t -1}

Among them, F _{t is} the current threshold value of the first transaction dimension, F _{t -1 is} the historical threshold value of the first transaction dimension at a moment before the current time, and X _{t is} the number of resources currently occupied by the first transaction dimension. α is the weight value of the first transaction dimension.

Preferably, the processing module is further configured to obtain each transaction dimension of the node to be controlled by: obtaining each message corresponding to the node to be controlled; and according to the service elements contained in each message, all the messages are Included service elements Prime is determined as the target service element; the types contained in each target service element are combined to obtain each transaction dimension of the node to be controlled.

FIG. 3 is a schematic structural diagram of another flow rate control device according to an embodiment of the present invention. As shown in FIG. 3, the flow rate control device 300 includes: a memory 301 and a processor 302; the memory 301 is used to store a program; specifically, the program may include a program code, and the program code includes a computer operation instruction. The memory 301 may be a random access memory (English: random access memory, RAM), or may be a non-volatile memory (English: non-volatile memory), such as at least one magnetic disk memory. Only one memory is shown in the figure. Of course, the memory can also be set as many as needed. The memory 301 may also be a memory in the processor 302.

The memory 301 stores the following elements, executable modules or data structures, or a subset thereof, or an extended set thereof: operation instructions: including various operation instructions for implementing various operations.

Operating system: Includes various system programs for implementing various basic services and processing hardware-based tasks.

The processor 302 may also be referred to as a central processing unit (English: Central Processing Unit, CPU). The method disclosed in the foregoing embodiment of the present invention may be applied to the processor 302, or implemented by the processor 302. The processor 302 may be an integrated circuit chip with signal processing capabilities. In the implementation process, each step of the above method may be completed by a hardware integrated logic circuit or a software form instruction in the processor 302. The processor 302 may be a general-purpose processor, a digital signal processor (DSP), a dedicated integrated circuit (ASIC), a field programmable gate array (FPGA), or other programmable logic devices, discrete gates, or transistor logic. Editing device, discrete hardware components. Various methods, steps, and logical block diagrams disclosed in the embodiments of the present invention may be implemented or executed. A general-purpose processor may be a microprocessor or the processor may be any conventional processor or the like. The software module may be located in a mature storage medium such as a random memory, a flash memory, a read-only memory, a programmable read-only memory, or an electrically readable and writable programmable memory, a register, and the like. The storage medium is located in the memory 301, and the processor 302 reads the information in the memory 301 and combines the hardware to execute the program stored in the memory. When the program is executed, the processor is used to determine the node to be controlled. After the resource occupancy rate is greater than a preset occupancy threshold, the number of resources occupied by each transaction dimension of the node to be controlled at the current moment is obtained. For the first transaction dimension of each transaction dimension, if it is determined that the first transaction dimension is If the number of resources occupied at the current moment is greater than the current threshold of the first transaction dimension, the transaction of the received first transaction dimension is quickly failed to be processed; the current threshold of the first transaction dimension is based on the first transaction dimension Obtained from the historical threshold; the first transaction dimension is any one of the transaction dimensions.

Optionally, the processor 302 is further configured to: if it is determined that the number of resources occupied by the first transaction dimension at the current moment is less than or equal to the current threshold of the first transaction dimension, The transaction is processed.

Optionally, the processor 302 is specifically configured to determine the current threshold value of the first transaction dimension by the following formula: F _t = αX _t + (1- α ) F _{t -1}

Among them, F _{t is} the current threshold value of the first transaction dimension, F _{t -1 is} the historical threshold value of the first transaction dimension at a moment before the current time, and X _{t is} the number of resources currently occupied by the first transaction dimension. α is the weight value of the first transaction dimension.

Optionally, the processor 302 is further configured to obtain each transaction dimension of the node to be controlled by: obtaining each message corresponding to the node to be controlled; and according to the service element included in each message, The included service element is determined as the target service element; the types contained in each target service element are combined to obtain each transaction dimension of the node to be controlled.

It can be seen from the foregoing that: in the above embodiment of the present invention, after determining that the resource occupancy rate of the node to be controlled is greater than a preset occupancy threshold, obtaining the number of resources occupied by each transaction dimension of the node to be controlled at the current moment; For the first transaction dimension of each transaction dimension, if it is determined that the number of resources occupied by the first transaction dimension at the current moment is greater than the current threshold of the first transaction dimension, the transaction of the first transaction dimension will be received Fast failure processing is performed; the current threshold value of the first transaction dimension is obtained according to the historical threshold value of the first transaction dimension; in an embodiment of the present invention, on the one hand, the resource occupation rate of the node to be controlled is compared with a preset occupation rate threshold Compare and perform subsequent flow rate control operations when the resource occupancy rate is greater than the preset occupancy threshold value, which not only ensures the availability of the system, but also effectively avoids invalid flow rate control when resources are not tight and saves processing resources ; On the other hand, for any one of the transaction dimensions, if the number of resources occupied is greater than Value, it means that the pipeline of the transaction dimension may be faulty. At this time, the received transaction of the transaction dimension may be quickly failed to handle, so as to realize the smooth transition control of the pipeline that may fail in the case of resource constraints. , Rather than completely isolated, by sacrificing a part of the transaction that could not be successful, to avoid the failure of the pipeline of the transaction dimension, so that it can progress smoothly after the transaction dimension returns to normal. The line automatically recovers; in particular, the current threshold value of the first transaction dimension is obtained based on the historical threshold value of the first transaction dimension, thereby ensuring that the threshold is dynamically updated and more in line with the characteristics of actual transactions.

Those skilled in the art should understand that the embodiments of the present invention may be provided as a method or a computer program product. Therefore, the present invention may take the form of an entirely hardware embodiment, an entirely software embodiment, or an embodiment combining software and hardware aspects. Moreover, the present invention may take the form of a computer program product implemented on one or more computer-usable storage media (including but not limited to magnetic disk memory, CD-ROM, optical memory, etc.) containing computer-usable code therein. .

The present invention is described with reference to flowcharts and / or block diagrams of methods, devices (systems), and computer program products according to embodiments of the present invention. It should be understood that each flow and / or block in the flowchart and / or block diagram, and a combination of the flow and / or block in the flowchart and / or block diagram can be implemented by computer program instructions. These computer program instructions can be provided to a processor of a general purpose computer, special purpose computer, embedded processor, or other programmable data processing device to generate a machine for instructions executed by the processor of the computer or other programmable data processing device Means are generated for implementing the functions specified in one or more flowcharts and / or one or more blocks of the block diagrams.

These computer program instructions may also be stored in computer readable memory that can guide a computer or other programmable data processing device to work in a specific manner, so that the instructions stored in the computer readable memory generate a manufactured article including a command device The instruction device implements the functions specified in a flowchart or a plurality of processes and / or a block or a plurality of blocks in the block diagram.

These computer program instructions can also be loaded on a computer or other programmable data processing equipment, so that a series of operating steps can be performed on the computer or other programmable equipment to generate computer-implemented processing, and thus on the computer or other programmable equipment The instructions executed on the Steps for implementing the functions specified in one or more flowcharts and / or one or more blocks of the block diagrams.

Although the preferred embodiments of the present invention have been described, those skilled in the art can make other changes and modifications to these embodiments once they know the basic inventive concepts. Therefore, the scope of the appended patent applications is intended to be construed to include the preferred embodiments and all changes and modifications that fall within the scope of the invention.

Obviously, those skilled in the art can make various modifications and variations to the present invention without departing from the spirit and scope of the present invention. In this way, if these modifications and variations of the present invention fall within the scope of the patent application for the present invention and the scope of the equivalent technology, the present invention also intends to include these modifications and variations.

Claims (12)

A method for controlling flow rate, which is applied to gateways and decentralized Internet transactions, is characterized in that the method includes: after determining that the resource occupancy rate of a node to be controlled is greater than a preset occupancy rate threshold, obtaining each transaction dimension of the node to be controlled in The number of resources occupied at the current moment; for the first transaction dimension of each transaction dimension, if it is determined that the number of resources occupied by the first transaction dimension at the current moment is greater than the current threshold of the first transaction dimension, it will receive The transaction of the first transaction dimension is quickly failed; the current threshold of the first transaction dimension is obtained according to the historical threshold of the first transaction dimension; the first transaction dimension is any transaction in each of the transaction dimensions Dimensions. The flow rate control method according to claim 1, wherein if it is determined that the number of resources occupied by the first transaction dimension at the current moment is less than or equal to the current threshold value of the first transaction dimension, the received first transaction dimension is Transaction. The flow rate control method according to claim 1, wherein the current threshold value of the first transaction dimension is obtained according to the historical threshold value of the first transaction dimension, including: determining the current threshold value of the first transaction dimension by the following formula: F _t = α X _t + (1-α) F _{t -1,} where F _{t is} the current threshold value of the first transaction dimension, and F _{t -1 is} the historical threshold value of the first transaction dimension at the moment before the current moment, X _{t is} the number of resources currently occupied by the first transaction dimension, and α is a weight value of the first transaction dimension. The flow rate control method according to any one of claims 1-3, wherein each transaction dimension of the node to be controlled is obtained by: acquiring each message corresponding to the node to be controlled; and according to each message including The service element included in each message is determined as the target service element; the types contained in each target service element are combined to obtain each transaction dimension of the node to be controlled. A flow rate control device applied to a gateway and a decentralized Internet transaction is characterized in that the device includes: an acquisition module for determining that a resource occupation rate of a node to be controlled is greater than a preset occupation rate threshold, and acquiring the to-be-controlled The number of resources occupied by each transaction dimension of the node at the current moment; the processing module is used for the first transaction dimension of each transaction dimension, if it is determined that the number of resources occupied by the first transaction dimension at the current moment is greater than If the current threshold of the first transaction dimension is used to quickly fail the received transaction of the first transaction dimension; the current threshold of the first transaction dimension is obtained according to the historical threshold of the first transaction dimension; the first The transaction dimension is any one of the transaction dimensions. The flow rate control device according to claim 5, wherein the processing module is further configured to: if it is determined that the number of resources occupied by the first transaction dimension at the current moment is less than or equal to the current threshold value of the first transaction dimension, The received transaction of the first transaction dimension is processed. The flow rate control device according to claim 5, wherein the processing module is specifically configured to determine a current threshold value of the first transaction dimension by the following formula: F _t = α X _t + (1-α) F _{t -1} Among them, F _{t is} the current threshold value of the first transaction dimension, F _{t -1 is} the historical threshold value of the first transaction dimension at a moment before the current time, and X _{t is} the number of resources currently occupied by the first transaction dimension. α is the weight value of the first transaction dimension. The flow rate control device according to any one of claims 5-7, wherein the processing module is further configured to obtain each transaction dimension of the node to be controlled by: acquiring each message corresponding to the node to be controlled; according to The service elements included in each message are determined as the target service elements; the types contained in each target service element are combined to obtain each transaction dimension of the node to be controlled. A flow rate control device, which is used in gateways and distributed Internet transactions, is characterized in that the device includes: a processor and a memory, the memory is used to store software programs, and the processor is used to read the memory stored in the memory Software program execution: After determining that the resource occupancy of the node to be controlled is greater than a preset occupancy threshold, obtain the number of resources occupied by each transaction dimension of the node to be controlled at the current moment; for the first transaction in each transaction dimension Dimension, if it is determined that the number of resources occupied by the first transaction dimension at the current moment is greater than the current threshold value of the first transaction dimension, the received transaction of the first transaction dimension is quickly failed to be processed; the first transaction dimension The current threshold of is obtained according to the historical threshold of the first transaction dimension; the first transaction dimension is any one of the transaction dimensions. The flow rate control device according to claim 9, wherein the processor is further configured to: if it is determined that the number of resources occupied by the first transaction dimension at the current moment is less than or equal to the current threshold of the first transaction dimension, The transaction of the first transaction dimension is processed. The flow rate control device according to claim 9, wherein the processor is specifically configured to determine a current threshold value of the first transaction dimension by the following formula: F _t = α X _t + (1-α) F _{t -1where} , F _{t is} the current threshold value of the first transaction dimension, F _{t -1 is} the historical threshold value of the first transaction dimension at a moment before the current time, X _{t is} the number of resources currently occupied by the first transaction dimension, α Is the weight value of the first transaction dimension. The flow rate control device according to any one of claims 9-11, wherein the processor is further configured to obtain each transaction dimension of the node to be controlled by: acquiring each message corresponding to the node to be controlled; according to the The service elements included in each message are determined as the target service elements; the types contained in each target service element are combined to obtain the transaction dimensions of the node to be controlled.