在Golang微服务架构中，服务通常部署在多个节点上并频繁扩缩容，日志分散在各自容器或主机中。要实现高效的故障排查与监控，必须将所有服务的日志统一收集到中心化存储，并进行聚合查询。
为什么需要日志统一收集
微服务场景下，一次请求可能跨越多个服务。如果日志散落在不同机器，排查问题要登录多台主机，效率极低。统一收集后能带来以下好处：
- 集中检索：通过一个界面搜索所有服务日志
- 关联分析：按traceId串联多次调用链路
- 告警联动：基于错误日志触发通知
常用技术栈组合
目前主流的日志聚合处理方法分为两类：ELK系与轻量Loki系。
| 方案 | 采集端 | 存储 | 展示 |
|---|---|---|---|
| ELK | Filebeat | Elasticsearch | Kibana |
| PLG | Promtail | Loki | Grafana |
Golang服务侧日志规范
建议Golang服务使用结构化日志，例如zap库输出JSON格式，并带上服务名、traceId等字段。
package main
import (
"go.uber.org/zap"
)
func main() {
// 创建生产级logger，输出JSON格式
logger, _ := zap.NewProduction()
defer logger.Sync()
// 带上服务名与traceId，方便聚合时过滤
logger.Info("http request handled",
zap.String("service", "user-service"),
zap.String("traceId", "abc123"),
zap.Int("status", 200),
)
}
基于Filebeat的收集流程
服务将日志写到本地文件，Filebeat监控文件变化并转发到消息队列，降低日志丢失风险。
# filebeat.yml 简化配置
filebeat.inputs:
- type: log
paths:
- /var/log/golang/*.log
output.kafka:
hosts: ["192.168.0.1:9092"]
topic: "golang_logs"
使用Loki的轻量方案
如果不想维护Elasticsearch，可用Loki。Golang服务直接输出到stdout，Promtail自动抓取。
# 启动Promtail容器，抓取本机docker日志 promtail -config.file=/etc/promtail.yml -client.url=http://127.0.0.1:3100/loki/api/v1/push
注意转义标签名称
在代码或配置中如果提到HTML标签，比如<input>或<div>，必须转义避免被解析。函数调用如fmt.Println()不属于标签，原样书写即可。
聚合查询示例
在Kibana或Grafana中，可通过语句筛选某服务的错误日志：
service: "user-service" AND level: "error"
通过上述方法，Golang微服务的日志统一收集与聚合处理即可落地，提升系统可观测性。