consumer 的 andthen 方法不直接支持流式日志链条，而是用于顺序串联多个无返回值的 consumer 实现分段审计日志处理。
Java 中 Consumer 的 andThen 方法本身**不直接支持流式日志链条的构建**，但它可以作为轻量级、无返回值的**串联执行工具**，配合业务逻辑和日志上下文，实现简洁可控的审计日志分段处理。关键在于：它不是为“流式”（如 Stream API）设计的，而是为 顺序执行多个 Consumer 服务的。
理解 andThen 的本质：串行消费，非响应式流
andThen 是 Consumer<t></t> 接口定义的默认方法，签名如下：
它返回一个新的 Consumer，先执行当前实例，再执行 after。整个过程同步、阻塞、无异常传播、不中断链路（除非抛出未捕获异常）。这决定了它适合做「确定性、低风险、顺序依赖」的日志增强操作，比如：
- 记录主操作前的参数快照
- 主操作后记录结果或耗时
- 异常发生时补充上下文（需配合 try-catch）
- 向不同输出目标（控制台、文件、MQ）分别写入同一事件
构建审计日志链条的典型模式
以一次用户转账为例，构建含「入参审计→执行→结果/异常审计→异步归档」的链条：
logInput()
.andThen(executeTransfer())
.andThen(logResultOrError())
.andThen(archiveAsync());
其中每个方法都返回 Consumer<transferevent></transferevent>。注意：executeTransfer() 不应是纯业务逻辑——它必须封装成一个接受 TransferEvent 并执行转账的 Consumer，同时把结果或异常存入事件对象中，供后续环节读取。
关键实践要点
-
事件对象需可变且承载上下文：定义类似
TransferEvent的 POJO，包含input、result、error、startTime、endTime等字段，所有 Consumer 共享同一实例 -
异常处理不能依赖 andThen 自动传递：andThen 遇到异常会中断后续执行。应在每个 Consumer 内部用 try-catch 捕获并记录，或统一在最外层包裹（如用
try { auditChain.accept(event); } catch (Exception e) { logFatal(e); }） - 避免副作用泄露：不要在某个 Consumer 中修改影响后续 Consumer 判断的共享状态（如清空 event.input），除非这是明确设计的流程契约
-
异步操作需谨慎：如
archiveAsync()应返回一个立即完成的 Consumer（例如提交到线程池后不 await），否则会阻塞主链；真正异步归档失败不应导致主业务回滚
对比更重的方案：何时该选其他方式？
如果需要错误恢复、背压控制、跨线程编排、条件分支（如「成功才记结果日志」）、或与 WebFlux/Reactor 集成，andThen 就力不从心了。此时应转向：
-
Stream.of(...).peek().forEach()：仅适用于一次性集合遍历，不适用于单事件多阶段 - 自定义责任链（Chain of Responsibility）：更灵活，支持跳过、中断、动态插拔
- Spring AOP + @AfterReturning/@AfterThrowing：适合横切审计，但侵入性低、上下文传递需靠 ThreadLocal
- 反应式框架（如 Project Reactor 的
doOnNext,doOnError）：真·流式、非阻塞、可组合
andThen 的价值在于简单、零依赖、易测试、无额外抽象——适合中小规模、强顺序、强调可读性的审计场景。
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
