基于 Log4j 将日志持久化至 MongoDB 实践

背景

在实际开发中，有时需要将关键日志直接持久化到 MongoDB，以便利用其灵活的查询能力进行分析或审计。这里分享一种基于 Log4j 集成 log4mongo 组件的实现方案。

依赖准备

确保项目中引入了 log4mongo 相关库，否则无法加载 org.log4mongo.MongoDbPatternLayoutAppender 类。

配置文件

在 log4j.properties 中配置根日志级别及控制台输出，同时定义指向 MongoDB 的 Appender。为了区分不同业务场景，我们配置了两个独立的 Appender，分别写入不同的集合。

log4j.rootLogger=INFO, stdout

# 控制台输出
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout

# MongoDB 输出 - 业务操作日志
log4j.logger.MongoDB=INFO,MongoDB
log4j.appender.MongoDB=org.log4mongo.MongoDbPatternLayoutAppender
log4j.appender.MongoDB.Threshold=INFO
log4j.appender.MongoDB.databaseName=mydb
log4j.appender.MongoDB.collectionName=optlog
log4j.appender.MongoDB.hostname=10.25.193.16
log4j.appender.MongoDB.port=9933
log4j.appender.MongoDB.layout=org.log4mongo.MongoDbPatternLayout

# MongoDB 输出 - 特定分类日志
log4j.logger.MongoDB2=INFO,MongoDB2
log4j.appender.MongoDB2=org.log4mongo.MongoDbPatternLayoutAppender
log4j.appender.MongoDB2.Threshold=INFO
log4j.appender.MongoDB2.databaseName=mydb
log4j.appender.MongoDB2.collectionName=abclog
log4j.appender.MongoDB2.hostname=10.25.193.16
log4j.appender.MongoDB2.port=9933
log4j.appender.MongoDB2.layout=org.log4mongo.MongoDbPatternLayout

注意这里使用了两个不同的 Appender 名称（MongoDB 和 MongoDB2），对应各自的 Logger 名称，这样可以更精细地控制日志流向。

代码实现

在 Java 代码中，通过 Logger.getLogger 获取对应的 Logger 实例即可。下面是一个简单的测试示例：

public static void main(String[] args) {
    // 获取绑定到 MongoDB 输出的 Logger
    Logger logger = Logger.getLogger("MongoDB");
    logger.info("{'provinceCode': null, 'channelSubCode': null, 'platFormCode': '002', 'optCode': null, 'startTimeLong': 1384599600000, 'processTime_sum': 10081,'count': 404, 'suc_count': 0,'suc_rate': '0.00000'}");

    // 获取另一个分类的 Logger
    Logger logger2 = Logger.getLogger("MongoDB2");
    logger2.info("{'provinceCode':123}");
}

注意事项

1. 连接稳定性：生产环境建议增加重试机制或异步写入策略，避免日志写入阻塞主线程。
2. 性能影响：频繁的网络 IO 可能影响应用性能，建议根据业务重要性分级配置日志级别。
3. 数据格式：这里演示的是字符串形式存入，实际可根据需求自定义 Layout 以存储结构化 JSON 对象。