C++实现类似Log4j的异步日志记录

为了实现类似 Log4j 的异步日志记录，我们可以使用 C++ 的线程库和日志库

首先，安装 spdlog 库。你可以从这里下载：https://github.com/gabime/spdlog

然后，创建一个名为 async_logger.h 的头文件，用于定义异步日志记录器类：

#pragma once

#include <spdlog/spdlog.h>
#include <spdlog/sinks/basic_file_sink.h>
#include <memory>
#include <thread>
#include <mutex>
#include <queue>
#include <condition_variable>

class AsyncLogger {
public:
    AsyncLogger(const std::string& log_file, size_t queue_size = 1024 * 1024);
    ~AsyncLogger();

    void log(const spdlog::level::level_enum level, const std::string& message);

private:
    void worker();

    std::shared_ptr<spdlog::sinks::basic_file_sink> file_sink_;
    std::queue<std::pair<spdlog::level::level_enum, std::string>> log_queue_;
    std::mutex queue_mutex_;
    std::condition_variable cond_;
    std::thread worker_thread_;
    bool stop_;
};

接下来，创建一个名为 async_logger.cpp 的源文件，用于实现异步日志记录器类：

#include "async_logger.h"

AsyncLogger::AsyncLogger(const std::string& log_file, size_t queue_size)
    : file_sink_(std::make_shared<spdlog::sinks::basic_file_sink>(log_file, true)),
      log_queue_(queue_size),
      queue_mutex_(),
      cond_(),
      worker_thread_(),
      stop_(false) {
    worker_thread_ = std::thread(&AsyncLogger::worker, this);
}

AsyncLogger::~AsyncLogger() {
    {
        std::unique_lock<std::mutex> lock(queue_mutex_);
        stop_ = true;
    }
    cond_.notify_one();
    if (worker_thread_.joinable()) {
        worker_thread_.join();
    }
}

void AsyncLogger::log(const spdlog::level::level_enum level, const std::string& message) {
    {
        std::unique_lock<std::mutex> lock(queue_mutex_);
        log_queue_.emplace(level, message);
    }
    cond_.notify_one();
}

void AsyncLogger::worker() {
    while (true) {
        std::pair<spdlog::level::level_enum, std::string> log_entry;
        {
            std::unique_lock<std::mutex> lock(queue_mutex_);
            cond_.wait(lock, [this] { return !log_queue_.empty() || stop_; });
            if (stop_ && log_queue_.empty()) {
                return;
            }
            log_entry = std::move(log_queue_.front());
            log_queue_.pop();
        }
        file_sink_->log(log_entry.first, log_entry.second);
    }
}

现在，你可以在你的项目中包含 async_logger.h 头文件并使用 AsyncLogger 类进行异步日志记录：

#include "async_logger.h"

int main() {
    AsyncLogger async_logger("logs/app.log");

    async_logger.log(spdlog::level::info, "This is an info message");
    async_logger.log(spdlog::level::debug, "This is a debug message");
    async_logger.log(spdlog::level::error, "This is an error message");

    return 0;
}

这个简单的示例展示了如何使用 spdlog 库创建一个异步日志记录器。你可以根据需要调整日志级别、输出格式等。