From b21dfad4851f5f192b28e53d3a3ef35de7e7ba91 Mon Sep 17 00:00:00 2001
From: wangky <m1561510467@163.com>
Date: 星期六, 02 十一月 2024 15:25:36 +0800
Subject: [PATCH] 1
---
Server/马丽萍/code/log/log.h | 113 ++++++++++++++++++++++++++++++++++++--------------------
1 files changed, 73 insertions(+), 40 deletions(-)
diff --git "a/Server/\351\251\254\344\270\275\350\220\215/code/log/log.h" "b/Server/\351\251\254\344\270\275\350\220\215/code/log/log.h"
index 64972af..83df983 100644
--- "a/Server/\351\251\254\344\270\275\350\220\215/code/log/log.h"
+++ "b/Server/\351\251\254\344\270\275\350\220\215/code/log/log.h"
@@ -3,67 +3,100 @@
#include <stdio.h>
#include <iostream>
-#include <string>
#include <stdarg.h>
-#include <pthread.h>
+#include <thread>
#include "block_queue.h"
+#include "locker.h"
+#include <fstream>
+#include <sqlite3.h> // 娣诲姞 SQLite 鏁版嵁搴撶殑澶存枃浠�
using namespace std;
+
+// 鏃ュ織绾у埆鏋氫妇
+enum LogLevel {
+ DEBUG = 0,
+ INFO,
+ WARN,
+ ERROR
+};
+
+// 瀛樺偍瑙ｆ瀽鏃ュ織鏂囦欢鐨勭粨鏋勪綋
+struct ParsedLog {
+ char timestamp[64]; // 鏃堕棿鎴�
+ char device_id[64]; // 璁惧ID
+ char level[16]; // 鏃ュ織绾у埆
+ char content[256]; // 鏃ュ織鍐呭
+ char source[64]; // 鏉ユ簮妯″潡
+ char user_id[64]; // 鐢ㄦ埛ID
+};
class Log
{
public:
- //C++11浠ュ悗,浣跨敤灞�閮ㄥ彉閲忔噿姹変笉鐢ㄥ姞閿�
+ // 鑾峰彇鍗曚緥瀹炰緥
static Log *get_instance()
{
static Log instance;
return &instance;
}
- static void *flush_log_thread(void *args)
- {
- 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 flush_log_thread(); // 淇敼涓洪潪闈欐�佹垚鍛樺嚱鏁�
+ // 鍒濆鍖栨棩蹇楃郴缁燂紝鍙傛暟鍖呮嫭鏂囦欢鍚嶃�佹槸鍚﹀叧闂棩蹇椼�佺紦鍐插尯澶у皬銆佹渶澶ц鏁板拰鏈�澶ч槦鍒楀ぇ灏�
+ 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);
-private:
- Log();
- virtual ~Log();
- void *async_write_log()
- {
- string single_log;
- //浠庨樆濉為槦鍒椾腑鍙栧嚭涓�涓棩蹇梥tring锛屽啓鍏ユ枃浠�
- while (m_log_queue->pop(single_log))
- {
- m_mutex.lock();
- fputs(single_log.c_str(), m_fp);
- m_mutex.unlock();
- }
- }
+ // 鎺ユ敹鍘熷鏃ュ織
+ void receiveLog(const char* raw_log);
+
+ // 灏嗘棩蹇楀啓鍏ユ暟鎹簱
+ void writeLogToDatabase(const ParsedLog& log);
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 *m_buf;
- block_queue<string> *m_log_queue; //闃诲闃熷垪
- bool m_is_async; //鏄惁鍚屾鏍囧織浣�
- locker m_mutex;
- int m_close_log; //鍏抽棴鏃ュ織
+ Log(); // 鏋勯�犲嚱鏁�
+ virtual ~Log(); // 鏋愭瀯鍑芥暟
+
+ void async_write_log(); // 寮傛鍐欏叆鏃ュ織
+ bool check_log_size(); // 妫�鏌ユ棩蹇楁枃浠跺ぇ灏�
+ void rotate_logs(); // 杞崲鏃ュ織鏂囦欢
+
+ 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 char *level);
+
+private:
+ char dir_name[128]; // 鏃ュ織鏂囦欢鐩綍
+ char log_name[128]; // 鏃ュ織鏂囦欢鍚�
+ int m_split_lines; // 鏃ュ織鏈�澶ц鏁�
+ int m_log_buf_size; // 鏃ュ織缂撳啿鍖哄ぇ灏�
+ long long m_count; // 鏃ュ織琛屾暟璁板綍
+ int m_today; // 璁板綍褰撳墠鏃堕棿
+ std::ofstream m_fp; // 灏� FILE * m_fp 鏇存敼涓� std::ofstream m_fp
+ char *m_buf; // 鏃ュ織缂撳啿鍖�
+ block_queue<char*> *m_log_queue; // 闃诲闃熷垪
+ bool m_is_async; // 鏄惁寮傛鏍囧織浣�
+ locker m_mutex; // 浜掓枼閿�
+ int m_close_log; // 鍏抽棴鏃ュ織鐨勬爣蹇�
+ long max_size = 10 * 1024 * 1024; // 鍗曚釜鏃ュ織鏂囦欢鐨勫ぇ灏� 10MB
+
+ // 鏁版嵁搴撶浉鍏�
+ 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(0, format, ##__VA_ARGS__); Log::get_instance()->flush();}
-#define LOG_INFO(format, ...) if(0 == m_close_log) {Log::get_instance()->write_log(1, format, ##__VA_ARGS__); Log::get_instance()->flush();}
-#define LOG_WARN(format, ...) if(0 == m_close_log) {Log::get_instance()->write_log(2, format, ##__VA_ARGS__); Log::get_instance()->flush();}
-#define LOG_ERROR(format, ...) if(0 == m_close_log) {Log::get_instance()->write_log(3, format, ##__VA_ARGS__); Log::get_instance()->flush();}
+#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();}
+#define LOG_ERROR(format, ...) if(0 == m_close_log) {Log::get_instance()->write_log(ERROR, format, ##__VA_ARGS__); Log::get_instance()->flush();}
#endif
--
Gitblit v1.8.0