Spring Boot 全局异常处理与日志监控实战
介绍基于 Spring Boot 的全局异常处理方案。通过 @RestControllerAdvice 统一错误响应格式,利用 MDC 和过滤器实现请求追踪(requestId),并结合 Actuator 与 Micrometer 将异常计数暴露为监控指标。内容涵盖项目依赖配置、自定义异常类、全局处理器实现、日志模式配置及常见场景建议,旨在提升生产环境的可观测性与排查效率。

介绍基于 Spring Boot 的全局异常处理方案。通过 @RestControllerAdvice 统一错误响应格式,利用 MDC 和过滤器实现请求追踪(requestId),并结合 Actuator 与 Micrometer 将异常计数暴露为监控指标。内容涵盖项目依赖配置、自定义异常类、全局处理器实现、日志模式配置及常见场景建议,旨在提升生产环境的可观测性与排查效率。

目标:构建一套健壮的全局异常处理方案,统一错误响应、可追踪的日志(requestId/MDC),并把异常上报为监控指标(使用 Micrometer),方便在生产环境定位与统计异常。
生产环境中,异常无处不在。我们要解决三件事:
requestId(MDC),便于从日志中串联一条请求的全部操作;@RestControllerAdvice + @ExceptionHandler 进行全局捕获;ErrorResponse(包含时间戳、HTTP 状态码、业务错误码、message、path、requestId);log.error(...) 并把异常计数交给 MeterRegistry(Micrometer);OncePerRequestFilter 在每个请求开始时生成 requestId 并放入 SLF4J 的 MDC(MDC.put("requestId", id));logback-spring.xml 把 %X{requestId} 输出到日志 pattern,建议也输出 JSON(视需求)。<!-- pom.xml 依赖片段 -->
<dependencies>
<!-- Spring Boot Starter Web -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- 日志 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-logging</artifactId>
</dependency>
<!-- Validation -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-validation</artifactId>
</dependency>
<!-- Actuator & Micrometer (Prometheus) -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>io.micrometer</groupId>
<artifactId>micrometer-registry-prometheus</artifactId>
</dependency>
</dependencies>
src/main/java/com/example/demo/api/ErrorResponse.java
package com.example.demo.api;
import java.time.Instant;
import java.util.Map;
public class ErrorResponse {
private Instant timestamp;
private int status;
private String error;
private String message;
private String path;
private String requestId;
private Map<String, Object> details; // 可选扩展字段
public ErrorResponse() {}
public ErrorResponse(int status, String error, String message, String path, String requestId) {
this.timestamp = Instant.now();
this.status = status;
this.error = error;
this.message = message;
this.path = path;
this.requestId = requestId;
}
// getters & setters omitted for brevity
}
src/main/java/com/example/demo/exception/BusinessException.java
package com.example.demo.exception;
public class BusinessException extends RuntimeException {
private final String code;
public BusinessException(String code, String message) {
super(message);
this.code = code;
}
public String getCode() {
return code;
}
}
src/main/java/com/example/demo/exception/GlobalExceptionHandler.java
package com.example.demo.exception;
import com.example.demo.api.ErrorResponse;
import io.micrometer.core.instrument.MeterRegistry;
import io.micrometer.core.instrument.Counter;
import jakarta.servlet.http.HttpServletRequest;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.slf4j.MDC;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.validation.FieldError;
import org.springframework.web.bind.MethodArgumentNotValidException;
import org.springframework.web.bind.annotation.ExceptionHandler;
import org.springframework.web.bind.annotation.RestControllerAdvice;
import java.util.stream.Collectors;
@RestControllerAdvice
public class GlobalExceptionHandler {
private static final Logger log = LoggerFactory.getLogger(GlobalExceptionHandler.class);
private final MeterRegistry meterRegistry;
// 一个简单的异常计数器前缀(可按异常 class、path、status 维度构造标签)
private final Counter genericExceptionCounter;
public GlobalExceptionHandler(MeterRegistry meterRegistry) {
this.meterRegistry = meterRegistry;
this.genericExceptionCounter = Counter.builder("exceptions.total")
.description("Total number of handled exceptions")
.register(meterRegistry);
}
// 业务异常处理
@ExceptionHandler(BusinessException.class)
public ResponseEntity<ErrorResponse> handleBusiness(BusinessException ex, HttpServletRequest request) {
String requestId = MDC.get("requestId");
log.warn("BusinessException - requestId={}, path={}, code={}, msg={}", requestId, request.getRequestURI(), ex.getCode(), ex.getMessage());
// 增加监控计数(按业务码)
meterRegistry.counter("exceptions.by_code", "code", ex.getCode()).increment();
ErrorResponse err = new ErrorResponse(HttpStatus.BAD_REQUEST.value(), "Business Error", ex.getMessage(), request.getRequestURI(), requestId);
return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(err);
}
// 参数校验异常
@ExceptionHandler(MethodArgumentNotValidException.class)
public ResponseEntity<ErrorResponse> handleValidation(MethodArgumentNotValidException ex, HttpServletRequest request) {
String requestId = MDC.get("requestId");
String msg = ex.getBindingResult().getFieldErrors().stream()
.map(fe -> fe.getField() + ":" + fe.getDefaultMessage())
.collect(Collectors.joining("; "));
log.info("Validation failed - requestId={}, path={}, errors={}", requestId, request.getRequestURI(), msg);
meterRegistry.counter("exceptions.validation").increment();
ErrorResponse err = new ErrorResponse(HttpStatus.BAD_REQUEST.value(), "Validation Error", msg, request.getRequestURI(), requestId);
return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(err);
}
// 通用异常处理
@ExceptionHandler(Exception.class)
public ResponseEntity<ErrorResponse> handleGeneric(Exception ex, HttpServletRequest request) {
String requestId = MDC.get("requestId");
log.error("Unhandled exception - requestId={}, path={}", requestId, request.getRequestURI(), ex);
// 总量计数
genericExceptionCounter.increment();
// 按异常类计数标签
meterRegistry.counter("exceptions.by_type", "type", ex.getClass().getSimpleName()).increment();
ErrorResponse err = new ErrorResponse(HttpStatus.INTERNAL_SERVER_ERROR.value(), "Internal Server Error", "服务器繁忙,请稍后重试", request.getRequestURI(), requestId);
// 在开发环境可以把 ex.getMessage() 或堆栈信息放到 details 中(生产环境慎用)
return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(err);
}
}
说明:
log 和 meterRegistry.counter(...).increment(),用于日志与监控;MDC.get("requestId") 用于把请求的 requestId 写入返回体,方便客户端带回查日志。src/main/java/com/example/demo/filter/RequestIdFilter.java
package com.example.demo.filter;
import jakarta.servlet.FilterChain;
import jakarta.servlet.ServletException;
import jakarta.servlet.http.HttpServletRequest;
import jakarta.servlet.http.HttpServletResponse;
import org.slf4j.MDC;
import org.springframework.stereotype.Component;
import org.springframework.web.filter.OncePerRequestFilter;
import java.io.IOException;
import java.util.UUID;
@Component
public class RequestIdFilter extends OncePerRequestFilter {
private static final String REQUEST_ID_HEADER = "X-Request-Id";
@Override
protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain) throws ServletException, IOException {
try {
String requestId = request.getHeader(REQUEST_ID_HEADER);
if (requestId == null || requestId.isBlank()) {
requestId = UUID.randomUUID().toString();
}
MDC.put("requestId", requestId);
// 同时将 requestId 放回响应头,便于前端或网关追踪
response.setHeader(REQUEST_ID_HEADER, requestId);
filterChain.doFilter(request, response);
} finally {
MDC.remove("requestId");
}
}
}
说明:
X-Request-Id,并放到 MDC,日志 pattern 能输出 %X{requestId};# 暴露 Actuator prometheus 端点
management.endpoints.web.exposure.include=health,info,prometheus,metrics
management.endpoint.prometheus.enabled=true
# 日志级别(根据环境调整)
logging.level.root=INFO
logging.level.com.example=DEBUG
放在 src/main/resources/logback-spring.xml:
<configuration>
<springProfile name="prod">
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<!-- 输出包含 requestId -->
<pattern>%d{yyyy-MM-dd'T'HH:mm:ss.SSSXXX} [%thread] %-5level %logger{36} - %msg - requestId=%X{requestId}%n</pattern>
</encoder>
</appender>
<root level="INFO">
<appender-ref ref="STDOUT"/>
</root>
</springProfile>
<springProfile name="!prod">
<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss} [%thread] %-5level %logger{36} - %msg - requestId=%X{requestId}%n</pattern>
</encoder>
</appender>
<root level="DEBUG">
<appender-ref ref="STDOUT"/>
</root>
</springProfile>
</configuration>
2025-08-10T18:34:10.123+03:00 [http-nio-8080-exec-1] ERROR com.example.demo.exception.GlobalExceptionHandler - Unhandled exception - requestId=2f1a8c7f-1d2b-4f0a-9b2a-123456789abc, path=/api/orders
java.lang.NullPointerException: ...
at com.example.demo.service.OrderService.create(OrderService.java:45)
...
你会看到 requestId 出现在每条日志,便于用 grep 或日志平台(ELK/EFK)按 requestId 过滤整条调用链。
前文 GlobalExceptionHandler 已经把计数器注册到 Micrometer:
exceptions.totalexceptions.by_code{code=...}exceptions.by_type{type=...}在 Prometheus 中抓取 Spring Boot 的 /actuator/prometheus 指标,就能在 Grafana 中根据 exceptions.by_type 做报警规则。例如:如果 exceptions.by_type{type="NullPointerException"} 在 5 分钟内增幅过大,就触发报警。
MethodArgumentNotValidException)
BusinessException)
code,前端可根据 code 做差异化提示或重试策略;监控中也可以以 code 为标签统计。requestId 做本地快速查找。details。X-Request-Id,否则服务端生成并回传;requestId、code、type 聚合查询;
微信公众号「极客日志」,在微信中扫描左侧二维码关注。展示文案:极客日志 zeeklog
查找任何按下的键的javascript键代码、代码、位置和修饰符。 在线工具,Keycode 信息在线工具,online
JavaScript 字符串转义/反转义;Java 风格 \uXXXX(Native2Ascii)编码与解码。 在线工具,Escape 与 Native 编解码在线工具,online
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。 在线工具,JavaScript / HTML 格式化在线工具,online
Terser 压缩、变量名混淆,或 javascript-obfuscator 高强度混淆(体积会增大)。 在线工具,JavaScript 压缩与混淆在线工具,online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具,Base64 字符串编码/解码在线工具,online
将字符串、文件或图像转换为其 Base64 表示形式。 在线工具,Base64 文件转换器在线工具,online