Go 语言常用生态库

zap 为什么快：四个关键设计

结果：zap 比 logrus 快 4–10 倍，高压场景（如每请求一条日志）差距被放大。

Logger vs SugaredLogger：两条 API

经验：业务代码用 SugaredLogger 省心；写库/热点路径用 Logger。两者可互转 sugar.Desugar()。

完整示例：自定义配置 + 文件滚动 + 错误字段

package main

import (
    "errors"

    "go.uber.org/zap"
    "go.uber.org/zap/zapcore"
    "gopkg.in/natefinch/lumberjack.v2"
)

func main() {
    // 1) 最快捷：生产配置（JSON + Info + 自动采样）
    prod, _ := zap.NewProduction()
    defer prod.Sync() // 退出前刷新缓冲

    prod.Info("hello zap",
        zap.String("service", "order"),
        zap.Int("qps", 1200),
        zap.Bool("cached", true),
    )

    // 2) 便利版 SugaredLogger
    sugar := prod.Sugar()
    sugar.Infow("user login", "uid", 10086, "ip", "10.0.0.3")
    sugar.Infof("latency=%dms", 35)

    // 3) 自定义：console 编码 + 调用者行号 + 按大小滚动落盘
    err := errors.New("connection refused")
    cfg := zap.NewProductionConfig()
    cfg.Encoding = "console"
    cfg.EncoderConfig.EncodeTime = zapcore.ISO8601TimeEncoder
    cfg.EncoderConfig.EncodeLevel = zapcore.CapitalColorLevelEncoder

    w := zapcore.AddSync(&lumberjack.Logger{
        Filename:   "app.log",
        MaxSize:    100, // MB
        MaxBackups: 7,
        MaxAge:     30, // 天
        Compress:   true,
    })
    core := zapcore.NewCore(
        zapcore.NewJSONEncoder(cfg.EncoderConfig),
        w,
        zapcore.InfoLevel,
    )
    logger := zap.New(core, zap.AddCaller())
    logger.Error("db failed", zap.Error(err)) // 专用错误字段
}

采样（高吞吐防刷屏）

生产环境错误可能每秒几万条。zapcore.NewSamplerWithOptions 让「每 Level 每秒前 N 条全记 + 之后每 M 条记 1 条」，既保留现场又不撑爆磁盘。NewProduction() 默认已带采样。

GORM 最小示例

type User struct {
    ID   uint   `gorm:"primaryKey"`
    Name string `gorm:"size:64"`
    Age  int
}

func main() {
    db, err := gorm.Open(mysql.Open("user:pwd@tcp(127.0.0.1:3306)/app?charset=utf8mb4"), &gorm.Config{})
    if err != nil { panic(err) }

    db.AutoMigrate(&User{})
    db.Create(&User{Name: "lvsi", Age: 18})

    var u User
    db.First(&u, "name = ?", "lvsi") // 参数化，防注入
}

标准库 database/sql 最小示例（最可控）

db, _ := sql.Open("mysql", dsn)
db.SetMaxOpenConns(50)  // 连接池上限
db.SetConnMaxLifetime(time.Hour)

var name string
err := db.QueryRow("SELECT name FROM user WHERE id = ?", 1).Scan(&name)
// 参数化占位符 ? 防止 SQL 注入

go-redis 最小示例（带连接池与 Pipeline）

rdb := redis.NewClient(&redis.Options{
    Addr:     "127.0.0.1:6379",
    Password: "",
    DB:       0,
    PoolSize: 100, // 连接池
})

if err := rdb.Set(ctx, "k", "v", time.Hour).Err(); err != nil {
    return err
}
val, _ := rdb.Get(ctx, "k").Result()

// Pipeline：一次 RTT 批量执行
pipe := rdb.Pipeline()
pipe.Set(ctx, "a", 1, 0)
pipe.Incr(ctx, "counter")
pipe.Exec(ctx)

服务端：net/http 最简（无需任何框架）

http.HandleFunc("/ping", func(w http.ResponseWriter, r *http.Request) {
    w.Header().Set("Content-Type", "application/json")
    w.Write([]byte(`{"ok":true}`))
})
http.ListenAndServe(":8080", nil)

客户端：resty 链式调用（含重试）

var resp map[string]interface{}
_, err := resty.New().
    SetRetryCount(3).
    SetTimeout(5 * time.Second).
    R().
    SetHeader("Authorization", token).
    SetResult(&resp).
    Get("https://api.example.com/user/1")

gRPC 客户端最小示例

conn, _ := grpc.Dial("127.0.0.1:9000", grpc.WithTransportCredentials(insecure.NewCredentials()))
defer conn.Close()
client := pb.NewUserClient(conn)
resp, _ := client.GetUser(ctx, &pb.GetUserReq{Id: 1})

viper 最小示例

v := viper.New()
v.SetConfigName("config")
v.SetConfigType("yaml")
v.AddConfigPath("./etc")
v.SetDefault("port", 8080)
v.ReadInConfig()

port := v.GetInt("port")
token := v.GetString("token") // 支持 ${ENV} 占位

validator 最小示例

type Signup struct {
    Email string `validate:"required,email"`
    Age   int    `validate:"gte=0,lte=150"`
}

v := validator.New()
err := v.Struct(Signup{Email: "a@b.com", Age: 20})
if _, ok := err.(validator.ValidationErrors); ok {
    // 逐字段错误信息，返回给前端
}

cobra 最小示例

var root = &cobra.Command{
    Use:   "app",
    Short: "demo cli",
    Run: func(cmd *cobra.Command, args []string) {
        fmt.Println("hello")
    },
}
func main() { root.Execute() }

testify 最小示例

func TestAdd(t *testing.T) {
    got := Add(1, 2)
    assert.Equal(t, 3, got)
    assert.NoError(t, nil)
}

errgroup 最小示例

g, ctx := errgroup.WithContext(context.Background())
for _, url := range urls {
    url := url
    g.Go(func() error {
        return fetch(ctx, url) // 任一失败，其余被取消
    })
}
if err := g.Wait(); err != nil { // 聚合第一个错误
}

最小示例

if err != nil {
    return fmt.Errorf("query user: %w", err) // 包装，保留链
}
// 调用方判断根因
if errors.Is(err, sql.ErrNoRows) { // 沿链匹配
}