CN103067209B - 一种心跳模块自检测方法 - Google Patents
一种心跳模块自检测方法 Download PDFInfo
- Publication number
- CN103067209B CN103067209B CN201310028990.5A CN201310028990A CN103067209B CN 103067209 B CN103067209 B CN 103067209B CN 201310028990 A CN201310028990 A CN 201310028990A CN 103067209 B CN103067209 B CN 103067209B
- Authority
- CN
- China
- Prior art keywords
- heartbeat
- time
- detection
- poll
- flow
- 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.)
- Active
Links
- 238000000034 method Methods 0.000 title claims abstract description 28
- 238000001514 detection method Methods 0.000 claims abstract description 73
- 230000002159 abnormal effect Effects 0.000 claims abstract description 10
- 230000005540 biological transmission Effects 0.000 claims description 17
- 230000005856 abnormality Effects 0.000 claims description 14
- 238000012360 testing method Methods 0.000 claims description 10
- 230000007246 mechanism Effects 0.000 description 4
- 238000007689 inspection Methods 0.000 description 3
- 238000005516 engineering process Methods 0.000 description 2
- 206010033799 Paralysis Diseases 0.000 description 1
- 230000009286 beneficial effect Effects 0.000 description 1
- 230000007812 deficiency Effects 0.000 description 1
- 235000013399 edible fruits Nutrition 0.000 description 1
- 230000000694 effects Effects 0.000 description 1
- 230000002349 favourable effect Effects 0.000 description 1
- 230000009191 jumping Effects 0.000 description 1
- 238000012544 monitoring process Methods 0.000 description 1
- 238000004806 packaging method and process Methods 0.000 description 1
- 238000011084 recovery Methods 0.000 description 1
- 230000001550 time effect Effects 0.000 description 1
Landscapes
- Debugging And Monitoring (AREA)
Abstract
本发明提供一种心跳模块自检测方法，其具体检测步骤包括：发送心跳流程：发送心跳流程以心跳时间间隔为频率定时发送；检测心跳超时流程：用于检查某个节点或某个心跳媒介是否出现故障，进行业务报警；所述检测心跳超时流程的执行频率大于发送心跳流程的执行频率，且这两个流程对两个轮询进行互检，当某个轮询出现异常时，将重新启动该轮询，并更新下一次异常检测时间，所述两个流程应用于高可用集群中。该一种心跳模块自检测方法和现有技术相比，能够解决因轮询失效无法实时提供业务状态并及时进行业务报警的问题，解决了心跳发送异常问题；提高了节点和媒介状态检测的可靠性。
Description
技术领域
本发明涉及高可用集群系统中多节点消息通信的方法，具体的说是一种心跳模块自检测方法。
背景技术
高可用集群系统是指能够保证业务24小时不中断，在系统发生问题或者应用软件发生问题时，能够快速恢复业务，尽可能将宕机时间控制在分钟级别的系统。高可用集群系统由下至上主要包括以下几个模块：心跳模块、资源监控模块、资源管理模块、分布式控制台模块和web服务模块。
其中，心跳模块负责多节点的信息传输，是整个系统的核心，是信息交换的枢纽。该模块的可靠性和稳定性直接影响整个系统的实时效应，即实时提供业务状态并及时进行业务预警。面对多节点多媒介的信息传输，要求可进行多播和广播、传输速率快、信息量大且不遗漏、资源开销少。心跳模块一般采用glib库中main event loop轮询机制进行消息发送，以及节点和媒介的状态检测。但由于该机制复杂度高，封装性强，调用时程序中的某个错误可能使得该轮询在某个运行点失效，从而导致心跳模块无法正常工作，甚至使高可用集群系统瘫痪。同时高可用集群系统要求保证业务7×24小时不间断运行，对可靠性，稳定性要求极高，一旦出现轮询失效，对企业将是巨大的损失。
发明内容
本发明的技术任务是解决现有技术的不足，提供一种心跳模块自检测方法。
本发明的技术方案是按以下方式实现的，该一种心跳模块自检测方法，其具体检测步骤包括：
发送心跳流程：发送心跳流程以心跳时间间隔为频率定时发送；
检测心跳超时流程：用于检查某个节点或某个心跳媒介是否出现故障，进行业务报警；
所述检测心跳超时流程的执行频率大于发送心跳流程的执行频率，且这两个流程对两个轮询进行互检，当某个轮询出现异常时，将重新启动该轮询，并更新下一次异常检测时间，所述两个流程应用于高可用集群中。
所述发送心跳流程的详细步骤为：
步骤1、获取系统自开机以来的当前时间；
步骤2、检测心跳超时检测流程是否正常，若正常则进入步骤6，若不正常则进入步骤3；
步骤3、移除心跳超时检测轮询；
步骤4、重新根据心跳超时检测时间间隔添加新的超时检测轮询；
步骤5、更新超时检测时间；
步骤6、更新心跳发送时间；
步骤7、创建心跳信息并放到发送队列里等待发送。
所述步骤2的检测心跳超时检测流程为：通过比较心跳超时时间与步骤1测量的当前时间差值来确定心跳超时检测轮询是否异常，如果差值为正数，则表示正常，反之异常。
所述步骤5的详细过程为：超时检测时间更新为当前时间与超时检测时间间隔×4之和，表明再经过更新后的超时检测时间进行超时检测轮询的异常检测。
所述步骤6的详细过程为：心跳发送时间更新为当前时间与心跳发送时间间隔×2之和，表明再经过更新后的心跳发送时间进行心跳发送轮询的异常检测。
所述检测心跳超时流程的详细步骤为：
步骤1：获取系统自开机以来的当前时间；
步骤2、检测心跳发送检测流程是否正常，若正常则进入步骤6，若不正常则进入步骤3；
步骤3、移除心跳发送轮询；
步骤4、重新根据心跳发送时间间隔添加新的心跳发送轮询；
步骤5、更新心跳发送时间；
步骤6、更新超时检测时间；
步骤7、继续进行节点状态检测和心跳媒介的检测，并将检测结果反馈集群各节点。
所述步骤2的检测发送心跳流程是否正确过程为：通过比较心跳发送时间与当前时间差值来确定检测心跳发送检测流程是否正常，如果是正数，表明心跳发送轮询正常；如果为非正数，则为异常。
所述步骤5的详细过程为：心跳发送时间更新为当前时间与心跳发送时间间隔×2之和，表明再经过更新后的心跳发送时间进行心跳发送轮询的异常检测。
所述步骤6的详细过程为：超时检测时间更新为当前时间与超时检测时间间隔×4之和，表明再经过更新后的超时检测时间进行超时检测轮询的异常检测。
本发明与现有技术相比所产生的有益效果是：
本发明的一种心跳模块自检测方法该心跳模块自检测方法应用于高可用集群，能够解决因轮询失效无法实时提供业务状态并及时进行业务报警的问题，解决了心跳发送异常问题；提高了节点和媒介状态检测的可靠性，及时发现故障，第一时间进行业务资源切换。
附图说明
附图1是本发明的发送心跳流程示意图。
附图2是本发明的检测心跳超时流程示意图。
具体实施方式
下面结合附图对本发明的一种心跳模块自检测方法作以下详细说明。
一种心跳模块自检测方法，其具体检测步骤包括两个流程的互检：发送心跳流程和检测心跳超时流程，这两个流程都是通过main event loop机制实现的。发送心跳流程以心跳时间间隔为频率定时发送，如果该流程轮询失效，集群中所有节点将收不到该节点的消息，误判该节点为死亡节点。检测心跳超时流程，用于检查某个节点或某个心跳媒介是否出现故障，进行业务报警，如果该轮询失效，则无法通知集群故障，集群将不可操作。检测心跳超时流程的执行频率要大于发送心跳流程，以便及时发现故障，第一时间进行业务资源切换，保证集群业务高可用。
附图1是应用于高可用集群系统中心跳模块的发送心跳流程图，下面对各个步骤进行详细描述。
步骤101：获取系统自开机以来的当前时间，单位为毫秒。
步骤201：检测心跳超时检测流程是否正确：通过比较心跳超时时间与当前时间差值，如果非正，表明心跳超时检测轮询异常，执行步骤301；否则正常，执行步骤601。
步骤301：移除心跳超时检测轮询。
步骤401：根据心跳超时检测时间间隔添加新的超时检测轮询。
步骤501：超时检测时间更新，更新为当前时间与超时检测时间间隔×4之和，这里的×4是个经验值。表明再经过更新后的超时检测时间进行超时检测轮询的异常检测。
步骤601：心跳发送时间更新，更新为当前时间与心跳发送时间间隔×2之和，这里的×2是个经验值。表明再经过更新后的心跳发送时间进行心跳发送轮询的异常检测。
步骤701：创建心跳信息并放到发送队列里等待发送。
附图2是应用于高可用集群系统中心跳模块的检测心跳超时流程图，下面对该流程各个步骤进行详细描述。
步骤101：获取系统自开机以来的当前时间，单位为毫秒。
步骤201：检测发送心跳流程是否正确：通过比较心跳发送时间与当前时间差值，如果非正，表明心跳发送轮询异常，执行步骤301；否则正常，执行步骤601。
步骤301：移除心跳定时发送轮询。
步骤401：根据心跳发送时间间隔添加新的心跳发送轮询。
步骤501：心跳发送时间更新，更新为当前时间与心跳发送时间间隔×2之和，这里的×2是个经验值。表明再经过更新后的心跳发送时间进行心跳发送轮询的异常检测。
步骤601：超时检测时间更新，更新为当前时间与超时检测时间间隔×4之和，这里的×4是个经验值。表明再经过更新后的超时检测时间进行超时检测轮询的异常检测。
步骤701：继续进行节点状态检测和心跳媒介的检测，并将检测结果反馈集群各节点。
通过发送心跳流程和检测心跳超时流程对两个轮询进行互检，当某个轮询出现异常时，将重新启动该轮询，并更新下一次异常检测时间，从而实现了心跳模块的自检测方法。
至此，已经完整实现了心跳模块自检测方法，该方法与传统的集群心跳模块管理方法相比，增加了自检测流程，对两个重要的轮询：心跳发送轮询和心跳超时检测轮询添加互检机制，保证在消息量大，传输速率快的情况下，心跳模块的可用性、可靠性和稳定性，从而为集群的高可用提供有利保障。
除说明书所述的技术特征外，均为本专业技术人员的公知技术。
Claims (1)
1.一种心跳模块自检测方法，其特征在于：其具体检测步骤包括：
发送心跳流程：发送心跳流程以心跳时间间隔为频率定时发送；
检测心跳超时流程：用于检查某个节点或某个心跳媒介是否出现故障，进行业务报警；
所述检测心跳超时流程的执行频率大于发送心跳流程的执行频率，且这两个流程对两个轮询进行互检，当某个轮询出现异常时，将重新启动该轮询，并更新下一次异常检测时间，所述两个流程应用于高可用集群中；
所述发送心跳流程的详细步骤为：
步骤101：获取系统自开机以来的当前时间，单位为毫秒；
步骤201：检测心跳超时检测流程是否正确：通过比较心跳超时时间与当前时间差值，如果非正，表明心跳超时检测轮询异常，执行步骤301；否则正常，执行步骤601；
步骤301：移除心跳超时检测轮询；
步骤401：根据心跳超时检测时间间隔添加新的超时检测轮询；
步骤501：超时检测时间更新，更新为当前时间与超时检测时间间隔×4之和，这里的×4是个经验值；表明再经过更新后的超时检测时间进行超时检测轮询的异常检测；
步骤601：心跳发送时间更新，更新为当前时间与心跳发送时间间隔×2之和，这里的×2是个经验值；表明再经过更新后的心跳发送时间进行心跳发送轮询的异常检测；
步骤701：创建心跳信息并放到发送队列里等待发送；
所述检测心跳超时流程的详细步骤为：
步骤102：获取系统自开机以来的当前时间，单位为毫秒；
步骤202：检测发送心跳流程是否正确：通过比较心跳发送时间与当前时间差值，如果非正，表明心跳发送轮询异常，执行步骤302；否则正常，执行步骤602；
步骤302：移除心跳定时发送轮询；
步骤402：根据心跳发送时间间隔添加新的心跳发送轮询；
步骤502：心跳发送时间更新，更新为当前时间与心跳发送时间间隔×2之和，这里的×2是个经验值；表明再经过更新后的心跳发送时间进行心跳发送轮询的异常检测；
步骤602：超时检测时间更新，更新为当前时间与超时检测时间间隔×4之和，这里的×4是个经验值；表明再经过更新后的超时检测时间进行超时检测轮询的异常检测；
步骤702：继续进行节点状态检测和心跳媒介的检测，并将检测结果反馈集群各节点。
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201310028990.5A CN103067209B (zh) | 2013-01-25 | 2013-01-25 | 一种心跳模块自检测方法 |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN201310028990.5A CN103067209B (zh) | 2013-01-25 | 2013-01-25 | 一种心跳模块自检测方法 |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN103067209A CN103067209A (zh) | 2013-04-24 |
| CN103067209B true CN103067209B (zh) | 2017-09-15 |
Family
ID=48109679
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN201310028990.5A Active CN103067209B (zh) | 2013-01-25 | 2013-01-25 | 一种心跳模块自检测方法 |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN103067209B (zh) |
Families Citing this family (8)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN103516556A (zh) * | 2013-10-23 | 2014-01-15 | 北京国双科技有限公司 | 分布式系统及其控制方法和装置 |
| CN105703940B (zh) * | 2015-12-10 | 2021-08-20 | 中国电力科学研究院有限公司 | 一种面向多级调度分布式并行计算的监控系统及监控方法 |
| CN105553760B (zh) * | 2015-12-11 | 2019-03-22 | 中国科学院信息工程研究所 | 一种基于心跳的软件模块故障处理方法及系统 |
| CN105656996B (zh) * | 2015-12-25 | 2019-03-01 | 北京奇虎科技有限公司 | 数据节点存活的检测方法及装置 |
| CN106961364A (zh) * | 2017-04-24 | 2017-07-18 | 努比亚技术有限公司 | 心跳检测方法及应用服务器 |
| CN109391495A (zh) * | 2017-08-10 | 2019-02-26 | 阿里巴巴集团控股有限公司 | 发送及接收心跳消息的方法、装置、计算机可读介质及电子设备 |
| CN109992436A (zh) * | 2017-12-29 | 2019-07-09 | 华为技术有限公司 | 线程阻塞检测方法及设备 |
| CN112511368A (zh) * | 2020-10-16 | 2021-03-16 | 深圳市科漫达智能管理科技有限公司 | 一种服务心跳监控方法及相关装置 |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102118309A (zh) * | 2010-12-31 | 2011-07-06 | 中国科学院计算技术研究所 | 一种双机热备份方法及系统 |
| CN102810073A (zh) * | 2012-06-13 | 2012-12-05 | 天津大学 | 数据后台实时监控处理方法 |
Family Cites Families (1)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN101645983A (zh) * | 2008-08-08 | 2010-02-10 | 鸿富锦精密工业（深圳）有限公司 | 网络管理系统及使用其测试网络设备的方法 |
-
2013
- 2013-01-25 CN CN201310028990.5A patent/CN103067209B/zh active Active
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102118309A (zh) * | 2010-12-31 | 2011-07-06 | 中国科学院计算技术研究所 | 一种双机热备份方法及系统 |
| CN102810073A (zh) * | 2012-06-13 | 2012-12-05 | 天津大学 | 数据后台实时监控处理方法 |
Also Published As
| Publication number | Publication date |
|---|---|
| CN103067209A (zh) | 2013-04-24 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN103067209B (zh) | 一种心跳模块自检测方法 | |
| Oliner et al. | What supercomputers say: A study of five system logs | |
| CN110716842B (zh) | 集群故障检测方法和装置 | |
| CN107995049B (zh) | 电力安全区跨区同步故障监测方法、装置和系统 | |
| CN102231681B (zh) | 一种高可用集群计算机系统及其故障处理方法 | |
| CN104268061B (zh) | 一种适用于虚拟机的存储状态监控方法 | |
| CN104022904B (zh) | 分布式机房it设备统一管理平台 | |
| CN111953566B (zh) | 一种基于分布式故障监控的方法和虚拟机高可用系统 | |
| WO2016106965A1 (zh) | 一种服务器自愈的方法和装置 | |
| EP3148116B1 (en) | Information system fault scenario information collection method and system | |
| CN104408071A (zh) | 一种基于集群管理器的分布式数据库高可用方法及系统 | |
| CN112073262B (zh) | 一种云平台监控方法、装置、设备及系统 | |
| WO2013071125A1 (en) | Systems and methods for automatic replacement and repair of communications network devices | |
| EP3142011A1 (en) | Anomaly recovery method for virtual machine in distributed environment | |
| CN110488701A (zh) | 基于国产化处理器的网络和FlexRay总线的高可用热备份方法 | |
| CN103607297A (zh) | 一种计算机集群系统的故障处理方法 | |
| CN104320311A (zh) | 一种scada分布式平台下的心跳检测方法 | |
| CN110134518A (zh) | 一种提高大数据集群多节点应用高可用性的方法及系统 | |
| CN101631048A (zh) | 一种监视被管理对象的方法、装置及系统 | |
| CN110784352B (zh) | 一种基于Oracle Goldengate的数据同步监控告警方法及装置 | |
| CN108469996A (zh) | 一种基于自动快照的系统高可用方法 | |
| CN102404386A (zh) | 一种保证分布式文件系统元数据服务器组的服务高可靠的方法 | |
| CN103428033A (zh) | 一种刀片服务器管理网络主动式检测方法 | |
| CN105068763A (zh) | 一种针对存储故障的虚拟机容错系统和方法 | |
| CN107071189B (zh) | 一种通讯设备物理接口的连接方法 |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| C06 | Publication | ||
| PB01 | Publication | ||
| C10 | Entry into substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant | ||
| TR01 | Transfer of patent right | ||
| TR01 | Transfer of patent right |
Effective date of registration: 20180816 Address after: 250101 S06 tower, 1036, Chao Lu Road, hi tech Zone, Ji'nan, Shandong. Patentee after: SHANDONG LANGCHAO YUNTOU INFORMATION TECHNOLOGY Co.,Ltd. Address before: 250014 1036 Shun Ya Road, hi tech Zone, Ji'nan, Shandong. Patentee before: INSPUR ELECTRONIC INFORMATION INDUSTRY Co.,Ltd. |
|
| CP03 | Change of name, title or address | ||
| CP03 | Change of name, title or address |
Address after: 250100 No. 1036 Tidal Road, Jinan High-tech Zone, Shandong Province, S01 Building, Tidal Science Park Patentee after: Inspur cloud Information Technology Co.,Ltd. Address before: 250101 S06 tower, 1036, Chao Lu Road, hi tech Zone, Ji'nan, Shandong. Patentee before: SHANDONG LANGCHAO YUNTOU INFORMATION TECHNOLOGY Co.,Ltd. |
|
| TR01 | Transfer of patent right | ||
| TR01 | Transfer of patent right |
Effective date of registration: 20221013 Address after: 046000 Floor 5, Changzhi Municipal Government Affairs Hall, No. 406, Taihang West Street, Changzhi, Shanxi Patentee after: Changzhi Langchao Yunhaiyun Computing Technology Co.,Ltd. Address before: 250100 No. 1036 Tidal Road, Jinan High-tech Zone, Shandong Province, S01 Building, Tidal Science Park Patentee before: Inspur cloud Information Technology Co.,Ltd. |