HarmonyOS鸿蒙Next中如何在应用中实现日志信息记录并通过用户模块发送日志功能

以下是一个简单的日志记录工具，上传自行处理：

import fs from '@ohos.file.fs';
import { util } from '@kit.ArkTS';

export enum LogLevel {
  INFO = 'INFO',
  WARN = 'WARN',
  ERROR = 'ERROR'
}

export class LogManager {
  private logPath: string;
  private maxLogSize: number = 10 * 1024 * 1024; // 10MB
  private logQueue: string[] = [];
  private isWriting: boolean = false;

  constructor() {
    const context = getContext();
    const rootPath = context.filesDir + '/logs';
    this.initLogDirectory(rootPath);
    this.logPath = `${rootPath}/server.log`;
  }

  private async initLogDirectory(rootPath: string) {
    try {
      await fs.mkdir(rootPath);
    } catch (error) {
      // 目录可能已存在，忽略错误
    }
  }

  public async log(level: LogLevel, message: string, details?: Record<string, Object>) {
    const timestamp = new Date().toISOString();
    const logEntry = `[${timestamp}] [${level}] ${message} ${details ? JSON.stringify(details) : ''}\n`;

    this.logQueue.push(logEntry);
    this.processLogQueue();
  }

  private async processLogQueue() {
    if (this.isWriting || this.logQueue.length === 0) {
      return;
    }

    this.isWriting = true;
    try {
      const entry = this.logQueue.shift();
      if (entry) {
        await this.writeLog(entry);
      }
    } finally {
      this.isWriting = false;
      if (this.logQueue.length > 0) {
        this.processLogQueue();
      }
    }
  }

  private async writeLog(entry: string) {
    try {
      // 检查文件大小
      const stat = await fs.stat(this.logPath).catch(() => null);
      if (stat && stat.size > this.maxLogSize) {
        await this.rotateLog();
      }

      // 追加日志
      const file = await fs.open(this.logPath, fs.OpenMode.CREATE | fs.OpenMode.APPEND | fs.OpenMode.READ_WRITE);
      await fs.write(file.fd, entry);
      await fs.close(file.fd);
    } catch (error) {
      console.error('写入日志失败:', error);
    }
  }

  private async rotateLog() {
    try {
      await fs.rename(this.logPath, `${this.logPath}.1`);
    } catch (error) {
      console.error('日志轮转失败:', error);
    }
  }

  public async getLogs(lines: number = 100): Promise<string[]> {
    try {
      const file = await fs.open(this.logPath, fs.OpenMode.READ_ONLY);
      const stat = await fs.stat(this.logPath);
      const buffer = new ArrayBuffer(stat.size);
      await fs.read(file.fd, buffer);
      await fs.close(file.fd);

      const logContent = util.TextDecoder.create().decodeToString(new Uint8Array(buffer))
      return logContent.split('\n')
        .filter(line => line.trim().length > 0)
        .slice(-lines);
    } catch (error) {
      console.error('读取日志失败:', error);
      return [];
    }
  }
}

export const Logger = new LogManager()

// 记录日志
Logger.log(LogLevel.INFO, 'HTTP Request', {
  'method': 'POST',
  'url': 'https://xxxx.com',
})

// 上传日志
// 上传 context.filesDir + '/logs' 目录下的所有文件，或者压缩后上传