SpringBoot实战：结合 MongoDB实现日志数据保存和归档

引言

MongoDB实现日志数据保存和归档，意味着利用MongoDB数据库来存储和管理日志数据，以及进行日志数据的归档处理。日志数据是系统或应用程序在运行过程中产生的记录信息，对于监控、审计和故障排查等至关重要。MongoDB作为一种高性能、可扩展的NoSQL数据库，适合处理大量、多样化的日志数据。通过将日志数据保存到MongoDB中，可以方便地进行查询、分析和归档。归档处理则是指将旧的、不再频繁访问的日志数据转移到存储成本更低的存储介质上，以节省存储空间并优化性能。MongoDB提供了丰富的数据操作和查询功能，使得日志数据的保存、管理和归档变得更加高效和便捷。

一、代码示例

应用场景：假设项目需要记录用户的操作日志，且需要实时查询近七天的数据，对于超过七天的数据，需要归档到数据库。

在项目的 pom.xml 文件中添加 MongoDB 依赖：

<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-mongodb</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-validation</artifactId>
    </dependency>
</dependencies>

创建日志实体类，用于 MongoDB 文档映射：

import org.springframework.data.annotation.Id;
import org.springframework.data.mongodb.core.mapping.Document;

import java.time.LocalDateTime;

@Document(collection = "logs")
public class LogEntry {
    @Id
    private String id;
    private String message;
    private LocalDateTime timestamp;
    private String level;

    // 构造器、getter和setter
}

定义一个日志存储库接口：

import org.springframework.data.mongodb.repository.MongoRepository;
import org.springframework.stereotype.Repository;

import java.time.LocalDateTime;
import java.util.List;

@Repository
public interface LogRepository extends MongoRepository<LogEntry, String> {
    List<LogEntry> findAllByTimestampBetween(LocalDateTime start, LocalDateTime end);
    List<LogEntry> findAllByTimestampBefore(LocalDateTime before);
}

实现日志服务

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.time.LocalDateTime;
import java.util.List;

@Service
public class LogService {
    @Autowired
    private LogRepository logRepository;

    public void addLog(String message, String level) {
        LogEntry log = new LogEntry();
        log.setMessage(message);
        log.setLevel(level);
        log.setTimestamp(LocalDateTime.now());
        logRepository.save(log);
    }

    public List<LogEntry> getRecentLogs(LocalDateTime from, LocalDateTime to) {
        return logRepository.findAllByTimestampBetween(from, to);
    }
}

编写一个定时任务用于进行日志归档：

import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;

@Component
public class LogArchiver {
    @Autowired
    private LogRepository logRepository;

    @Scheduled(cron = "0 0 1 * * ?") // 每天凌晨1点执行
    public void archiveLogs() {
        LocalDateTime sevenDaysAgo = LocalDateTime.now().minusDays(7);
        List<LogEntry> oldLogs = logRepository.findAllByTimestampBefore(sevenDaysAgo);
        // 将旧日志转移到归档数据库或集合
        oldLogs.forEach(log -> {
            // 归档操作
            logRepository.delete(log);
        });
    }
}