如何在Spring Boot中拦截日志消息并持久化到数据库？

当然有办法啦！其实你用的java.util.logging框架本身就提供了类似的拦截能力，核心就是自定义Handler——就像Web请求会经过HandlerInterceptor一样，所有日志消息都会流经注册的Handler，你完全可以在Handler里加逻辑把日志存到数据库。

具体实现步骤 #

1. 自定义数据库日志Handler

继承java.util.logging.Handler，重写publish()方法——这就是你拦截并处理日志的核心入口，在这里提取日志信息并执行数据库持久化逻辑：

import java.io.StringWriter;
import java.io.PrintWriter;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Timestamp;
import java.util.logging.Handler;
import java.util.logging.Level;
import java.util.logging.LogRecord;

public class DatabaseLogHandler extends Handler {
    // 建议用连接池替代直接创建连接，这里为了示例简化
    private Connection dbConnection;

    public DatabaseLogHandler() {
        // 初始化数据库连接
        try {
            dbConnection = DriverManager.getConnection(
                "jdbc:mysql://localhost:3306/your_log_db",
                "db_user",
                "db_password"
            );
        } catch (SQLException e) {
            throw new RuntimeException("初始化日志数据库连接失败", e);
        }
    }

    @Override
    public void publish(LogRecord record) {
        // 跳过级别不符合要求的日志
        if (!isLoggable(record)) {
            return;
        }

        // 提取日志核心信息
        Level logLevel = record.getLevel();
        String loggerName = record.getLoggerName();
        String logMessage = record.getMessage();
        long timestamp = record.getMillis();
        Throwable exception = record.getThrown();

        // 把异常栈转为字符串（如果有异常的话）
        String exceptionStack = null;
        if (exception != null) {
            StringWriter sw = new StringWriter();
            exception.printStackTrace(new PrintWriter(sw));
            exceptionStack = sw.toString();
        }

        // 执行数据库插入
        String insertSql = """
            INSERT INTO app_logs (log_level, logger_name, message, log_time, exception_stack)
            VALUES (?, ?, ?, ?, ?)
        """;
        try (PreparedStatement stmt = dbConnection.prepareStatement(insertSql)) {
            stmt.setString(1, logLevel.getName());
            stmt.setString(2, loggerName);
            stmt.setString(3, logMessage);
            stmt.setTimestamp(4, new Timestamp(timestamp));
            stmt.setString(5, exceptionStack);
            stmt.executeUpdate();
        } catch (SQLException e) {
            // 注意：这里别用当前Logger打日志，避免循环调用
            System.err.println("日志持久化到数据库失败：" + e.getMessage());
        }
    }

    @Override
    public void flush() {
        // 如果用了批量插入，这里可以做刷新操作
    }

    @Override
    public void close() throws SecurityException {
        // 关闭数据库连接
        if (dbConnection != null) {
            try {
                dbConnection.close();
            } catch (SQLException e) {
                System.err.println("关闭日志数据库连接失败：" + e.getMessage());
            }
        }
    }
}

2. 把自定义Handler注册到你的Logger

有两种方式可以完成注册：

• 代码手动注册：在Logger初始化后添加Handler（建议加静态代码块避免重复注册）

private final Logger log = Logger.getLogger(this.getClass().getSimpleName());

static {
    Logger targetLogger = Logger.getLogger(YourClassName.class.getSimpleName());
    // 检查是否已经添加过数据库Handler，避免重复注册
    boolean hasDbHandler = targetLogger.getHandlers().stream()
            .anyMatch(handler -> handler instanceof DatabaseLogHandler);
    if (!hasDbHandler) {
        targetLogger.addHandler(new DatabaseLogHandler());
        // 可以设置Handler的日志级别，比如只处理INFO及以上
        targetLogger.getHandlers()[targetLogger.getHandlers().length - 1].setLevel(Level.INFO);
    }
}

• 配置文件注册：修改项目或JRE下的logging.properties，全局生效

# 同时保留控制台输出和数据库Handler
handlers=java.util.logging.ConsoleHandler, com.yourpackage.DatabaseLogHandler

# 设置数据库Handler的日志级别
com.yourpackage.DatabaseLogHandler.level=INFO

关键注意事项 #

• 资源优化：别用示例里的DriverManager直接创建连接，改用HikariCP这类连接池，避免频繁创建销毁连接影响性能。
• 避免循环日志：在自定义Handler里绝对不能用当前Logger记录错误，否则会再次触发publish()方法，导致无限循环，用System.err输出即可。
• 性能优化：如果日志量很大，建议把日志先放到异步队列里，用后台线程批量写入数据库，避免阻塞业务逻辑。
• 级别过滤：可以在Handler上设置级别，和你代码里的log.isLoggable(Level.INFO)对应，避免处理不必要的低级别日志。

内容的提问来源于stack exchange，提问作者crmepham