SpringBoot 地铁 ISCS 实战第十五篇：三级告警体系实战｜告警分级收敛、联动抑制、故障闭锁与消息推送落地

标签：# 工控开发 #地铁 ISCS #告警系统 #轨道交通综合监控 #Java 工控
摘要：
地铁全自动 ISCS 综合监控系统存在上万测点并发变位场景，现场电磁干扰、网络瞬时抖动极易爆发海量风暴告警，若无分级、收敛、抑制机制，一级行车高危故障会被大量无效提示告警完全淹没，严重干扰调度处置。本文承接前十四篇 OPC UA 采集、Kafka 消息中台、场景联动引擎、数字孪生大屏、TDengine 时序存储整套完整架构，独立搭建标准化三级告警核心服务；划分一 / 二 / 三级故障优先级规范，落地测点防抖收敛、短时重复告警合并、联动动作闭锁抑制、故障自动复归全套业务逻辑；新增第五组独立 Kafka 告警消费组，实现多渠道消息分发，支持大屏弹窗声光提醒、站内运维消息推送，告警全生命周期数据持久化存储，可联动时序库调取故障前后工况曲线用于复盘。方案彻底解决工控现场告警风暴、干扰无效告警泛滥、根因故障难以识别、告警无留存无法验收等工程痛点，所有代码、业务规则完全贴合 GoA4 全自动无人驾驶线路运维调度规范。

一、前言

前十四篇连载已经搭建完成地铁全自动 ISCS 全链路基础底座：现场设备 OPC UA 统一采集、上位智能采集器预处理降噪、Kafka 分区消息统一分发，拆分四组隔离消费组分别支撑自动化场景联动、数字孪生大屏可视化、TDengine 时序历史归档、基础报表统计，实时监控、历史数据存储、大屏可视化能力全部落地。
项目现场联调、上线运维阶段，缺少独立告警管控服务暴露大量硬性业务缺陷，直接影响业主验收与日常行车调度：
电缆电磁干扰、网关瞬时断网会产生大量测点短时跳变，海量无效告警刷屏大屏，火灾、站台门、供电短路等一级高危故障被淹没，调度无法第一时间识别；
同一风机、开关柜设备短时间内反复变位，重复告警持续推送，加重 WebSocket、数据库、服务器整体负载；
执行自动化联动场景后会衍生大量附属设备告警，无闭锁抑制逻辑，无法区分根因故障与次生故障，故障复盘难度极大；
告警仅临时在大屏弹窗展示，无完整生命周期持久化记录，月度设备故障统计、事故复盘、项目监理验收缺少完整数据源；
未划分告警优先级，设备轻微参数偏移提示与影响行车安全的紧急故障弹窗样式、推送渠道完全一致，调度无法快速分级处置。
针对轨道交通调度运维核心刚需，本篇独立开发告警核心处理服务，新增第五路专属 Kafka 消费组，全程不改动采集层、联动引擎、大屏、时序库任意存量业务代码，完整实现告警分级、防抖收敛、重复合并、联动闭锁、多端推送、全量归档一体化能力，补齐 ISCS 告警管控核心模块。

二、全局完整五消费组隔离架构（最终定型生产架构）

现场底层硬件设备 → 各专业 OPC UA 边缘网关 → 上位智能采集器 → Kafka 统一主题 iscs_point_real_data
Scene-Engine-Group：场景联动引擎，负责自动化场景触发、跨子系统设备指令下发
Screen-BigData-Group：数字孪生大屏服务，WebSocket 实时推送全站设备实时工况
Td-Soe-Group：TDengine 时序归档服务，海量测点时序持久化、历史曲线查询支撑
Alarm-Core-Group：告警核心服务（本篇核心），告警过滤、分级、收敛、存储、多渠道推送
Report-Task-Group：运维定时报表服务，设备故障统计、月度运行报告生成
五组消费组各自维护独立 Offset，业务流量物理完全隔离。即便出现大规模告警风暴，也只会占用告警服务资源，不会阻塞场景联动引擎这类影响行车安全的核心业务，满足 GoA4 无人驾驶高可靠运行硬性标准。

三、地铁 ISCS 三级告警行业业务规范

3.1 告警优先级分级定义

一级告警（紧急，等级 1）
触发场景：车站火灾、站台门无法关闭、供电母线短路、区间设备故障，直接影响行车、乘客安全。
展示策略：大屏红色全屏闪烁弹窗、声光蜂鸣报警、运维人员站内消息强制推送、留存最高优先级置顶。
二级告警（重要，等级 2）
触发场景：环控风机水泵故障、开关柜过载、OPC UA 网关离线、设备温湿度严重超限。
展示策略：橙色弹窗固定置顶展示，无声光蜂鸣，大屏告警栏靠前滚动。
三级告警（提示，等级 3）
触发场景：设备参数轻微偏移、阈值临近预警、非关键辅助设备离线。
展示策略：灰色小字底部滚动提示，不弹窗、不推送消息，仅做记录留存。

3.2 告警完整生命周期状态

0 未确认：故障刚触发，未被运维人员手动确认
1 已确认：运维查看告警并手动确认故障存在
2 已复归：测点数值恢复正常，故障自动消除，完整归档留存

四、核心告警业务处理规则落地

告警防抖收敛过滤
全局统一防抖时间窗口，瞬时 1.5 秒内的测点跳变直接丢弃，不生成告警记录，过滤电磁、网络瞬时干扰。防抖时长支持页面动态配置，无需重启服务。
短时重复告警合并
同一测点 5 分钟内多次触发故障，仅首次完整推送弹窗，后续仅累加合并计数，避免重复刷屏，减少服务 IO 与前端渲染压力。
联动动作闭锁抑制机制
场景联动引擎执行自动化处置动作后，自动标记对应站点、子系统，短时间内屏蔽该区域衍生次生告警，仅保留原始根因故障，简化故障排查。
故障自动复归逻辑
故障测点恢复至正常阈值区间，自动生成复归事件，更新数据库告警状态为 “已复归”，同步推送复归提示至大屏。
分级差异化多渠道分发
一级告警全渠道推送；二、三级告警仅本地大屏展示，无额外消息推送，降低运维信息干扰。

五、MySQL 告警存储库表设计

告警全生命周期数据持久化至业务 MySQL，支撑运维查询、故障统计、项目验收复盘，完整建表语句：
sql

CREATETABLEiscs_alarm_record(idBIGINTAUTO_INCREMENTPRIMARYKEYCOMMENT'自增主键',line_idVARCHAR(32)NOTNULLCOMMENT'线路标识',station_idVARCHAR(32)NOTNULLCOMMENT'车站标识',system_typeVARCHAR(20)NOTNULLCOMMENT'子系统类型 BAS/PSCADA/FAS/PSD',point_idVARCHAR(40)NOTNULLCOMMENT'全局唯一测点ID',point_nameVARCHAR(64)NOTNULLCOMMENT'测点中文名称',alarm_levelTINYINTNOTNULLCOMMENT'告警等级 1紧急 2重要 3提示',alarm_descVARCHAR(128)NOTNULLCOMMENT'告警文字描述',alarm_timeDATETIME(3)NOTNULLCOMMENT'故障触发精确毫秒时间',confirm_timeDATETIME(3)NULLCOMMENT'运维确认时间',restore_timeDATETIME(3)NULLCOMMENT'故障复归恢复时间',alarm_statusTINYINTNOTNULLDEFAULT0COMMENT'0未确认 1已确认 2已复归',merge_countINTDEFAULT1COMMENT'重复告警合并累计次数',create_tsBIGINTNOTNULLCOMMENT'时间戳，用于快速分页查询',INDEXidx_line_station(line_id,station_id),INDEXidx_alarm_time(alarm_time),INDEXidx_point_id(point_id))ENGINE=InnoDBDEFAULTCHARSET=utf8mb4COMMENT'ISCS全站告警记录表';

六、项目 YAML 配置（Kafka 告警消费组 + 告警业务参数）

yaml

spring:# 告警专属Kafka消费配置kafka:consumer:group-id:iscs-alarm-core-groupbootstrap-servers:127.0.0.1:9092max-poll-records:200auto-offset-reset:earliestenable-auto-commit:falsetopic:iscs_point_real_data

ISCS告警自定义业务参数

iscs:alarm:# 开关量防抖过滤毫秒时长debounce-ms:1500# 重复告警合并时间窗口，单位分钟merge-window-min:5# 联动闭锁抑制时长，单位秒link-suppress-second:30

七、告警系统完整核心业务代码

7.1 告警输出推送实体（WebSocket 大屏使用）