企业级异步事件监听器应为无返回值、单向投递的纯对象:使用不可变事件对象承载元数据,监听器仅封装通道配置与fire方法,内部处理异常并记录日志,不重试、不阻塞、不依赖框架。

要构建一个纯粹、无返回值、企业级的异步事件监听器,核心不是“等结果”,而是“发即走”——事件触发后立即投递、不阻塞、不等待响应、不关心下游是否处理成功。它本质上是一个单向、解耦、高吞吐的对象封装通道,关键在于用对象边界隔离状态与副作用,而非依赖框架生命周期或注册机制。
用不可变事件对象承载元数据
事件本身必须是轻量、不可变、零业务解析的载体:
- 定义纯数据类(如 Java 的 record、Kotlin 的 data class 或 Python 的 @dataclass(frozen=True)),只含 id、type、timestamp、source 四个字段;
- 业务载荷以原始字节或 Base64 编码字符串形式透传,监听器不做 JSON 解析、字段校验或类型转换;
- 禁止在事件对象中嵌入回调函数、Service 引用、事务上下文等可变或有副作用的成员。
监听器对象封装为无状态投递函数
监听器不应是“注册-触发”式的组件,而应是专注投递行为的封闭对象:
- 构造时仅接收通道配置(如 Kafka topic 名、Webhook URL、UDP 地址),不持有 listener 列表、不管理订阅关系;
- 提供单一 fire(event: Event) 方法,内部调用底层通道 API(如 producer.send()、http.post()、socket.sendto())后立即返回;
- 方法签名严格为 void / None,不返回 Future、CompletableFuture 或任何可 await 对象;不暴露 cancel、retry、awaitAck 等接口。
通道实现与错误策略内聚于对象内部
网络通道选择和错误处理逻辑应被封装进监听器对象,对外完全透明:
- 根据场景内置一种通道:HTTP webhook(返回 204)、Kafka(acks=0)、UDP(无连接);不支持运行时切换或混合通道;
- 所有异常(序列化失败、网络超时、连接拒绝)在 fire 方法内捕获,仅写入结构化日志(含 event.id、channel、error.code),不抛出、不重试、不告警;
- 不维护重试队列、死信缓冲区或投递确认状态——这些属于下游系统职责,本对象只保证“发出即结束”。
使用时零注册、零代理、零 Spring 依赖
该监听器对象不参与任何容器生命周期管理,调用方直接 new 或 DI 注入后使用:
- 上游服务只需 new WebhookEventFire("https://hooks.example.com/events"),然后 fire(event);
- 不需 @EventListener、@Async、ApplicationEventPublisher 等 Spring 机制;也不依赖 ApplicationContext;
- 若需多通道分发(如同时发 Kafka 和 UDP),由外部组合多个独立监听器对象,而非让单个监听器承担路由逻辑。











