构建高并发无返回值事件监听器的关键是轻量、单向、专注投递：选用http webhook（204/202）、kafka/rabbitmq fanout exchange（acks=0）、udp日志通道；事件结构去语义化，仅保留id/type/timestamp/source四字段，业务载荷透传；监听器为无状态投递函数，fire后立即返回；错误静默捕获并结构化留痕。
要构建一个纯粹、无返回值、能扛住高并发的事件监听器，关键不是让它“更聪明”，而是让它“更轻、更哑、更专注”——只管发，不等回音，不记结果，不拦错误。
选对通道：用高并发友好的单向传输层
同步阻塞式通信（如带响应体的 HTTP POST、RPC 调用）天然不适合。应优先选用以下三类已验证的高吞吐通道：
- HTTP Webhook（204/202 状态码）：服务端收到事件后立即返回 204 No Content 或 202 Accepted，不解析 body，不写主库，仅记录投递日志；适合对接外部系统，部署简单
- Kafka / RabbitMQ Fanout Exchange：生产者调用 send() 后即返回，设 acks=0（Kafka）或 confirm=false（RabbitMQ），完全解耦上下游；适合内部服务间广播，吞吐稳定
- UDP 日志通道：用 socket.sendto() 发送 JSON 行格式事件，无连接、无重试、无确认；适合埋点、快照类场景，百万级 QPS 下延迟低于 100μs
事件结构：零解析、零转换、零业务侵入
监听器不是业务处理器，它只是“管道”。因此事件体必须去语义化：
Toingg Ops Toolkit
下载
一款AI音频处理工具，主要用于通过向 `toingg/make_campaign` API 发送 POST 请求，提交用户提供的 JSON 数据，创建并启动 Toingg 语音呼叫活动，适用于 Codex 将活动简报……，适合需要提升相关任务效率的用户。
- 元数据仅保留四个字段：id（UUID）、type（字符串枚举，如 "user.login"）、timestamp（ISO8601）、source（服务名）
- 业务载荷以原始字节或 Base64 编码字符串透传，监听器不做 JSON.parse()、字段校验、类型映射
- 禁止携带 callback_url、signature、tx_id、retry_count 等诱导同步行为的字段
监听器实现：无状态、无注册、无生命周期依赖
它不该是一个“组件”，而应是一个封闭的投递函数或轻量对象：
- 构造时只接收通道配置（如 Kafka topic、Webhook URL、UDP 地址），不维护 listener 列表、不暴露 on()/off() 方法
- 提供唯一方法 fire(event: bytes) → None，内部调用底层 API 后立刻返回，不返回 Future、Promise、Task 等可 await 对象
- 不依赖 Spring @EventListener、Laravel EventServiceProvider 等框架机制；上游服务 new 一个实例，直接 fire 即可
错误与可观测性：静默降级 + 结构化留痕
既然是“无返回值”，就绝不把错误抛给调用方，也不尝试修复：
- 所有异常（序列化失败、DNS 解析超时、connect refused、send buffer full）在 fire 内部捕获
- 仅写入结构化日志：含 event.id、channel.type、error.code、timestamp，便于聚合分析投递成功率
- 不重试、不进死信队列、不触发告警——这些是下游系统的责任；本层只保证“发出即结束”
