预览加载中,请您耐心等待几秒...
1/10
2/10
3/10
4/10
5/10
6/10
7/10
8/10
9/10
10/10

亲,该文档总共14页,到这已经超出免费预览范围,如果喜欢就直接下载吧~

如果您无法下载资料,请参考说明:

1、部分资料下载需要金币,请确保您的账户上有足够的金币

2、已购买过的文档,再次下载不重复扣费

3、资料包下载后请先用软件解压,在使用对应软件打开

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113872830A(43)申请公布日2021.12.31(21)申请号202111136531.X(22)申请日2021.09.27(71)申请人重庆紫光华山智安科技有限公司地址400700重庆市北碚区云汉大道117号附386号(72)发明人谭宗喜(74)专利代理机构北京超凡宏宇专利代理事务所(特殊普通合伙)11463代理人张欣欣(51)Int.Cl.H04L12/26(2006.01)H04L12/851(2013.01)H04L29/08(2006.01)权利要求书2页说明书9页附图2页(54)发明名称流量管理方法及相关装置(57)摘要本申请提供的流量管理方法及相关装置中,管理节点根据各服务节点在服务期间的节点状况,从服务节点中确定出目标节点,并根据各目标节点的服务质量重新确定各自的第二流量阈值;由于各目标节点的第二流量阈值之和同样满足需求条件,因此,能够为客户端提供稳定流量的服务。CN113872830ACN113872830A权利要求书1/2页1.一种流量管理方法,其特征在于,应用于Kafka系统中的管理设备,所述Kafka系统还包括为客户端提供服务的多个服务节点,所述多个服务节点各自的第一流量阈值之和满足所述客户端对流量的需求条件,所述方法包括:获取所述多个服务节点各自的节点状况;根据所述多个服务节点各自的节点状况,确定出目标节点,其中,所述节点状况分别用于指示对应服务节点是否发生异常;根据所述目标节点各自的服务质量,确定所述目标节点各自的第二流量阈值,其中,所述第二流量阈值之和满足所述需求条件,所述服务质量分别包括对应目标节点的实测流量。2.根据权利要求1所述的流量管理方法,其特征在于,所述根据所述多个服务节点各自的节点状况,确定出目标节点,包括:若所述多个服务节点中存在异常节点,则将所述多个服务节点中未发生异常的服务节点作为所述目标节点;若所述多个服务节点中不存在异常节点,则将所述多个服务节点作为所述目标节点。3.根据权利要求1所述的流量管理方法,其特征在于,所述管理设备配置有所述客户端对流量的需求总量,所述根据所述目标节点各自的服务质量,确定所述目标节点各自的第二流量阈值,包括:根据所述目标节点各自的实测流量,获得所述目标节点之间的第一流量比例;根据所述第一流量比例以及所述需求总量,确定所述目标节点各自的第二流量阈值。4.根据权利要求3所述的流量管理方法,其特征在于,根据所述第一流量比例以及所述需求总量,确定所述目标节点各自的第二流量阈值,包括:根据所述第一流量比例分配所述需求总量,获得所述目标节点各自的第一参考阈值;根据第二流量比例分配所述需求总量,获得所述目标节点各自的第二参考阈值,其中,所述第二流量比例获取自每个所述目标节点的第一流量阈值;针对每个所述目标节点,根据所述目标节点的第一参考阈值以及所述目标节点的第二参考阈值,获得所述目标节点的第二流量阈值。5.根据权利要求4所述的流量管理方法,其特征在于,所述第一参考阈值、所述第二参考阈值以及所述第二流量阈值满足以下关系:式中,表示第i个目标节点的第一参考阈值,表示第i个目标节点的第二参考阈值,β表示变化系数,Ci表示第i个目标节点的第二流量阈值。6.根据权利要求3所述的流量管理方法,其特征在于,所述根据所述目标节点各自的实测流量,获得所述目标节点之间的第一流量比例之前,所述方法还包括:若所述实测流量之和大于或者等于积压阈值,则从所述目标节点中确定出待优化节点,其中,所述待优化节点各自的实测流量均小于均衡阈值;针对每个所述待优化节点,根据所述均衡阈值以及所述待优化节点的实测流量,确定所述待优化节点的目标流量,其中,所述目标流量大于对应待优化节点的实测流量;将所述待优化节点各自的目标流量,作为对应目标节点新的实测流量。2CN113872830A权利要求书2/2页7.根据权利要求6所述的流量管理方法,其特征在于,所述均衡阈值、所述实测流量以及所述目标流量满足以下关系:式中,表示第i个待优化节点的目标流量,D表示所述均衡阈值,δ表示均衡系数,Fi表示第i个待优化节点的实测流量。8.一种流量管理装置,其特征在于,应用于Kafka系统中的管理设备,所述Kafka系统还包括为客户端提供服务的多个服务节点,所述多个服务节点各自的第一流量阈值之和满足所述客户端对流量的需求条件,所述流量管理装置包括:状况模块,用于获取所述多个服务节点各自的节点状况,其中,所述节点状况分别用于指示对应服务节点是否发生异常;筛选模块,用于根据所述多个服务节点各自的节点状况,确定出目标节点;流量模块,用于根据所述目标节点各自的服务质量,确定所述目标节点各自的第二流量阈值,其中,所述第二流量阈值之和满足所述需求条件,所述