springboot中用consumer实现aop日志拦截，核心是解耦采集与落地：切面专注构建含traceid、method、costms、success等字段的结构化logrecord，由外部consumer决定打印、入库或发kafka，提升可读性、可测性与扩展性。
在 SpringBoot 中，用切面（AOP）拦截接口并记录流水日志时，若想灵活、解耦地提取和处理日志内容（比如方法名、参数、耗时、异常、traceId 等），Consumer<logrecord></logrecord> 是一种轻量又实用的设计方式——它把“日志数据的构建”和“日志的落地行为”分离，让切面专注采集，由外部决定怎么消费（打印、入库、发 Kafka、推 ELK）。
下面直接说实战要点，不绕弯：
为什么用 Consumer 而不是直接 log.info？
硬编码 log.info(...) 会导致日志格式、敏感字段脱敏、异步写入、采样开关等逻辑全耦合在切面里，后期改起来费劲。用 Consumer<logrecord></logrecord> 把日志对象交给外部处理，切面只负责“造出干净、结构化的 LogRecord”，可读性高、测试友好、扩展性强。
定义一个轻量日志载体 LogRecord
不用引入复杂框架，自己建个 POJO 即可：
public class LogRecord {
private String traceId;
private String method; // 如 UserController.getUser
private String requestUrl;
private Map<string> params;
private Object result;
private long costMs;
private boolean success;
private String errorMsg;
private long timestamp = System.currentTimeMillis();
}</string>
字段按需增减，建议至少包含 traceId、method、costMs、success —— 这四个是定位问题的核心维度。
切面中用 Consumer 构建并传递 LogRecord
在 @Around 方法里，捕获执行前后状态，组装 LogRecord，最后交给 Consumer 处理：
- 用
RequestContextHolder提取当前请求 URL 和 header 中的 traceId（若已由网关透传） - 用
((MethodSignature) joinPoint.getSignature()).getMethod()获取真实 Method 对象，便于读注解或类名 - 参数过滤：跳过
HttpServletRequest、HttpServletResponse、MultipartFile等不可序列化对象 - 捕获异常后，设置
success = false并填充errorMsg，避免result为 null 导致 NPE - 别忘了用
System.nanoTime()替代System.currentTimeMillis()，精度更高、不受系统时间回拨影响
示例关键片段：
@Around("@annotation(org.springframework.web.bind.annotation.RequestMapping) || " +
"@annotation(org.springframework.web.bind.annotation.GetMapping) || " +
"@annotation(org.springframework.web.bind.annotation.PostMapping)")
public Object logWithConsumer(ProceedingJoinPoint joinPoint, Consumer<logrecord> logger) throws Throwable {
long start = System.nanoTime();
String traceId = MDC.get("traceId"); // 或从 request header 提取
String requestUrl = getCurrentRequestUrl();
String methodSig = joinPoint.getSignature().toShortString();try {
Object result = joinPoint.proceed();
long costMs = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start);
LogRecord record = new LogRecord()
.setTraceId(traceId)
.setMethod(methodSig)
.setRequestUrl(requestUrl)
.setParams(extractParams(joinPoint))
.setResult(result)
.setCostMs(costMs)
.setSuccess(true);
logger.accept(record); // ✅ 核心：交给外部消费
return result;
} catch (Exception e) {
long costMs = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - start);
LogRecord record = new LogRecord()
.setTraceId(traceId)
.setMethod(methodSig)
.setRequestUrl(requestUrl)
.setParams(extractParams(joinPoint))
.setErrorMsg(ExceptionUtils.getRootCauseMessage(e))
.setCostMs(costMs)
.setSuccess(false);
logger.accept(record);
throw e;
}}</logrecord>
如何注入和配置 Consumer 行为？
推荐两种常用方式：
-
方式一：通过 @Autowired 注入一个全局 Consumer Bean
比如定义
@Bean public Consumer<logrecord> consoleLogConsumer() { return r -> log.info("{}", r); }</logrecord>，再在切面中 autowire 它 -
方式二：通过 @Value 配置开关 + 条件装配
比如加个配置项
api.log.enabled=true，用@ConditionalOnProperty控制是否注册 consumer bean，避免上线后日志开销
进阶还可组合多个 Consumer：CompositeConsumer 包装控制台、DB、Kafka 多种落地方式，按需启用。
补充：实际落地前注意三点
— 参数脱敏：手机号、身份证、token 等字段，在 extractParams() 里统一正则替换，别等入库后再处理
— 日志采样：高频接口（如心跳、健康检查）可按 traceId 哈希做 1% 采样，避免日志爆炸
— 异常线程安全：Consumer 实现如果是异步写 DB 或发消息，确保内部有重试、降级、限流机制，别因日志失败拖垮主流程
