如何在Golang中开发简单的日志查询功能_Golang日志查询项目实战汇总_技术教程

答案：通过结构化日志格式、条件过滤和HTTP接口实现轻量级日志查询。使用JSON格式记录日志，结合slog包输出；按行读取文件并解析JSON，支持级别、关键字等条件筛选；通过net/http暴露查询接口，提供实时访问能力；可扩展分页、时间范围、mmap优化和WebSocket推送，适用于小型项目快速构建实用日志系统。

在Go语言项目中实现简单的日志查询功能，不需要依赖复杂的系统，通过合理设计文件结构、日志格式和检索逻辑，就能快速搭建一个轻量级但实用的日志查询工具。下面从实际开发角度出发，介绍如何一步步构建这个功能。

定义统一的日志格式

要能高效查询日志，第一步是确保日志输出格式规范、结构化。建议使用JSON格式记录每条日志，包含时间戳、级别、模块名和消息内容等字段。

{
  "time": "2025-04-05T10:23:45Z",
  "level": "ERROR",
  "module": "auth",
  "msg": "failed to login user",
  "user_id": 12345
}

使用 log/slog 包（Go 1.21+）可以轻松输出结构化日志：

logger := slog.New(slog.NewJSONHandler(os.Stdout, nil))
logger.Error("failed to login user", "module", "auth", "user_id", 12345)

实现基于条件的日志读取与过滤

将日志写入文件后，查询功能需要读取文件并按条件筛选。常见查询条件包括时间范围、日志级别、关键字或特定字段值。

基本思路如下：

按行读取日志文件
解析每一行为JSON结构
根据输入条件判断是否匹配
收集符合条件的日志条目返回

示例代码片段：

func QueryLogs(filename string, level string, keyword string) ([]map[string]any, error) {
    file, err := os.Open(filename)
    if err != nil {
        return nil, err
    }
    defer file.Close()

    var results []map[string]any
    scanner := bufio.NewScanner(file)
    for scanner.Scan() {
        line := scanner.Text()
        var logEntry map[string]any
        if json.Unmarshal([]byte(line), &logEntry) == nil {
            if (level == "" || logEntry["level"] == level) &&
               (keyword == "" || strings.Contains(fmt.Sprint(logEntry["msg"]), keyword)) {
                results = append(results, logEntry)
            }
        }
    }
    return results, scanner.Err()
}

提供HTTP接口供外部查询

为了让日志查询更易用，可以通过HTTP暴露查询接口。使用标准库 net/http 搭建简单服务。

定义一个处理函数：

http.HandleFunc("/logs", func(w http.ResponseWriter, r *http.Request) {
    level := r.URL.Query().Get("level")
    keyword := r.URL.Query().Get("keyword")

    logs, err := QueryLogs("app.log", level, keyword)
    if err != nil {
        http.Error(w, err.Error(), 500)
        return
    }

    w.Header().Set("Content-Type", "application/json")
    json.NewEncoder(w).Encode(logs)
})

启动服务后，可通过访问 /logs?level=ERROR&keyword=login 实时查看错误日志。