一种消息队列集群防脑裂方法及装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN108984320A(43)申请公布日2018.12.11(21)申请号201810682010.6(22)申请日2018.06.27(71)申请人郑州云海信息技术有限公司地址450018河南省郑州市郑东新区心怡路278号16层1601室(72)发明人苏志远(51)Int.Cl.G06F9/54(2006.01)G06F11/32(2006.01)G06F11/34(2006.01)权利要求书1页说明书6页附图1页(54)发明名称一种消息队列集群防脑裂方法及装置(57)摘要本申请实施例公开了一种消息队列集群防脑裂方法及装置，所述方法包括根据消息队列异常时节点的状态信息，构建告警模型，所述告警模型中包括用于表征所述节点的状态信息的N个元素；对所述节点当前时刻的所述N个元素分别进行时间序列分析，获得下一时刻所述N个元素对应的元素预测值；若第一元素对应的元素预测值大于或等于所述第一元素对应的告警阈值，则进行告警，所述第一元素为所述N个元素内的任一元素。在本申请实施例中，对引发消息队列脑裂的原因建模分析，获得引发消息队列的各个元素的阈值，并将这些阈值作为告警条件，另外对各个告警元素进行预测，并根据预测值给出告警，有效防止消息队列脑裂的出现。CN108984320ACN108984320A权利要求书1/1页1.一种消息队列集群防脑裂的方法，其特征在于，包括：根据消息队列异常时节点的状态信息，构建告警模型，所述告警模型中包括用于表征所述节点的状态信息的N个元素，其中每个元素配置一告警阈值，N≥1；对所述节点当前时刻的所述N个元素分别进行时间序列分析，获得下一时刻所述N个元素对应的元素预测值；若第一元素对应的元素预测值大于或等于所述第一元素对应的告警阈值，则进行告警，所述第一元素为所述N个元素内的任一元素。2.根据权利要求1所述的消息队列集群防脑裂的方法，其特征在于，还包括：若所述节点的告警次数超过预设的告警次数阈值，则关闭所述节点上的消息队列。3.根据权利要求1或2所述的消息队列集群防脑裂的方法，其特征在于，所述告警模型为一三元数据组，所述三元数据组的元素为CPU利用率、内存利用率和网络波动系数。4.根据权利要求3所述的消息队列集群防脑裂的方法，其特征在于，所述CPU利用率的告警阈值为CPU利用率历史数据平均值；所述内存利用率的告警阈值为内存利用率历史数据平均值；所述网络波动系数的告警阈值为网络波动系数历史数据平均值。5.根据权利要求1所述的消息队列集群防脑裂的方法，其特征在于，所述对所述节点当前时刻的所述N个元素分别进行时间序列分析，获得下一时刻所述N个元素对应的元素预测值，包括：基于Arima算法，对所述节点当前时刻的所述N个元素分别进行时间序列分析，获得下一时刻所述N个元素对应的元素预测值。6.一种消息队列集群防脑裂的装置，其特征在于，包括：构建模块，用于根据消息队列异常时节点的状态信息，构建告警模型，所述告警模型中包括用于表征所述节点的状态信息的N个元素，其中每个元素配置一告警阈值，N≥1；预测模块，用于对所述节点当前时刻的所述N个元素分别进行时间序列分析，获得下一时刻所述N个元素对应的元素预测值；告警模块，用于若第一元素对应的元素预测值大于或等于所述第一元素对应的告警阈值，则进行告警，所述第一元素为所述N个元素内的任一元素。7.根据权利要求6所述的消息队列集群防脑裂的装置，其特征在于，还包括：关闭模块，用于若所述节点的告警次数超过预设的告警次数阈值，则关闭所述节点上的消息队列。8.根据权利要求6或7所述的消息队列集群防脑裂的装置，其特征在于，所述告警模型为一三元数据组，所述三元数据组的元素为CPU利用率、内存利用率和网络波动系数。9.根据权利要求8所述的消息队列集群防脑裂的装置，其特征在于，所述CPU利用率的告警阈值为CPU利用率历史数据平均值；所述内存利用率的告警阈值为内存利用率历史数据平均值；所述网络波动系数的告警阈值为网络波动系数历史数据平均值。10.根据权利要求6所述的消息队列集群防脑裂的装置，其特征在于，所述预测模块，具体用于基于Arima算法，对所述节点当前时刻的所述N个元素分别进行时间序列分析，获得下一时刻所述N个元素对应的元素预测值。2CN108984320A说明书1/6页一种消息队列集群防脑裂方法及装置技术领域[0001]本申请涉及计算机技术领域，特别是涉及一种消息队列集群防脑裂方法及装置。背景技术[0002]OpenStack是一系列开源工具(或开源项目)的组合，主要使用池化虚拟资源来构建和管理私有云及公共云。其可以提供包括计算、网络、存储、身份认证、镜像和对象存储服务在内的核心云计算服务，用户可通过将其捆绑一起来创建独特、可部署的