当前位置：首页 > news >正文

CAN多节点通信实战：基于系统RTC及系统时钟Tick的心跳风暴抑制方案

news 2026/5/12 7:55:59

方案定义

本方案采用两级时基：

系统RTC：用于计算统一周期起点periodStart
系统时钟Tick：用于保证发送窗口精度

本方案支持两种通信模式：

主从通信：由 Master 周期发布系统 RTC
对等通信：由1号节点周期发布系统 RTC

系统 RTC 发布节点只负责授时，不直接参与其他节点的心跳调度计算。

全局参数

Thb：节点心跳周期
N：系统容量
NodeId：节点号
rtcNow：当前节点本地 RTC 时间
localTickNow：当前节点本地系统 Tick

当前参数示例：

Thb = 30s
N = 200
系统 RTC 发布周期 = 10分钟
本地 Tick 精度 = 10ms

系统RTC来源

主从通信模式

系统 RTC 由 Master 周期发布。
Slave 接收后同步本地 RTC。

对等通信模式

系统 RTC 由1号节点周期发布，其他节点接收后同步本地 RTC。
对等通信模式下，1号节点发送,所有节点仍按统一规则计算心跳周期与发送窗口。

周期起点计算

当前心跳周期起点由节点本地 RTC 直接计算：

periodStart=(rtcNow/Thb)*Thb;

其中：

rtcNow为以秒为单位的系统时间戳
Thb为以秒为单位的心跳周期

示例：

rtcNow=1719833725;Thb=30;periodStart=(1719833725/30)*30=1719833710;

所有节点只要 RTC 已同步到同一系统时间基准，计算得到的periodStart就一致。

发送窗口计算

每个节点固定映射到一个发送窗口：

windowSize=Thb/N;sendOffset=(NodeId%N)*windowSize;

参数代入：

windowSize=30000ms/200=150ms;

即在每个 30 秒周期内，200 个节点均匀分散到 200 个发送窗口中。

本地Tick映射

在轮询中根据当前 RTC 计算当前周期起点：

periodStartRtc=(rtcNowSec/T_hbSec)*T_hbSec;

若检测到进入新周期，则记录当前本地 Tick：

periodStartTick=localTickNow;

该值表示当前周期起点在本地 Tick 时间轴上的映射时刻。

心跳发送规则

本节点发送偏移为：

sendOffset=(NodeId%N)*windowSize;sendTick=periodStartTick+sendOffset;

发送条件：

if(!sentFlag&&localTickNow>=sendTick){send_heartbeat();sentFlag=1;}

每个周期只发送一次心跳。
进入新周期后清除sentFlag。

RTC同步规则

系统 RTC 发布节点周期发送 RTC 同步报文。
节点收到后执行本地 RTC 同步。

RTC 同步报文只用于：

更新本地 RTC

RTC 同步报文不用于：

不直接计算periodStart
不直接修改发送窗口
不直接触发心跳发送

运行流程

1. 节点初始化

初始化上下文参数：

心跳周期Thb
系统容量N
节点号NodeId
本周期发送标志sentFlag

2. 系统RTC同步

系统 RTC 发布节点周期发送 RTC 同步报文, 其他节点接收后同步本地 RTC。

3. 周期轮询

节点周期调用轮询函数，输入：

当前 RTC
当前本地 Tick

4. 计算周期起点

根据当前 RTC 计算：

periodStartRtc=(rtcNowSec/T_hbSec)*T_hbSec;

5. 新周期处理

若periodStartRtc发生变化：

更新记录的周期起点
保存新的periodStartTick
清除sentFlag

6. 发送判定

根据节点号计算发送偏移与发送时刻，满足条件后发送一次心跳。

参考实现

#include<stdint.h>typedefstruct{uint32_tlastPeriodStartRtc;// 当前周期起点，单位：秒uint32_tperiodStartTick;// 当前周期起点对应的本地Tick，单位：msuint32_twindowSizeMs;// 窗口宽度，单位：msuint32_tperiodSec;// 心跳周期，单位：秒uint16_tnodeId;uint16_tnodeCount;uint8_tsentFlag;}HeartbeatCtx;voidheartbeat_init(HeartbeatCtx*ctx,uint16_tnodeId,uint16_tnodeCount,uint32_tperiodSec){ctx->lastPeriodStartRtc=0;ctx->periodStartTick=0;ctx->windowSizeMs=(periodSec*1000)/nodeCount;ctx->periodSec=periodSec;ctx->nodeId=nodeId;ctx->nodeCount=nodeCount;ctx->sentFlag=0;}voidheartbeat_poll(HeartbeatCtx*ctx,uint32_trtcNowSec,uint32_tlocalTickNow){uint32_tperiodStartRtc=(rtcNowSec/ctx->periodSec)*ctx->periodSec;if(periodStartRtc!=ctx->lastPeriodStartRtc){ctx->lastPeriodStartRtc=periodStartRtc;ctx->periodStartTick=localTickNow;ctx->sentFlag=0;}uint32_tsendOffset=(uint32_t)(ctx->nodeId%ctx->nodeCount)*ctx->windowSizeMs;uint32_tsendTick=ctx->periodStartTick+sendOffset;if(!ctx->sentFlag&&localTickNow>=sendTick){send_heartbeat();ctx->sentFlag=1;}}