中台事件驱动异步消息结构规范

中台事件驱动异步消息结构规范一、总则规范（一）适用范围。本规范适用于公司中台架构下所有事件驱动异步消息的设计、开发、传输及处理环节，涵盖业务系统间数据交互、服务调用、状态变更等场景。（二）核心原则。消息结构必须遵循标准化、解耦化、可扩展、高可靠原则，确保跨系统通信的统一性与稳定性。（三）管理责任。中台技术委员会负责本规范的制定与修订，各业务部门需指定专人对消息结构实施进行监督，运维团队负责日常结构校验与异常监控。二、消息结构要素（一）基础框架。消息体必须包含以下核心字段：消息头（Header）、消息体（Payload）、消息签名（Signature）、时间戳（Timestamp），各部分需按固定顺序排列。（二）字段规范。1.消息头必须包含：消息类型（Type）、来源系统（Source）、目标系统（Destination）、消息ID（MessageID）、优先级（Priority）、版本号（Version），字段间使用JSON格式封装。2.消息体根据业务场景定义，但必须包含业务主键（BusinessKey）、操作类型（ActionType）、状态码（StatusCode）三要素。3.消息签名采用SHA256算法，以Base64格式存储，用于校验消息完整性。（三）编码标准。所有文本字段统一采用UTF-8编码，二进制数据需进行Base64编码，确保跨平台兼容性。三、消息类型划分（一）事件通知类。适用于业务状态变更的被动式消息推送，如订单支付成功、库存不足告警等。结构要求包含：事件名称（EventName）、触发时间（TriggerTime）、影响范围（AffectedScope）。（二）指令调用类。适用于系统间主动式服务请求，如订单创建请求、库存扣减指令等。结构要求包含：服务名称（ServiceName）、请求参数（RequestParam）、超时时间（Timeout）。（三）批量处理类。适用于高频批量数据的传输场景，如每日结算数据、周期性报表生成等。结构要求包含：批次ID（BatchID）、记录总数（RecordCount）、单条数据分隔符（Delimiter）。四、消息传输协议（一）传输方式。优先采用AMQP协议进行点对点传输，对实时性要求不高的场景可使用HTTP/2协议。传输过程中必须启用TLS1.2加密，确保数据机密性。（二）重传机制。消息传输失败时，接收方需在5秒内发起重传请求，重传次数上限为3次，每次间隔需递增（初始值1秒，最大值60秒）。（三）流量控制。单个系统接口单位时间（1分钟）内消息接收上限为100万条，超出需触发限流降级策略，优先保障核心业务消息优先级。五、错误处理规范（一）异常分类。消息错误分为：解析失败（ParseError）、校验失败（ValidateError）、处理超时（TimeoutError）、网络中断（NetworkError）四类。（二）错误响应。接收方收到异常消息时，需在消息头中标注错误类型，并在消息体中记录详细异常信息，同时向中台监控平台推送告警。（三）恢复流程。1.解析错误需立即中断当前处理流程，记录完整消息后暂停接收。2.校验失败需将消息暂存至死信队列，由运维人员人工审核。3.超时错误需触发重试机制，连续3次超时后执行降级预案。六、实施要求（一）开发规范。1.消息生产方必须实现消息格式校验器，对输出消息进行严格校验。2.消息消费方需实现幂等性设计，防止重复处理导致数据异常。3.所有接口需提供结构化文档，包含字段说明、示例数据、错误码说明。（二）版本管理。1.消息结构变更必须遵循"渐进式演进"原则，新增字段需添加默认值，旧版本系统需兼容处理。2.版本升级需经过中台技术委员会审批，发布周期不得少于2周。（三）测试要求。1.新接口上线前必须完成压力测试，消息吞吐量需达到设计上限的1.5倍。2.需模拟异常场景进行测试，包括网络中断、服务宕机、数据异常等。七、运维监控（一）监控指标。1.消息延迟率：核心消息处理延迟不得超过500毫秒，延迟率控制在5%以内。2.消息丢失率：系统级消息丢失率不得高于0.01%，业务级需根据重要性分级监控。3.资源占用率：消息队列内存占用率控制在70%以下，CPU使用率控制在30%以下。（二）监控工具。1.部署消息质量监控系统，实时采集延迟、错误、吞吐量等指标。2.设置自动告警阈值，延迟超过阈值时触发短信、邮件、钉钉等多渠道通知。3.建立消息溯源系统，支持通过MessageID查询完整传输链路。（三）应急预案。1.当消息队列积压超过阈值时，需自动触发削峰策略，包括降级非核心服务、增加临时处理节点。2.系统宕机时需实现消息热备份，确保业务连续性。3.每月组织一次应急演练，验证预案有效性。八、附则说明（一）文档更新。本规范由中台技术委员会负责维护，每年至少更新一次，重大变更需发布版本公告。（二）培训要求。所有涉及消息交互的开发人员必须通过