240717班级，工业化控制系统，煤矿相关行业，昆仑系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
Administrator
2024-11-01 b462e21965b8332b17ad3bdfa5ed38b67f4dc2bb 
 Server/ÂíÀöƼ/code/log/log.h


@@ -3,12 +3,12 @@




#include <stdio.h>


#include <iostream>


#include <string>


#include <stdarg.h>


#include <thread> 


#include <thread>


#include "block_queue.h"


#include "locker.h" 


#include "locker.h"


#include <fstream>


#include <sqlite3.h> // æ·»åŠ  SQLite æ•°æ®åº“的头文件




using namespace std;




@@ -22,10 +22,12 @@




// å­˜å‚¨è§£æžæ—¥å¿—文件的结构体


struct ParsedLog {


    std::string timestamp; // æ—¶é—´æˆ³


    std::string device_id; // è®¾å¤‡ID


    std::string level;     // æ—¥å¿—级别


    std::string content;   // æ—¥å¿—内容


    char timestamp[64]; // æ—¶é—´æˆ³


    char device_id[64]; // è®¾å¤‡ID


    char level[16];     // æ—¥å¿—级别


    char content[256];  // æ—¥å¿—内容


    char source[64];    // æ¥æºæ¨¡å—


    char user_id[64];   // ç”¨æˆ·ID


};




class Log


@@ -42,17 +44,19 @@


    void flush_log_thread(); // ä¿®æ”¹ä¸ºéžé™æ€æˆå‘˜å‡½æ•°




    // åˆå§‹åŒ–日志系统，参数包括文件名、是否关闭日志、缓冲区大小、最大行数和最大队列大小


    bool Log::init(const char *file_name, int close_log, int log_buf_size, int split_lines, int max_queue_size);


    bool init(const char *file_name, int close_log, int log_buf_size, int split_lines, int max_queue_size);




    


    // å†™å…¥æ—¥å¿—


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


    


    // åˆ·æ–°æ—¥å¿—文件


    void flush(void);




    //接收原始的要公共类


    void receiveLog(const std::string& raw_log); // æŽ¥æ”¶åŽŸå§‹æ—¥å¿—


    // æŽ¥æ”¶åŽŸå§‹æ—¥å¿—


    void receiveLog(const char* raw_log);




    // å°†æ—¥å¿—写入数据库


    void writeLogToDatabase(const ParsedLog& log);




private:


    Log(); // æž„造函数


@@ -62,12 +66,12 @@


    bool check_log_size(); // æ£€æŸ¥æ—¥å¿—文件大小


    void rotate_logs(); // è½®æ¢æ—¥å¿—文件


    


    ParsedLog parseLog(const std::string& log); // è§£æžæ—¥å¿—


    bool init(const std::string &file_name, int close_log, int log_buf_size, int split_lines, int max_queue_size);


    void queryLogs(const std::string &device_id); // æŸ¥è¯¢æ—¥å¿—


    ParsedLog parseLog(const char* log); // è§£æžæ—¥å¿—


    bool init(const char *file_name, int close_log, int log_buf_size, int split_lines, int max_queue_size);


    void queryLogs(const char *device_id); // æŸ¥è¯¢æ—¥å¿—




    const char* log_level_to_string(int level); // å°†æ—¥å¿—级别转换为字符串


    int levelToInt(const std::string &level);


    int levelToInt(const char *level);




private:


    char dir_name[128]; // æ—¥å¿—文件目录


@@ -78,16 +82,18 @@


    int m_today;        // è®°å½•å½“前时间


    std::ofstream m_fp; // å°† FILE * m_fp æ›´æ”¹ä¸º std::ofstream m_fp


    char *m_buf;        // æ—¥å¿—缓冲区


    block_queue<string> *m_log_queue; // é˜»å¡žé˜Ÿåˆ—


    block_queue<char*> *m_log_queue; // é˜»å¡žé˜Ÿåˆ—


    bool m_is_async;                  // æ˜¯å¦å¼‚步标志位


    locker m_mutex;                   // äº’斥锁


    int m_close_log; // å…³é—­æ—¥å¿—的标志


    long max_size = 10 * 1024 * 1024; // å•ä¸ªæ—¥å¿—文件的大小 10MB


    //测试文件里面的


    int m_close_log; // ç¡®ä¿åœ¨è¿™é‡Œå®šä¹‰




    // æ•°æ®åº“相关


    sqlite3 *db; // SQLite æ•°æ®åº“指针


    void openDatabase(const char *db_name); // æ‰“开数据库


    void closeDatabase(); // å…³é—­æ•°æ®åº“


};




// å®å®šä¹‰ç”¨äºŽä¸åŒçº§åˆ«çš„日志记录


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


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


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