CN110380985A - Flow control methods, device, equipment and storage medium based on trade link - Google Patents
Flow control methods, device, equipment and storage medium based on trade link Download PDFInfo
- Publication number
- CN110380985A CN110380985A CN201910714882.0A CN201910714882A CN110380985A CN 110380985 A CN110380985 A CN 110380985A CN 201910714882 A CN201910714882 A CN 201910714882A CN 110380985 A CN110380985 A CN 110380985A
- Authority
- CN
- China
- Prior art keywords
- link
- business transaction
- trade
- type
- flow control
- Prior art date
- Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
- Granted
Links
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L45/00—Routing or path finding of packets in data switching networks
- H04L45/24—Multipath
- H04L45/245—Link aggregation, e.g. trunking
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/10—Flow control; Congestion control
- H04L47/12—Avoiding congestion; Recovering from congestion
- H04L47/125—Avoiding congestion; Recovering from congestion by balancing the load, e.g. traffic engineering
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/10—Flow control; Congestion control
- H04L47/24—Traffic characterised by specific attributes, e.g. priority or QoS
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/10—Flow control; Congestion control
- H04L47/24—Traffic characterised by specific attributes, e.g. priority or QoS
- H04L47/2408—Traffic characterised by specific attributes, e.g. priority or QoS for supporting different services, e.g. a differentiated services [DiffServ] type of service
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L47/00—Traffic control in data switching networks
- H04L47/10—Flow control; Congestion control
- H04L47/29—Flow control; Congestion control using a combination of thresholds
-
- Y—GENERAL TAGGING OF NEW TECHNOLOGICAL DEVELOPMENTS; GENERAL TAGGING OF CROSS-SECTIONAL TECHNOLOGIES SPANNING OVER SEVERAL SECTIONS OF THE IPC; TECHNICAL SUBJECTS COVERED BY FORMER USPC CROSS-REFERENCE ART COLLECTIONS [XRACs] AND DIGESTS
- Y02—TECHNOLOGIES OR APPLICATIONS FOR MITIGATION OR ADAPTATION AGAINST CLIMATE CHANGE
- Y02D—CLIMATE CHANGE MITIGATION TECHNOLOGIES IN INFORMATION AND COMMUNICATION TECHNOLOGIES [ICT], I.E. INFORMATION AND COMMUNICATION TECHNOLOGIES AIMING AT THE REDUCTION OF THEIR OWN ENERGY USE
- Y02D30/00—Reducing energy consumption in communication networks
- Y02D30/50—Reducing energy consumption in communication networks in wire-line communication networks, e.g. low power modes or reduced link rate
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Financial Or Insurance-Related Operations Such As Payment And Settlement (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
This specification embodiment provides a kind of flow control methods based on trade link, device, equipment and storage medium, this method comprises: obtaining the business transaction request of application node service in distributed type assemblies, in real time to form business transaction request set；Link aggregation is carried out to the business transaction request in the business transaction request set, to form one or more trade link；Extract the link characteristics value of the trade link；The business transaction type that the trade link is belonged to is determined according to the link characteristics value, to obtain the portfolio of each business transaction type in the distributed type assemblies；When the portfolio of wherein one or more business transaction types meets flow control trigger condition, in the initial application node in the distributed type assemblies, flow control is carried out to the business transaction type.This specification embodiment may be implemented to carry out flow control according to the portfolio of specific business scenario.
Description
Technical field
This specification is related to technical field, more particularly, to a kind of flow control methods based on trade link, device, sets
Standby and storage medium.
Background technique
Micro services epoch, business scenario are split according to domain model, and often a complete operation flow needs
By the final closed loop of multiple Message Communications.Although large-scale distributed cluster carries more massive concurrency,
But trade link is also more intricate.Therefore, in the case where developing high concurrent scene, for guarantee distributed type assemblies stability,
Generally require carry out flow control.
However, during realizing the application, the inventor of the present application discovered that: existing current limliting generally be directed to node into
Capable harmonious flow control, and do not distinguish specific business scenario.In this way, once carrying out harmonious flow control based on node
System may be such that wherein trading volume lesser some or certain business scenarios, also by shadow due to the amount of being included into control range
It rings.
Summary of the invention
This specification embodiment is designed to provide a kind of flow control methods based on trade link, device, equipment
And storage medium, flow control is carried out according to the portfolio of specific business scenario to realize.
In order to achieve the above objectives, on the one hand, this specification embodiment provides a kind of flow control based on trade link
Method, comprising:
The business transaction request of application node service in distributed type assemblies is obtained, in real time to form business transaction request collection
It closes；
Link aggregation is carried out to the business transaction request in the business transaction request set, is handed over forming one or more
Easy link；
Extract the link characteristics value of the trade link；
The business transaction type that the trade link is belonged to is determined according to the link characteristics value, to obtain the distribution
The portfolio of each business transaction type in formula cluster；
When the portfolio of wherein one or more business transaction types meets flow control trigger condition, in the distribution
In initial application node in formula cluster, flow control is carried out to the business transaction type.
In the flow control methods based on trade link that this specification embodiment provides, according to the link characteristics value
After determining the business transaction type that the trade link is belonged to, further includes:
The business transaction type belonged to according to the trade link, the real-time deal for generating the distributed type assemblies call
Figure, and export in real time.
It is described to extract the trade link in the flow control methods based on trade link that this specification embodiment provides
Link characteristics value, comprising:
Select a trade link；
Extract the calling characteristic value of each business transaction request in the trade link；
The calling characteristic value is arranged by calling sequence, forms the link characteristics value of the trade link.
It is described according to the link characteristics in the flow control methods based on trade link that this specification embodiment provides
Value determines the business transaction type that the trade link is belonged to, comprising:
Select a trade link；
It inquires in preset business transaction type feature database, if there is the link characteristics value with the trade link
The business transaction type matched；
If there is the business transaction type with the trade link characteristic matching, then by the trade link labeled as corresponding
Business transaction type, and update the portfolio of corresponding business transaction type.
On the other hand, this specification embodiment additionally provides a kind of volume control device based on trade link, comprising:
Request module, the business transaction for obtaining application node service in distributed type assemblies in real time is requested, with shape
At business transaction request set；
Link aggregation module, for carrying out link aggregation to the business transaction request in the business transaction request set,
To form one or more trade link；
Characteristic extracting module, for extracting the link characteristics value of the trade link；
Type identification module, for determining business transaction class that the trade link is belonged to according to the link characteristics value
Type, to obtain the portfolio of each business transaction type in the distributed type assemblies；
Flow-control module meets flow control triggering for the portfolio when wherein one or more business transaction types
When condition, in the initial application node in the distributed type assemblies, flow control is carried out to the business transaction type.
In the volume control device based on trade link that this specification embodiment provides, further includes:
Images outputting module, for determining business transaction that the trade link is belonged to according to the link characteristics value
After type, the business transaction type belonged to according to the trade link, the real-time deal for generating the distributed type assemblies is called
Figure, and export in real time.
It is described to extract the trade link in the volume control device based on trade link that this specification embodiment provides
Link characteristics value, comprising:
Select a trade link；
Extract the calling characteristic value of each business transaction request in the trade link；
The calling characteristic value is arranged by calling sequence, forms the link characteristics value of the trade link.
It is described according to the link characteristics in the volume control device based on trade link that this specification embodiment provides
Value determines the business transaction type that the trade link is belonged to, comprising:
Select a trade link；
It inquires in preset business transaction type feature database, if there is the link characteristics value with the trade link
The business transaction type matched；
If there is the business transaction type with the trade link characteristic matching, then by the trade link labeled as corresponding
Business transaction type, and update the portfolio of corresponding business transaction type.
On the other hand, this specification embodiment additionally provides a kind of computer equipment, including memory, processor and
The computer program being stored on the memory, the computer program execute following steps when being run by the processor:
The business transaction request of application node service in distributed type assemblies is obtained, in real time to form business transaction request collection
It closes；
Link aggregation is carried out to the business transaction request in the business transaction request set, is handed over forming one or more
Easy link；
Extract the link characteristics value of the trade link；
The business transaction type that the trade link is belonged to is determined according to the link characteristics value, to obtain the distribution
The portfolio of each business transaction type in formula cluster；
When the portfolio of wherein one or more business transaction types meets flow control trigger condition, in the distribution
In initial application node in formula cluster, flow control is carried out to the business transaction type.
On the other hand, this specification embodiment additionally provides a kind of computer storage medium, is stored thereon with computer journey
Sequence, the computer program perform the steps of when being executed by processor
The business transaction request of application node service in distributed type assemblies is obtained, in real time to form business transaction request collection
It closes；
Link aggregation is carried out to the business transaction request in the business transaction request set, is handed over forming one or more
Easy link；
Extract the link characteristics value of the trade link；
The business transaction type that the trade link is belonged to is determined according to the link characteristics value, to obtain the distribution
The portfolio of each business transaction type in formula cluster；
When the portfolio of wherein one or more business transaction types meets flow control trigger condition, in the distribution
In initial application node in formula cluster, flow control is carried out to the business transaction type.
The technical solution provided by above this specification embodiment is as it can be seen that in this specification embodiment based on trade link
Flow control methods in, realized based on link tracing real-time to the portfolio of business transaction type each in distributed type assemblies
Monitoring, can be in distribution when the portfolio of wherein one or more business transaction types meets flow control trigger condition
In initial application node in cluster, flow control is carried out to the business transaction type, to realize according to specific business field
The portfolio of scape carries out flow control, so that the control range of flow control is only limitted to the high business transaction class of those concurrency
Type, without being related to the low business transaction type of those concurrency, to will not influence the low business transaction type of concurrency
Arm's length dealing processing.
Detailed description of the invention
In order to illustrate more clearly of this specification embodiment or technical solution in the prior art, below will to embodiment or
Attached drawing needed to be used in the description of the prior art is briefly described, it should be apparent that, the accompanying drawings in the following description is only
The some embodiments recorded in this specification, for those of ordinary skill in the art, in not making the creative labor property
Under the premise of, it is also possible to obtain other drawings based on these drawings.In the accompanying drawings:
Fig. 1 is the flow chart for the flow control methods based on trade link that this specification embodiment provides；
Fig. 2 is the trade link schematic diagram in one embodiment of this specification；
Fig. 3 is the flow control principle signal for the volume control device based on trade link that this specification embodiment provides
Figure；
Fig. 4 is the structural block diagram for the volume control device based on trade link that this specification embodiment provides；
Fig. 5 is the structural block diagram for the computer equipment that this specification embodiment provides.
Specific embodiment
In order to make those skilled in the art more fully understand the technical solution in this specification, below in conjunction with this explanation
Attached drawing in book embodiment is clearly and completely described the technical solution in this specification embodiment, it is clear that described
Embodiment be only this specification a part of the embodiment, instead of all the embodiments.The embodiment of base in this manual,
Every other embodiment obtained by those of ordinary skill in the art without making creative efforts, all should belong to
The range of this specification protection.
Refering to what is shown in Fig. 1, the flow control methods based on trade link of some embodiments of this specification may include with
Lower step:
S101, the business transaction request for obtaining application node service in distributed type assemblies in real time, are asked with forming business transaction
Seek set.
S102, in the business transaction request set business transaction request carry out link aggregation, with formed one or
A plurality of trade link.
S103, the link characteristics value for extracting the trade link.
S104, the business transaction type that the trade link is belonged to is determined according to the link characteristics value, to obtain
State the portfolio of each business transaction type in distributed type assemblies.
S105, when the portfolio of wherein one or more business transaction types meets flow control trigger condition, in institute
It states in the initial application node in distributed type assemblies, flow control is carried out to the business transaction type.
It can be seen that being realized in the flow control methods based on trade link of above-described embodiment based on link tracing
The portfolio of business transaction type each in distributed type assemblies is monitored in real time, when wherein one or more business transaction types
Portfolio when meeting flow control trigger condition, the business can be handed in the initial application node in distributed type assemblies
Easy type carries out flow control, flow control is carried out according to the portfolio of specific business scenario to realize, so that flow control
The control range of system is only limitted to the high business transaction type of those concurrency, without being related to the low business transaction of those concurrency
Type, to will not influence the arm's length dealing processing of the low business transaction type of concurrency.
In some embodiments of this specification, it can be obtained by blocker (Interceptor) or filter (Filter)
The business transaction request for taking application node to receive.For example, in one exemplary embodiment, the skills such as bytecode weaving can be passed through
Art intercepts the business transaction request that application node receives.
Generally, the application node in distributed type assemblies may include front-end server, back-end server and database etc..
One trade link includes multiple service call links between multiple application nodes；Meanwhile it can also on the same application node
It can be related to the service call link of a plurality of trade link, and the concrete methods of realizing of each called service of service call link
It is general also different.Therefore, for each application node, by the way that application node each in distributed type assemblies is received
Business transaction request be collected into together, formed business transaction request set, can be used for subsequent link aggregation.Wherein, institute
Stating agreement used by business transaction is requested can be RPC agreement or http agreement etc..
In view of the transaction ID that each business transaction request includes for the unique identification transaction, therefore, Ke Yigen
Link aggregation is carried out to the business transaction request in the business transaction request set according to transaction ID, so as to form one
Or a plurality of trade link.It is handed over specifically, the business comprising same transaction ID can be inquired from business transaction request set
Easily request, and these business transactions request is arranged according to calling sequence, so as to form a trade link.According to this
Mode may finally polymerize one or more trade link from business transaction request set.
In one embodiment of this specification, the link characteristics value for extracting the trade link may include walking as follows
It is rapid:
Select a trade link；
Extract the calling characteristic value of each business transaction request in the trade link；Wherein, the calling characteristic value is for example
It can be call method etc..
The calling characteristic value is arranged by calling sequence, just forms the link characteristics value of the trade link.
Such as in Fig. 2, A trade link includes five calling characteristic values of A1, A2, A3, A4 and A5；Correspondingly, A chain transaction
The link characteristics value on road can be indicated with sequence (A1, A2, A3, A4).B trade link includes tri- calling features of B1, B2 and B3
Value；Correspondingly, the link characteristics value of B trade link can be indicated with sequence (B1, B2, B3).C trade link includes C1 and C2 two
A calling characteristic value；Correspondingly, the link characteristics value of C trade link can be indicated with sequence (C1, C2).
In one embodiment of this specification, the industry for determining that the trade link is belonged to according to the link characteristics value
Business type of transaction, may comprise steps of:
Select a trade link；
It inquires in preset business transaction type feature database, if there is the link characteristics value with the trade link
The business transaction type matched；
If there is the business transaction type with the trade link characteristic matching, then by the trade link labeled as corresponding
Business transaction type, and update the portfolio of corresponding business transaction type.In some special circumstances, it is possible that being not present
With the situation of the business transaction type of the trade link characteristic matching, can be not processed at this time.
The business of each business transaction type in distributed type assemblies is preserved in above-mentioned business transaction type feature database
Type of transaction characteristic sequence.The link characteristics of the historical trading link of analysis distribution formula cluster are first passed through in advance, it is available each
The corresponding relationship of business transaction type and its link characteristics, as shown in table 1 below:
Table 1
For example, in one exemplary embodiment, the link characteristics value of a certain trade link selected for sequence (C1,
C2), found by tabling look-up, there are sequence (C1, C2) in table 1, and its corresponding business transaction type is C transaction；It can then incite somebody to action
The business transaction type mark of the trade link is C transaction.
On the basis of identifying the business transaction type that every trade link is belonged to, so that it may in business transaction amount number
According to the portfolio for updating corresponding business transaction type in library.Wherein, safeguarding in business transaction amount database has in set period
The portfolio of business transaction type, such as shown in the following table 2.
Table 2
When the portfolio of wherein one or more business transaction types meets flow control trigger condition, so that it may divide
In initial application node in cloth cluster, flow control is carried out to the business transaction type.For example, the flow control of A transaction
Threshold value is 300, when the real time traffic of A transaction is more than 300, so that it may trade to A and carry out flow control.Wherein, starting is answered
Can be for the application node for being initially received business transaction request in distributed type assemblies with node, such as front-end server etc..
In some embodiments of this specification, the control strategy of the flow control can include but is not limited to drainage, limit
Stream and/or fusing etc., can specifically select, this specification is not construed as limiting this according to actual needs.
In some embodiments of this specification, industry that the trade link is belonged to is being determined according to the link characteristics value
After type of transaction of being engaged in, the business transaction type belonged to according to the trade link generates the real-time friendship of the distributed type assemblies
Easy calling figure, and output display in real time.Each business transaction in distributed type assemblies is intuitively viewed in this way, can be more clear
The real-time deal of type calls situation.
In another embodiment of this specification, industry that the trade link is belonged to is being determined according to the link characteristics value
After type of transaction of being engaged in, all trade links can also be persisted in trade link detailed data library.
Refering to what is shown in Fig. 3, corresponding with the above-mentioned flow control methods based on trade link, this specification embodiment is also provided
A kind of volume control device based on trade link, the device can be used for obtaining application node service in distributed type assemblies in real time
Business transaction request, to form business transaction request set；To the business transaction request in the business transaction request set
Link aggregation is carried out, to form one or more trade link；Extract the link characteristics value of the trade link；According to the chain
Road characteristic value determines the business transaction type that the trade link is belonged to, and is handed over obtaining each business in the distributed type assemblies
The portfolio of easy type；When the portfolio of wherein one or more business transaction types meets flow control trigger condition,
In initial application node in the distributed type assemblies, flow control is carried out to the business transaction type.
In the volume control device based on trade link of this specification embodiment, based on link tracing realize to point
The portfolio real time monitoring of each business transaction type in cloth cluster, when the business of wherein one or more business transaction types
It, can be in the initial application node in distributed type assemblies, to the business transaction type when amount meets flow control trigger condition
Flow control is carried out, flow control is carried out according to the portfolio of specific business scenario to realize, so that the control of flow control
Range processed is only limitted to the high business transaction type of those concurrency, without being related to the low business transaction type of those concurrency,
To will not influence the arm's length dealing processing of the low business transaction type of concurrency.
As shown in connection with fig. 4, in one embodiment of this specification, the above-mentioned volume control device based on trade link be can wrap
Include request module 41, link aggregation module 42, characteristic extracting module 43, type identification module 44 and flow-control module
45.Wherein:
Request module 41, the business transaction that can be used for obtaining application node service in distributed type assemblies in real time are asked
It asks, to form business transaction request set；
Link aggregation module 42 can be used for carrying out link to the business transaction request in the business transaction request set
Polymerization, to form one or more trade link；
Characteristic extracting module 43 can be used for extracting the link characteristics value of the trade link；
Type identification module 44 can be used for the business for determining that the trade link is belonged to according to the link characteristics value
Type of transaction, to obtain the portfolio of each business transaction type in the distributed type assemblies；
Flow-control module 45 can be used for meeting flow control when the portfolio of wherein one or more business transaction types
When trigger condition processed, in the initial application node in the distributed type assemblies, flow control is carried out to the business transaction type.
For convenience of description, it is divided into various units when description apparatus above with function to describe respectively.Certainly, implementing this
The function of each unit can be realized in the same or multiple software and or hardware when specification.
Refering to what is shown in Fig. 5, this specification embodiment can also provide a kind of computer equipment, including memory, processor,
And it is stored in the computer program on the memory, following step is executed when the computer program is run by the processor
It is rapid:
The business transaction request of application node service in distributed type assemblies is obtained, in real time to form business transaction request collection
It closes；
Link aggregation is carried out to the business transaction request in the business transaction request set, is handed over forming one or more
Easy link；
Extract the link characteristics value of the trade link；
The business transaction type that the trade link is belonged to is determined according to the link characteristics value, to obtain the distribution
The portfolio of each business transaction type in formula cluster；
When the portfolio of wherein one or more business transaction types meets flow control trigger condition, in the distribution
In initial application node in formula cluster, flow control is carried out to the business transaction type.
In addition, this specification embodiment can also provide a kind of computer storage medium, it is stored thereon with computer program,
The computer program performs the steps of when being executed by processor
The business transaction request of application node service in distributed type assemblies is obtained, in real time to form business transaction request collection
It closes；
Link aggregation is carried out to the business transaction request in the business transaction request set, is handed over forming one or more
Easy link；
Extract the link characteristics value of the trade link；
The business transaction type that the trade link is belonged to is determined according to the link characteristics value, to obtain the distribution
The portfolio of each business transaction type in formula cluster；
When the portfolio of wherein one or more business transaction types meets flow control trigger condition, in the distribution
In initial application node in formula cluster, flow control is carried out to the business transaction type.
Although procedures described above process includes the multiple operations occurred with particular order, it should however be appreciated that understand,
These processes may include more or fewer operations, these operations can be executed sequentially or be executed parallel (such as using parallel
Processor or multi-thread environment).
The present invention be referring to according to the method for the embodiment of the present invention, the process of equipment (system) and computer program product
Figure and/or block diagram describe.It should be understood that every one stream in flowchart and/or the block diagram can be realized by computer program instructions
The combination of process and/or box in journey and/or box and flowchart and/or the block diagram.It can provide these computer programs
Instruct the processor of general purpose computer, special purpose computer, Embedded Processor or other programmable data processing devices to produce
A raw machine, so that being generated by the instruction that computer or the processor of other programmable data processing devices execute for real
The device for the function of being specified in present one or more flows of the flowchart and/or one or more blocks of the block diagram.
These computer program instructions, which may also be stored in, is able to guide computer or other programmable data processing devices with spy
Determine in the computer-readable memory that mode works, so that it includes referring to that instruction stored in the computer readable memory, which generates,
Enable the manufacture of device, the command device realize in one box of one or more flows of the flowchart and/or block diagram or
The function of being specified in multiple boxes.
These computer program instructions also can be loaded onto a computer or other programmable data processing device, so that counting
Series of operation steps are executed on calculation machine or other programmable devices to generate computer implemented processing, thus in computer or
The instruction executed on other programmable devices is provided for realizing in one or more flows of the flowchart and/or block diagram one
The step of function of being specified in a box or multiple boxes.
In a typical configuration, calculating equipment includes one or more processors (CPU), input/output interface, net
Network interface and memory.
Memory may include the non-volatile memory in computer-readable medium, random access memory (RAM) and/or
The forms such as Nonvolatile memory, such as read-only memory (ROM) or flash memory (flash RAM).Memory is computer-readable medium
Example.
Computer-readable medium includes permanent and non-permanent, removable and non-removable media can be by any method
Or technology come realize information store.Information can be computer readable instructions, data structure, the module of program or other data.
The example of the storage medium of computer includes, but are not limited to phase change memory (PRAM), static random access memory (SRAM), moves
State random access memory (DRAM), other kinds of random access memory (RAM), read-only memory (ROM), electric erasable
Programmable read only memory (EEPROM), flash memory or other memory techniques, read-only disc read only memory (CD-ROM) (CD-ROM),
Digital versatile disc (DVD) or other optical storage, magnetic cassettes, magnetic disc type storage or other magnetic storage devices are appointed
What his non-transmission medium, can be used for storing and can be accessed by a computing device information.As defined in this article, computer can
Reading medium not includes temporary computer readable media (transitory media), such as data-signal and carrier wave of modulation.
It should also be noted that, the terms "include", "comprise" or its any other variant are intended to nonexcludability
Include, so that process, method or equipment including a series of elements not only include those elements, but also including not having
There is the other element being expressly recited, or further includes for this process, method or the intrinsic element of equipment.Do not having more
In the case where more limitations, the element that is limited by sentence "including a ...", it is not excluded that including process, the side of the element
There is also other identical elements in method or equipment.
It will be understood by those skilled in the art that the embodiment of this specification can provide as the production of method, system or computer program
Product.Therefore, complete hardware embodiment, complete software embodiment or implementation combining software and hardware aspects can be used in this specification
The form of example.Moreover, it wherein includes the computer of computer usable program code that this specification, which can be used in one or more,
The computer program implemented in usable storage medium (including but not limited to magnetic disk storage, CD-ROM, optical memory etc.) produces
The form of product.
This specification can describe in the general context of computer-executable instructions executed by a computer, such as journey
Sequence module.Generally, program module include routines performing specific tasks or implementing specific abstract data types, programs, objects,
Component, data structure etc..This specification can also be practiced in a distributed computing environment, in these distributed computing environment
In, by executing task by the connected remote processing devices of communication network.In a distributed computing environment, program module
It can be located in the local and remote computer storage media including storage equipment.
All the embodiments in this specification are described in a progressive manner, same and similar portion between each embodiment
Dividing may refer to each other, and each embodiment focuses on the differences from other embodiments.Especially for system reality
For applying example, since it is substantially similar to the method embodiment, so being described relatively simple, related place is referring to embodiment of the method
Part explanation.
The foregoing is merely the embodiments of this specification, are not limited to this specification.For art technology
For personnel, this specification can have various modifications and variations.It is all made any within the spirit and principle of this specification
Modification, equivalent replacement, improvement etc., should be included within the scope of the claims of this specification.
Claims (10)
1. a kind of flow control methods based on trade link characterized by comprising
The business transaction request of application node service in distributed type assemblies is obtained, in real time to form business transaction request set；
Link aggregation is carried out to the business transaction request in the business transaction request set, to form one or more chain transaction
Road；
Extract the link characteristics value of the trade link；
The business transaction type that the trade link is belonged to is determined according to the link characteristics value, to obtain the distributed collection
The portfolio of each business transaction type in group；
When the portfolio of wherein one or more business transaction types meets flow control trigger condition, in the distributed collection
In initial application node in group, flow control is carried out to the business transaction type.
2. as described in claim 1 based on the flow control methods of trade link, which is characterized in that special according to the link
After value indicative determines the business transaction type that the trade link is belonged to, further includes:
The business transaction type belonged to according to the trade link generates the real-time deal calling figure of the distributed type assemblies,
And it exports in real time.
3. as described in claim 1 based on the flow control methods of trade link, which is characterized in that described to extract the transaction
The link characteristics value of link, comprising:
Select a trade link；
Extract the calling characteristic value of each business transaction request in the trade link；
The calling characteristic value is arranged by calling sequence, forms the link characteristics value of the trade link.
4. as described in claim 1 based on the flow control methods of trade link, which is characterized in that described according to the link
Characteristic value determines the business transaction type that the trade link is belonged to, comprising:
Select a trade link；
It inquires in preset business transaction type feature database, if exist matched with the link characteristics value of the trade link
Business transaction type；
If there is the business transaction type with the trade link characteristic matching, then the trade link is labeled as corresponding business
Type of transaction, and update the portfolio of corresponding business transaction type.
5. a kind of volume control device based on trade link characterized by comprising
Request module, the business transaction for obtaining application node service in distributed type assemblies in real time is requested, to form industry
Business transaction request set；
Link aggregation module, for carrying out link aggregation to the business transaction request in the business transaction request set, with shape
At one or more trade link；
Characteristic extracting module, for extracting the link characteristics value of the trade link；
Type identification module, for determining business transaction type that the trade link is belonged to according to the link characteristics value,
To obtain the portfolio of each business transaction type in the distributed type assemblies；
Flow-control module meets flow control trigger condition for the portfolio when wherein one or more business transaction types
When, in the initial application node in the distributed type assemblies, flow control is carried out to the business transaction type.
6. as claimed in claim 5 based on the volume control device of trade link, which is characterized in that further include:
Images outputting module, for determining business transaction type that the trade link is belonged to according to the link characteristics value
Afterwards, the business transaction type belonged to according to the trade link generates the real-time deal calling figure of the distributed type assemblies, and
Output in real time.
7. as claimed in claim 5 based on the volume control device of trade link, which is characterized in that described to extract the transaction
The link characteristics value of link, comprising:
Select a trade link；
Extract the calling characteristic value of each business transaction request in the trade link；
The calling characteristic value is arranged by calling sequence, forms the link characteristics value of the trade link.
8. as claimed in claim 5 based on the volume control device of trade link, which is characterized in that described according to the link
Characteristic value determines the business transaction type that the trade link is belonged to, comprising:
Select a trade link；
It inquires in preset business transaction type feature database, if exist matched with the link characteristics value of the trade link
Business transaction type；
If there is the business transaction type with the trade link characteristic matching, then the trade link is labeled as corresponding business
Type of transaction, and update the portfolio of corresponding business transaction type.
9. a kind of computer equipment, including memory, processor and the computer program being stored on the memory,
It is characterized in that, the computer program executes following steps when being run by the processor:
The business transaction request of application node service in distributed type assemblies is obtained, in real time to form business transaction request set；
Link aggregation is carried out to the business transaction request in the business transaction request set, to form one or more chain transaction
Road；
Extract the link characteristics value of the trade link；
The business transaction type that the trade link is belonged to is determined according to the link characteristics value, to obtain the distributed collection
The portfolio of each business transaction type in group；
When the portfolio of wherein one or more business transaction types meets flow control trigger condition, in the distributed collection
In initial application node in group, flow control is carried out to the business transaction type.
10. a kind of computer storage medium, is stored thereon with computer program, which is characterized in that the computer program is located
Reason device performs the steps of when executing
The business transaction request of application node service in distributed type assemblies is obtained, in real time to form business transaction request set；
Link aggregation is carried out to the business transaction request in the business transaction request set, to form one or more chain transaction
Road；
Extract the link characteristics value of the trade link；
The business transaction type that the trade link is belonged to is determined according to the link characteristics value, to obtain the distributed collection
The portfolio of each business transaction type in group；
When the portfolio of wherein one or more business transaction types meets flow control trigger condition, in the distributed collection
In initial application node in group, flow control is carried out to the business transaction type.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201910714882.0A CN110380985B (en) | 2019-08-02 | 2019-08-02 | Traffic control method, device, equipment and storage medium based on transaction link |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201910714882.0A CN110380985B (en) | 2019-08-02 | 2019-08-02 | Traffic control method, device, equipment and storage medium based on transaction link |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN110380985A true CN110380985A (en) | 2019-10-25 |
| CN110380985B CN110380985B (en) | 2023-05-09 |
Family
ID=68257910
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201910714882.0A Active CN110380985B (en) | 2019-08-02 | 2019-08-02 | Traffic control method, device, equipment and storage medium based on transaction link |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN110380985B (en) |
Cited By (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111369367A (en) * | 2020-04-02 | 2020-07-03 | 中国工商银行股份有限公司 | Transaction flow combination method and device |
| CN111415261A (en) * | 2020-03-27 | 2020-07-14 | 中国建设银行股份有限公司 | Control method, system and device for dynamically updating flow control threshold of bank system |
| CN111709731A (en) * | 2020-06-18 | 2020-09-25 | 深圳前海微众银行股份有限公司 | Transaction processing method and device |
| CN111737297A (en) * | 2020-06-15 | 2020-10-02 | 中国工商银行股份有限公司 | Method and device for processing link aggregation call information |
| CN112702321A (en) * | 2020-12-15 | 2021-04-23 | 深圳市快付通金融网络科技服务有限公司 | Distributed transaction current limiting method, device, equipment and storage medium |
Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN104219316A (en) * | 2014-09-12 | 2014-12-17 | 微梦创科网络科技（中国）有限公司 | Method and device for processing call request in distributed system |
| US20150156127A1 (en) * | 2013-12-03 | 2015-06-04 | International Business Machines Corporation | Autonomic Traffic Load Balancing in Link Aggregation Groups |
| WO2018076760A1 (en) * | 2016-10-27 | 2018-05-03 | 上海亿账通区块链科技有限公司 | Block chain-based transaction processing method, system, electronic device, and storage medium |
-
2019
- 2019-08-02 CN CN201910714882.0A patent/CN110380985B/en active Active
Patent Citations (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US20150156127A1 (en) * | 2013-12-03 | 2015-06-04 | International Business Machines Corporation | Autonomic Traffic Load Balancing in Link Aggregation Groups |
| CN104219316A (en) * | 2014-09-12 | 2014-12-17 | 微梦创科网络科技（中国）有限公司 | Method and device for processing call request in distributed system |
| WO2018076760A1 (en) * | 2016-10-27 | 2018-05-03 | 上海亿账通区块链科技有限公司 | Block chain-based transaction processing method, system, electronic device, and storage medium |
Cited By (7)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111415261A (en) * | 2020-03-27 | 2020-07-14 | 中国建设银行股份有限公司 | Control method, system and device for dynamically updating flow control threshold of bank system |
| CN111415261B (en) * | 2020-03-27 | 2023-10-24 | 中国建设银行股份有限公司 | Control method, system and device for dynamically updating flow control threshold of bank system |
| CN111369367A (en) * | 2020-04-02 | 2020-07-03 | 中国工商银行股份有限公司 | Transaction flow combination method and device |
| CN111737297A (en) * | 2020-06-15 | 2020-10-02 | 中国工商银行股份有限公司 | Method and device for processing link aggregation call information |
| CN111737297B (en) * | 2020-06-15 | 2023-08-25 | 中国工商银行股份有限公司 | Method and device for processing link aggregation call information |
| CN111709731A (en) * | 2020-06-18 | 2020-09-25 | 深圳前海微众银行股份有限公司 | Transaction processing method and device |
| CN112702321A (en) * | 2020-12-15 | 2021-04-23 | 深圳市快付通金融网络科技服务有限公司 | Distributed transaction current limiting method, device, equipment and storage medium |
Also Published As
| Publication number | Publication date |
|---|---|
| CN110380985B (en) | 2023-05-09 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN110380985A (en) | Flow control methods, device, equipment and storage medium based on trade link | |
| CN105989155B (en) | Identify the method and device of risk behavior | |
| CN110489437A (en) | Distributed transaction processing method, device, computer equipment and storage medium | |
| CN109144699A (en) | Distributed task dispatching method, apparatus and system | |
| CN109784058A (en) | Version strong consistency method of calibration, client, server and storage medium | |
| KR20190075962A (en) | Data processing method and data processing apparatus | |
| CN110009347B (en) | Block chain transaction information auditing method and device | |
| CN110162422A (en) | One kind being based on the problem of decision tree localization method and device | |
| CN107645483A (en) | Risk Identification Method, risk identification device, cloud risk identification apparatus and system | |
| CN115631039A (en) | Fund tracking method, device and equipment | |
| CN108062243A (en) | Generation method, task executing method and the device of executive plan | |
| CN109951326A (en) | Data processing method, device, storage medium and processor | |
| CN108520077A (en) | A kind of method and apparatus avoiding repeated downloads | |
| CN113535399A (en) | NFV resource scheduling method, device and system | |
| CN109492049A (en) | Data processing, block generation and synchronous method for block chain network | |
| Valli et al. | Importance of AIOps for Turn Metrics and Log Data: A Survey | |
| CN112583944B (en) | Processing method and device for updating domain name certificate | |
| CN112750038B (en) | Transaction risk determination method, device and server | |
| CN106294530A (en) | The method and system of rule match | |
| CN109191096A (en) | A kind of signing risk quantification method withholds risk quantification method, device and equipment | |
| CN112712125A (en) | Event stream pattern matching method and device, storage medium and processor | |
| CN109150643A (en) | A kind of business processing method for detecting abnormality and device | |
| CN111193631B (en) | Information processing method, system, and computer-readable storage medium | |
| CN109885425A (en) | Backup method, back-up device, storage medium and the processor of data | |
| CN110019449A (en) | There are the merging method and device of intersection set |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |