Spring Boot全局异常处理与日志监控全解析

 更新时间:2025年08月15日 09:14:25   作者:学习编程的小羊  
本文给大家介绍Spring Boot全局异常处理与日志监控全解析,通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧

代码以 Spring Boot 3 / Java 17 风格示例(可适配 Spring Boot 2.x 做少量改动)

目标:构建一套健壮的全局异常处理方案,统一错误响应、可追踪的日志(requestId/MDC),并把异常上报为监控指标(使用 Micrometer),方便在生产环境定位与统计异常。

1. 背景与目标

生产环境中,异常无处不在。我们要解决三件事:

  • 对外统一 JSON 错误格式,便于前端/客户端解析与展示;
  • 在日志中携带可追溯的 requestId(MDC),便于从日志中串联一条请求的全部操作;
  • 对异常做指标统计(例如按异常类型/状态码计数),能在监控平台(Prometheus/Grafana)上报警与分析。

2. 设计思路(要点)

  • 使用 @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(视需求)。

3. 项目依赖(Maven)

<!-- 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>

4. 通用错误响应 DTO

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
}

5. 自定义业务异常示例

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;
    }
}

6. 全局异常处理实现(日志 + 指标)

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 写入返回体,方便客户端带回查日志。

7. 请求 ID 与 MDC 过滤器(保证每条请求都有 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};
  • 响应中返回该 header,有利于客户端/运维串联。

8. 日志配置与示例输出

application.properties(关键项)

# 暴露 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

logback-spring.xml(pattern 示例)

放在 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 过滤整条调用链。

9. 将异常计数暴露到监控(Actuator + Micrometer)

前文 GlobalExceptionHandler 已经把计数器注册到 Micrometer:

  • exceptions.total
  • exceptions.by_code{code=...}
  • exceptions.by_type{type=...}

在 Prometheus 中抓取 Spring Boot 的 /actuator/prometheus 指标,就能在 Grafana 中根据 exceptions.by_type 做报警规则。例如:如果 exceptions.by_type{type="NullPointerException"} 在 5 分钟内增幅过大,就触发报警。

10. 常见场景与处理建议

  • 参数校验失败(MethodArgumentNotValidException)
    • 建议把字段错误拼成单行 message(示例中已实现),并返回 400。
  • 业务异常(自定义 BusinessException)
    • 业务异常可携带 code,前端可根据 code 做差异化提示或重试策略;监控中也可以以 code 为标签统计。
  • 第三方超时/HTTP 错误(RestTemplate/WebClient)
    • 在调用处抛出有意义的自定义异常或将原异常包装后抛出;在全局异常处理器中根据异常类型映射为 502/504 等状态,并计数。
  • 链路追踪(可选)
    • 若有分布式追踪需求,可接入 OpenTelemetry/Zipkin/Jaeger,但仍保留 requestId 做本地快速查找。
  • 安全注意
    • 生产环境不要在 API 返回中包含完整堆栈或敏感字段(示例中仅返回通用 message)。可以在开发 profile 下增加 details。

11. 小结与部署建议

  • 统一异常处理 可以显著提升前后端协作效率与错误可观察性;
  • MDC + requestId 是生产排查的第一要素,务必保证上游(网关)能传递 X-Request-Id,否则服务端生成并回传;
  • 监控计数(Micrometer)使异常不再是“偶发的黑盒”,可以在 Grafana/Prometheus 上设定阈值与报警;
  • 日志集中化 建议配合 ELK/EFK(或云日志)保存结构化日志(JSON)以便于按 requestId、code、type 聚合查询;
  • 对外返回 应保持稳定的 JSON 格式与明确的状态码,避免泄露内部实现细节。

相关文章

  • JAVA加密算法实密钥一致协议代码示例

    JAVA加密算法实密钥一致协议代码示例

    这篇文章主要介绍了JAVA加密算法实密钥一致协议代码示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-10-10
  • Spring的事务机制实例代码

    Spring的事务机制实例代码

    这篇文章主要介绍了Spring的事务机制实例代码,分享了相关代码示例,小编觉得还是挺不错的,具有一定借鉴价值,需要的朋友可以参考下
    2018-02-02
  • Java软件编程培训机构靠谱吗

    Java软件编程培训机构靠谱吗

    随着网络信息化的快速发展,Java培训受到越来越多人的青睐,目前Java工程师的薪资水平在不断攀升,但是有好多企业还是招不到合适的人才,为什么呢
    2017-04-04
  • SpringBoot源码剖析之属性文件加载原理

    SpringBoot源码剖析之属性文件加载原理

    这篇文章主要给大家介绍了关于SpringBoot源码剖析之属性文件加载原理的相关资料,文中通过实例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2022-02-02
  • java ant包中的org.apache.tools.zip实现压缩和解压缩实例详解

    java ant包中的org.apache.tools.zip实现压缩和解压缩实例详解

    这篇文章主要介绍了java ant包中的org.apache.tools.zip实现压缩和解压缩实例详解的相关资料,需要的朋友可以参考下
    2017-04-04
  • 浅谈hibernate中对象的3种状态_瞬时态、持久态、脱管态

    浅谈hibernate中对象的3种状态_瞬时态、持久态、脱管态

    下面小编就为大家带来一篇浅谈hibernate中对象的3种状态_瞬时态、持久态、脱管态。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-08-08
  • SpringBoot基于JAXB实现天地图路径规划结果XML转JSON

    SpringBoot基于JAXB实现天地图路径规划结果XML转JSON

    这篇文章主要为大家详细介绍了SpringBoot如何基于JAXB实现将天地图路径规划结果XML转JSON功能,文中的示例代码讲解详细,需要的可以了解下
    2025-02-02
  • SpringMVC集成FastJson使用流程详解

    SpringMVC集成FastJson使用流程详解

    如果你使用 Spring MVC 来构建 Web 应用并对性能有较高的要求的话,可以使用 Fastjson 提供的FastJsonHttpMessageConverter 来替换 Spring MVC 默认的 HttpMessageConverter 以提高 @RestController @ResponseBody @RequestBody 注解的 JSON序列化速度
    2023-02-02
  • SpringCloud集成Hystrix熔断过程分步分解

    SpringCloud集成Hystrix熔断过程分步分解

    通过hystrix可以解决雪崩效应问题,它提供了资源隔离、降级机制、融断、缓存等功能。接下来通过本文给大家分享SpringCloud集成Hystrix熔断,感兴趣的朋友一起看看吧
    2022-09-09
  • JSON.toJSONString()空字段不忽略修改的问题

    JSON.toJSONString()空字段不忽略修改的问题

    这篇文章主要介绍了JSON.toJSONString()空字段不忽略修改的问题,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-02-02

最新评论