Merge branch 'master' of ssh://115.28.86.8:29418/~admin/昆仑_1025

congmu

2024-10-30 79d067bcf500355e65e26a11c345a9427ed0128c

 Server/ÂíÀöƼ/code/log/log.h

@@ -13,7 +13,7 @@
class Log
{
public:
    //C++11以后,使用局部变量懒汉不用加锁
    // C++11以后,使用局部变量懒汉不用加锁
    static Log *get_instance()
    {
        static Log instance;
@@ -24,41 +24,69 @@
    {
        Log::get_instance()->async_write_log();
    }
    //可选择的参数有日志文件、日志缓冲区大小、最大行数以及最长日志条队列

    // å¯é€‰æ‹©çš„参数有日志文件、日志缓冲区大小、最大行数以及最长日志条队列
    bool init(const char *file_name, int close_log, int log_buf_size = 8192, int split_lines = 5000000, int max_queue_size = 0);

    void write_log(int level, const char *format, ...);

    void flush(void);

private:
    Log();
    virtual ~Log();
    
    void *async_write_log()
    {
        string single_log;
        //从阻塞队列中取出一个日志string，写入文件
        // ä»Žé˜»å¡žé˜Ÿåˆ—中取出一个日志string，写入文件
        while (m_log_queue->pop(single_log))
        {
            m_mutex.lock();
            if (check_log_size()) // æ£€æŸ¥æ–‡ä»¶å¤§å°
            {
                rotate_logs(); // è½®æ¢æ—¥å¿—
            }
            fputs(single_log.c_str(), m_fp);
            m_mutex.unlock();
        }
    }

    // æ£€æŸ¥æ—¥å¿—文件大小
    bool check_log_size()
    {
        if (m_fp)
        {
            fseek(m_fp, 0, SEEK_END);
            long file_size = ftell(m_fp);
            return file_size >= max_size; // è¿”回文件是否超出限制
        }
        return false;
    }

    // è½®æ¢æ—¥å¿—文件
    void rotate_logs()
    {
        fclose(m_fp); // å…³é—­å½“前日志文件
        char new_log[256] = {0};
        snprintf(new_log, sizeof(new_log), "%s/%s.%lld", dir_name, log_name, m_count / m_split_lines);
        m_fp = fopen(new_log, "a"); // æ‰“开新的日志文件
        m_count = 0; // é‡ç½®æ—¥å¿—计数
    }

private:
    char dir_name[128]; //路径名
    char log_name[128]; //log文件名
    int m_split_lines;  //日志最大行数
    int m_log_buf_size; //日志缓冲区大小
    long long m_count;  //日志行数记录
    int m_today;        //因为按天分类,记录当前时间是那一天
    FILE *m_fp;         //打开log的文件指针
    char dir_name[128]; // è·¯å¾„名
    char log_name[128]; // log文件名
    int m_split_lines;  // æ—¥å¿—最大行数
    int m_log_buf_size; // æ—¥å¿—缓冲区大小
    long long m_count;  // æ—¥å¿—行数记录
    int m_today;        // å› ä¸ºæŒ‰å¤©åˆ†ç±»,记录当前时间是那一天
    FILE *m_fp;         // æ‰“å¼€log的文件指针
    char *m_buf;
    block_queue<string> *m_log_queue; //阻塞队列
    bool m_is_async;                  //是否同步标志位
    block_queue<string> *m_log_queue; // é˜»å¡žé˜Ÿåˆ—
    bool m_is_async;                  // æ˜¯å¦åŒæ­¥æ ‡å¿—位
    locker m_mutex;
    int m_close_log; //关闭日志
    int m_close_log; // å…³é—­æ—¥å¿—
    long max_size = 10 * 1024 * 1024; // 10MB
};

#define LOG_DEBUG(format, ...) if(0 == m_close_log) {Log::get_instance()->write_log(0, format, ##__VA_ARGS__); Log::get_instance()->flush();}