CN110380985A - 基于交易链路的流量控制方法、装置、设备及存储介质 - Google Patents
基于交易链路的流量控制方法、装置、设备及存储介质 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
本说明书实施例提供了一种基于交易链路的流量控制方法、装置、设备及存储介质,该方法包括:实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;提取所述交易链路的链路特征值;根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。本说明书实施例可以实现根据具体业务场景的业务量进行流量控制。
Description
技术领域
本说明书涉及技术领域,尤其是涉及一种基于交易链路的流量控制方法、装置、设备及存储介质。
背景技术
微服务时代,业务场景按照领域模型进行了拆分,往往一个完整的业务流程需要经过多个服务间消息通信才最终闭环。虽然大规模分布式集群承载了更大规模的并发量,但是交易链路也更加错综复杂。因此,在开发高并发场景下,为保证分布式集群的稳定性,一般需要进行流量控制。
然而,在实现本申请的过程中,本申请的发明人发现:现有限流一般是针对节点进行的均衡性流量控制,而并不区分具体的业务场景。如此,一旦基于节点进行均衡性流量控制,可能会使得其中交易量较小的某个或某些业务场景,也因被纳入量控制范围而受到影响。
发明内容
本说明书实施例的目的在于提供一种基于交易链路的流量控制方法、装置、设备及存储介质,以实现根据具体业务场景的业务量进行流量控制。
为达到上述目的,一方面,本说明书实施例提供了一种基于交易链路的流量控制方法,包括:
实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;
对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;
提取所述交易链路的链路特征值;
根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;
当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
本说明书实施例提供的基于交易链路的流量控制方法中,在根据所述链路特征值确定所述交易链路所归属的业务交易类型后,还包括:
根据所述交易链路所归属的业务交易类型,生成所述分布式集群的实时交易调用图,并实时输出。
本说明书实施例提供的基于交易链路的流量控制方法中,所述提取所述交易链路的链路特征值,包括:
选择一条交易链路;
提取该交易链路中每个业务交易请求的调用特征值;
将所述调用特征值按调用顺序进行排列,形成该交易链路的链路特征值。
本说明书实施例提供的基于交易链路的流量控制方法中,所述根据所述链路特征值确定所述交易链路所归属的业务交易类型,包括:
选择一条交易链路;
查询预设的业务交易类型特征数据库中,是否存在与该交易链路的链路特征值匹配的业务交易类型;
如果存在与该交易链路特征匹配的业务交易类型,则将该交易链路标记为对应的业务交易类型,并更新对应业务交易类型的业务量。
另一方面,本说明书实施例还提供了一种基于交易链路的流量控制装置,包括:
请求获取模块,用于实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;
链路聚合模块,用于对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;
特征提取模块,用于提取所述交易链路的链路特征值;
类型识别模块,用于根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;
流量控制模块,用于当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
本说明书实施例提供的基于交易链路的流量控制装置中,还包括:
图形输出模块,用于在根据所述链路特征值确定所述交易链路所归属的业务交易类型后,根据所述交易链路所归属的业务交易类型,生成所述分布式集群的实时交易调用图,并实时输出。
本说明书实施例提供的基于交易链路的流量控制装置中,所述提取所述交易链路的链路特征值,包括:
选择一条交易链路;
提取该交易链路中每个业务交易请求的调用特征值;
将所述调用特征值按调用顺序进行排列,形成该交易链路的链路特征值。
本说明书实施例提供的基于交易链路的流量控制装置中,所述根据所述链路特征值确定所述交易链路所归属的业务交易类型,包括:
选择一条交易链路;
查询预设的业务交易类型特征数据库中,是否存在与该交易链路的链路特征值匹配的业务交易类型;
如果存在与该交易链路特征匹配的业务交易类型,则将该交易链路标记为对应的业务交易类型,并更新对应业务交易类型的业务量。
另一方面,本说明书实施例还提供了一种计算机设备,包括存储器、处理器、以及存储在所述存储器上的计算机程序,所述计算机程序被所述处理器运行时执行如下步骤:
实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;
对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;
提取所述交易链路的链路特征值;
根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;
当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
另一方面,本说明书实施例还提供了一种计算机存储介质,其上存储有计算机程序,所述计算机程序被处理器执行时实现以下步骤:
实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;
对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;
提取所述交易链路的链路特征值;
根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;
当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
由以上本说明书实施例提供的技术方案可见,在本说明书实施例的基于交易链路的流量控制方法中,基于链路追踪实现了对分布式集群中每个业务交易类型的业务量实时监控,当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,可以在分布式集群中的起始应用节点中,对该业务交易类型进行流量控制,从而实现了根据具体业务场景的业务量进行流量控制,使得流量控制的控制范围仅限于那些并发量高的业务交易类型,而不会涉及那些并发量低的业务交易类型,从而不会影响并发量低的业务交易类型的正常交易处理。
附图说明
为了更清楚地说明本说明书实施例或现有技术中的技术方案,下面将对实施例或现有技术描述中所需要使用的附图作简单地介绍,显而易见地,下面描述中的附图仅仅是本说明书中记载的一些实施例,对于本领域普通技术人员来讲,在不付出创造性劳动性的前提下,还可以根据这些附图获得其他的附图。在附图中:
图1为本说明书实施例提供的基于交易链路的流量控制方法的流程图;
图2为本说明书一实施例中的交易链路示意图;
图3为本说明书实施例提供的基于交易链路的流量控制装置的流量控制原理示意图;
图4为本说明书实施例提供的基于交易链路的流量控制装置的结构框图;
图5为本说明书实施例提供的计算机设备的结构框图。
具体实施方式
为了使本技术领域的人员更好地理解本说明书中的技术方案,下面将结合本说明书实施例中的附图,对本说明书实施例中的技术方案进行清楚、完整地描述,显然,所描述的实施例仅仅是本说明书一部分实施例,而不是全部的实施例。基于本说明书中的实施例,本领域普通技术人员在没有作出创造性劳动前提下所获得的所有其他实施例,都应当属于本说明书保护的范围。
参考图1所示,本说明书一些实施例的基于交易链路的流量控制方法可以包括以下步骤:
S101、实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合。
S102、对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路。
S103、提取所述交易链路的链路特征值。
S104、根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量。
S105、当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
由此可见,在上述实施例的基于交易链路的流量控制方法中,基于链路追踪实现了对分布式集群中每个业务交易类型的业务量实时监控,当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,可以在分布式集群中的起始应用节点中,对该业务交易类型进行流量控制,从而实现了根据具体业务场景的业务量进行流量控制,使得流量控制的控制范围仅限于那些并发量高的业务交易类型,而不会涉及那些并发量低的业务交易类型,从而不会影响并发量低的业务交易类型的正常交易处理。
在本说明书一些实施例中,可以通过拦截器(Interceptor)或过滤器(Filter)获取应用节点接收到的业务交易请求。例如,在一示例性实施例中,可以通过字节码织入等技术拦截应用节点收到的业务交易请求。
一般地,分布式集群中的应用节点可以包括前端服务器、后端服务器和数据库等。一个交易链路包含多个应用节点之间的多个服务调用环节;同时,同一个应用节点上也可能会涉及多条交易链路的服务调用环节,且每个服务调用环节所调用服务的具体实现方法一般也各不相同。因此,对于每个应用节点而言,通过将分布式集群中各个应用节点接收到的业务交易请求收集到一起,形成业务交易请求集合,可以用于后续的链路聚合。其中,所述业务交易请求所采用的协议可以是RPC协议或http协议等。
鉴于每个业务交易请求都包含有用于唯一标识该交易的交易标识,因此,可以根据交易标识对所述业务交易请求集合中的业务交易请求进行链路聚合,从而可以形成一条或多条交易链路。具体的,可以从业务交易请求集合中查询出包含同一交易标识的业务交易请求,并将这些业务交易请求按照调用顺序排列,从而可以形成一条交易链路。按照这种方式,最终可以从业务交易请求集合聚合出一条或多条交易链路。
在本说明书一实施例中,所述提取所述交易链路的链路特征值可以包括如下步骤:
选择一条交易链路;
提取该交易链路中每个业务交易请求的调用特征值;其中,所述调用特征值例如可以为调用方法等。
将所述调用特征值按调用顺序进行排列,就形成该交易链路的链路特征值。
例如在图2中,A交易链路包含A1、A2、A3、A4和A5五个调用特征值;相应的,A交易链路的链路特征值可以用序列(A1,A2,A3,A4)表示。B交易链路包含B1、B2和B3三个调用特征值;相应的,B交易链路的链路特征值可以用序列(B1,B2,B3)表示。C交易链路包括C1和C2两个调用特征值;相应的,C交易链路的链路特征值可以用序列(C1,C2)表示。
在本说明书一实施例中,所述根据所述链路特征值确定所述交易链路所归属的业务交易类型,可以包括以下步骤:
选择一条交易链路;
查询预设的业务交易类型特征数据库中,是否存在与该交易链路的链路特征值匹配的业务交易类型;
如果存在与该交易链路特征匹配的业务交易类型,则将该交易链路标记为对应的业务交易类型,并更新对应业务交易类型的业务量。在一些特殊情况下,可能会出现不存在与该交易链路特征匹配的业务交易类型的情形,此时可以不做处理。
上述业务交易类型特征数据库中保存有分布式集群中各个业务交易类型的业务交易类型特征序列。预先通过分析分布式集群的历史交易链路的链路特征,可以得到每个业务交易类型与其链路特征的对应关系,如下表1所示:
表1
例如,在一示例性实施例中,被选择的某一交易链路的链路特征值为序列(C1,C2),通过查表发现,表1中存在序列(C1,C2),且其对应的业务交易类型为C交易;则可以将该交易链路的业务交易类型标记为C交易。
在识别出每条交易链路所归属的业务交易类型的基础上,就可以在业务交易量数据库中更新对应的业务交易类型的业务量。其中,业务交易量数据库中维护有指定时段内业务交易类型的业务量,例如下表2所示。
表2
当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,就可以在分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。例如,A交易的流量控制阈值为300,当A交易的实时业务量超过300时,就可以对A交易进行流量控制。其中,起始应用节点可以为分布式集群中的最先接收到业务交易请求的应用节点,例如前端服务器等。
在本说明书一些实施例中,所述流量控制的控制策略可以包括但不限于引流、限流和/或熔断等,具体可根据实际需要选择,本说明书对此不作限定。
在本说明书一些实施例中,在根据所述链路特征值确定所述交易链路所归属的业务交易类型后,根据所述交易链路所归属的业务交易类型,生成所述分布式集群的实时交易调用图,并实时输出显示。如此,可以更加清晰直观地查看到分布式集群中每个业务交易类型的实时交易调用情况。
在本说明书另一实施例中,在根据所述链路特征值确定所述交易链路所归属的业务交易类型后,还可以将所有的交易链路持久化到交易链路明细数据库中。
参考图3所示,与上述基于交易链路的流量控制方法对应,本说明书实施例还提供了一种基于交易链路的流量控制装置,该装置可用于实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;提取所述交易链路的链路特征值;根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
在本说明书实施例的基于交易链路的流量控制装置中,基于链路追踪实现了对分布式集群中每个业务交易类型的业务量实时监控,当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,可以在分布式集群中的起始应用节点中,对该业务交易类型进行流量控制,从而实现了根据具体业务场景的业务量进行流量控制,使得流量控制的控制范围仅限于那些并发量高的业务交易类型,而不会涉及那些并发量低的业务交易类型,从而不会影响并发量低的业务交易类型的正常交易处理。
结合图4所示,在本说明书一实施例中,上述基于交易链路的流量控制装置可以包括请求获取模块41、链路聚合模块42、特征提取模块43、类型识别模块44和流量控制模块45。其中:
请求获取模块41,可以用于实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;
链路聚合模块42,可以用于对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;
特征提取模块43,可以用于提取所述交易链路的链路特征值;
类型识别模块44,可以用于根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;
流量控制模块45,可以用于当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
为了描述的方便,描述以上装置时以功能分为各种单元分别描述。当然,在实施本说明书时可以把各单元的功能在同一个或多个软件和/或硬件中实现。
参考图5所示,本说明书实施例还可以提供一种计算机设备,包括存储器、处理器、以及存储在所述存储器上的计算机程序,所述计算机程序被所述处理器运行时执行如下步骤:
实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;
对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;
提取所述交易链路的链路特征值;
根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;
当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
此外,本说明书实施例还可以提供一种计算机存储介质,其上存储有计算机程序,所述计算机程序被处理器执行时实现以下步骤:
实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;
对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;
提取所述交易链路的链路特征值;
根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;
当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
虽然上文描述的过程流程包括以特定顺序出现的多个操作,但是,应当清楚了解,这些过程可以包括更多或更少的操作,这些操作可以顺序执行或并行执行(例如使用并行处理器或多线程环境)。
本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器,使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。
这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中,使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品,该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。
这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上,使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理,从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。
在一个典型的配置中,计算设备包括一个或多个处理器(CPU)、输入/输出接口、网络接口和内存。
内存可能包括计算机可读介质中的非永久性存储器,随机存取存储器(RAM)和/或非易失性内存等形式,如只读存储器(ROM)或闪存(flash RAM)。内存是计算机可读介质的示例。
计算机可读介质包括永久性和非永久性、可移动和非可移动媒体可以由任何方法或技术来实现信息存储。信息可以是计算机可读指令、数据结构、程序的模块或其他数据。计算机的存储介质的例子包括,但不限于相变内存(PRAM)、静态随机存取存储器(SRAM)、动态随机存取存储器(DRAM)、其他类型的随机存取存储器(RAM)、只读存储器(ROM)、电可擦除可编程只读存储器(EEPROM)、快闪记忆体或其他内存技术、只读光盘只读存储器(CD-ROM)、数字多功能光盘(DVD)或其他光学存储、磁盒式磁带,磁盘式存储或其他磁性存储设备或任何其他非传输介质,可用于存储可以被计算设备访问的信息。按照本文中的界定,计算机可读介质不包括暂存电脑可读媒体(transitory media),如调制的数据信号和载波。
还需要说明的是,术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含,从而使得包括一系列要素的过程、方法、或者设备不仅包括那些要素,而且还包括没有明确列出的其他要素,或者是还包括为这种过程、方法或者设备所固有的要素。在没有更多限制的情况下,由语句“包括一个……”限定的要素,并不排除在包括所述要素的过程、方法或者设备中还存在另外的相同要素。
本领域技术人员应明白,本说明书的实施例可提供为方法、系统或计算机程序产品。因此,本说明书可采用完全硬件实施例、完全软件实施例或结合软件和硬件方面的实施例的形式。而且,本说明书可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。
本说明书可以在由计算机执行的计算机可执行指令的一般上下文中描述,例如程序模块。一般地,程序模块包括执行特定任务或实现特定抽象数据类型的例程、程序、对象、组件、数据结构等等。也可以在分布式计算环境中实践本说明书,在这些分布式计算环境中,由通过通信网络而被连接的远程处理设备来执行任务。在分布式计算环境中,程序模块可以位于包括存储设备在内的本地和远程计算机存储介质中。
本说明书中的各个实施例均采用递进的方式描述,各个实施例之间相同相似的部分互相参见即可,每个实施例重点说明的都是与其他实施例的不同之处。尤其,对于系统实施例而言,由于其基本相似于方法实施例,所以描述的比较简单,相关之处参见方法实施例的部分说明即可。
以上所述仅为本说明书的实施例而已,并不用于限制本说明书。对于本领域技术人员来说,本说明书可以有各种更改和变化。凡在本说明书的精神和原理之内所作的任何修改、等同替换、改进等,均应包含在本说明书的权利要求范围之内。
Claims (10)
1.一种基于交易链路的流量控制方法,其特征在于,包括:
实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;
对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;
提取所述交易链路的链路特征值;
根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;
当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
2.如权利要求1所述的基于交易链路的流量控制方法,其特征在于,在根据所述链路特征值确定所述交易链路所归属的业务交易类型后,还包括:
根据所述交易链路所归属的业务交易类型,生成所述分布式集群的实时交易调用图,并实时输出。
3.如权利要求1所述的基于交易链路的流量控制方法,其特征在于,所述提取所述交易链路的链路特征值,包括:
选择一条交易链路;
提取该交易链路中每个业务交易请求的调用特征值;
将所述调用特征值按调用顺序进行排列,形成该交易链路的链路特征值。
4.如权利要求1所述的基于交易链路的流量控制方法,其特征在于,所述根据所述链路特征值确定所述交易链路所归属的业务交易类型,包括:
选择一条交易链路;
查询预设的业务交易类型特征数据库中,是否存在与该交易链路的链路特征值匹配的业务交易类型;
如果存在与该交易链路特征匹配的业务交易类型,则将该交易链路标记为对应的业务交易类型,并更新对应业务交易类型的业务量。
5.一种基于交易链路的流量控制装置,其特征在于,包括:
请求获取模块,用于实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;
链路聚合模块,用于对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;
特征提取模块,用于提取所述交易链路的链路特征值;
类型识别模块,用于根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;
流量控制模块,用于当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
6.如权利要求5所述的基于交易链路的流量控制装置,其特征在于,还包括:
图形输出模块,用于在根据所述链路特征值确定所述交易链路所归属的业务交易类型后,根据所述交易链路所归属的业务交易类型,生成所述分布式集群的实时交易调用图,并实时输出。
7.如权利要求5所述的基于交易链路的流量控制装置,其特征在于,所述提取所述交易链路的链路特征值,包括:
选择一条交易链路;
提取该交易链路中每个业务交易请求的调用特征值;
将所述调用特征值按调用顺序进行排列,形成该交易链路的链路特征值。
8.如权利要求5所述的基于交易链路的流量控制装置,其特征在于,所述根据所述链路特征值确定所述交易链路所归属的业务交易类型,包括:
选择一条交易链路;
查询预设的业务交易类型特征数据库中,是否存在与该交易链路的链路特征值匹配的业务交易类型;
如果存在与该交易链路特征匹配的业务交易类型,则将该交易链路标记为对应的业务交易类型,并更新对应业务交易类型的业务量。
9.一种计算机设备,包括存储器、处理器、以及存储在所述存储器上的计算机程序,其特征在于,所述计算机程序被所述处理器运行时执行如下步骤:
实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;
对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;
提取所述交易链路的链路特征值;
根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;
当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
10.一种计算机存储介质,其上存储有计算机程序,其特征在于,所述计算机程序被处理器执行时实现以下步骤:
实时获取分布式集群中应用节点服务的业务交易请求,以形成业务交易请求集合;
对所述业务交易请求集合中的业务交易请求进行链路聚合,以形成一条或多条交易链路;
提取所述交易链路的链路特征值;
根据所述链路特征值确定所述交易链路所归属的业务交易类型,以获取所述分布式集群中每个业务交易类型的业务量;
当其中一个或多个业务交易类型的业务量满足流量控制触发条件时,在所述分布式集群中的起始应用节点中,对该业务交易类型进行流量控制。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201910714882.0A CN110380985B (zh) | 2019-08-02 | 2019-08-02 | 基于交易链路的流量控制方法、装置、设备及存储介质 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201910714882.0A CN110380985B (zh) | 2019-08-02 | 2019-08-02 | 基于交易链路的流量控制方法、装置、设备及存储介质 |
Publications (2)
Publication Number | Publication Date |
---|---|
CN110380985A true CN110380985A (zh) | 2019-10-25 |
CN110380985B CN110380985B (zh) | 2023-05-09 |
Family
ID=68257910
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN201910714882.0A Active CN110380985B (zh) | 2019-08-02 | 2019-08-02 | 基于交易链路的流量控制方法、装置、设备及存储介质 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN110380985B (zh) |
Cited By (5)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN111369367A (zh) * | 2020-04-02 | 2020-07-03 | 中国工商银行股份有限公司 | 一种交易流程的组合方法及装置 |
CN111415261A (zh) * | 2020-03-27 | 2020-07-14 | 中国建设银行股份有限公司 | 银行系统的流控阈值动态更新的控制方法、系统和装置 |
CN111709731A (zh) * | 2020-06-18 | 2020-09-25 | 深圳前海微众银行股份有限公司 | 一种交易处理方法及装置 |
CN111737297A (zh) * | 2020-06-15 | 2020-10-02 | 中国工商银行股份有限公司 | 链路聚合调用信息的处理方法及装置 |
CN112702321A (zh) * | 2020-12-15 | 2021-04-23 | 深圳市快付通金融网络科技服务有限公司 | 分布式交易限流方法、装置、设备及存储介质 |
Citations (3)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN104219316A (zh) * | 2014-09-12 | 2014-12-17 | 微梦创科网络科技(中国)有限公司 | 一种分布式系统中的调用请求处理方法及装置 |
US20150156127A1 (en) * | 2013-12-03 | 2015-06-04 | International Business Machines Corporation | Autonomic Traffic Load Balancing in Link Aggregation Groups |
WO2018076760A1 (zh) * | 2016-10-27 | 2018-05-03 | 上海亿账通区块链科技有限公司 | 基于区块链的交易事务处理方法、系统、电子装置及存储介质 |
-
2019
- 2019-08-02 CN CN201910714882.0A patent/CN110380985B/zh 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 (zh) * | 2014-09-12 | 2014-12-17 | 微梦创科网络科技(中国)有限公司 | 一种分布式系统中的调用请求处理方法及装置 |
WO2018076760A1 (zh) * | 2016-10-27 | 2018-05-03 | 上海亿账通区块链科技有限公司 | 基于区块链的交易事务处理方法、系统、电子装置及存储介质 |
Cited By (7)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN111415261A (zh) * | 2020-03-27 | 2020-07-14 | 中国建设银行股份有限公司 | 银行系统的流控阈值动态更新的控制方法、系统和装置 |
CN111415261B (zh) * | 2020-03-27 | 2023-10-24 | 中国建设银行股份有限公司 | 银行系统的流控阈值动态更新的控制方法、系统和装置 |
CN111369367A (zh) * | 2020-04-02 | 2020-07-03 | 中国工商银行股份有限公司 | 一种交易流程的组合方法及装置 |
CN111737297A (zh) * | 2020-06-15 | 2020-10-02 | 中国工商银行股份有限公司 | 链路聚合调用信息的处理方法及装置 |
CN111737297B (zh) * | 2020-06-15 | 2023-08-25 | 中国工商银行股份有限公司 | 链路聚合调用信息的处理方法及装置 |
CN111709731A (zh) * | 2020-06-18 | 2020-09-25 | 深圳前海微众银行股份有限公司 | 一种交易处理方法及装置 |
CN112702321A (zh) * | 2020-12-15 | 2021-04-23 | 深圳市快付通金融网络科技服务有限公司 | 分布式交易限流方法、装置、设备及存储介质 |
Also Published As
Publication number | Publication date |
---|---|
CN110380985B (zh) | 2023-05-09 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
CN110380985A (zh) | 基于交易链路的流量控制方法、装置、设备及存储介质 | |
CN105989155B (zh) | 识别风险行为的方法及装置 | |
CN110489437A (zh) | 分布式事务处理方法、装置、计算机设备及存储介质 | |
CN109144699A (zh) | 分布式任务调度方法、装置及系统 | |
CN109784058A (zh) | 版本强一致性校验方法、客户端、服务器及存储介质 | |
KR20190075962A (ko) | 데이터 처리 방법과 데이터 처리 장치 | |
CN110009347B (zh) | 一种区块链交易信息审计的方法及装置 | |
CN110162422A (zh) | 一种基于决策树的问题定位方法和装置 | |
CN107645483A (zh) | 风险识别方法、风险识别装置、云风险识别装置及系统 | |
CN115631039A (zh) | 资金追踪方法、装置及设备 | |
CN108062243A (zh) | 执行计划的生成方法、任务执行方法及装置 | |
CN109951326A (zh) | 数据处理方法、装置、存储介质及处理器 | |
CN108520077A (zh) | 一种避免重复下载的方法和装置 | |
CN113535399A (zh) | 一种nfv资源调度方法、装置以及系统 | |
CN109492049A (zh) | 用于区块链网络的数据处理、区块生成及同步方法 | |
Valli et al. | Importance of AIOps for Turn Metrics and Log Data: A Survey | |
CN112583944B (zh) | 一种更新域名证书的处理方法和装置 | |
CN112750038B (zh) | 交易风险的确定方法、装置和服务器 | |
CN106294530A (zh) | 规则匹配的方法和系统 | |
CN109191096A (zh) | 一种签约风险量化方法、代扣风险量化方法、装置及设备 | |
CN112712125A (zh) | 事件流的模式匹配方法、装置、存储介质及处理器 | |
CN109150643A (zh) | 一种业务处理异常检测方法及装置 | |
CN111193631B (zh) | 信息处理方法、系统和计算机可读存储介质 | |
CN109885425A (zh) | 数据的备份方法、备份装置、存储介质和处理器 | |
CN110019449A (zh) | 有交集集合的合并方法及装置 |
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 |