最佳实践与避坑指南

// ✅ 正确：所有依赖在 ServiceContext 中初始化
type ServiceContext struct {
    Config      config.Config
    UserModel   model.UserModel
    UserRpc     user.User
    Redis       *redis.Redis
    KqPusher    *kq.Pusher
}

func NewServiceContext(c config.Config) *ServiceContext {
    return &ServiceContext{
        Config:    c,
        UserModel: model.NewUserModel(sqlx.NewMysql(c.DataSource), c.Cache),
        UserRpc:   user.NewUser(zrpc.MustNewClient(c.UserRpcConf)),
        Redis:     redis.NewRedis(c.Redis.Host, ""),
        KqPusher:  kq.NewPusher(c.KafkaConf.Brokers, c.KafkaConf.Topic),
    }
}

// ❌ 错误：在 logic 里临时创建连接
func (l *MyLogic) DoSomething() error {
    conn := sqlx.NewMysql(dsn)  // 不可以！
    // ...
}

✅ 推荐：
  API → User RPC → Order RPC → Payment RPC （单向）

❌ 禁止：
  API → User RPC → Order RPC → User RPC （循环调用）

// 串行改并行 — 使用 core/mr 包
import "github.com/zeromicro/go-zero/core/mr"

func (l *OrderLogic) GetOrderDetail(id int64) (*OrderDetail, error) {
    var user *userRpc.GetUserResp
    var product *productRpc.GetProductResp

    err := mr.Finish(func() error {
        user, err = l.svcCtx.UserRpc.GetUser(ctx, &userRpc.GetUserReq{Id: userId})
        return err
    }, func() error {
        product, err = l.svcCtx.ProductRpc.GetProduct(ctx, &productRpc.GetProductReq{Id: productId})
        return err
    })
    // ...
}

// ✅ 正确：结构化日志 + trace_id
logx.WithContext(ctx).Infow("order created",
    logx.Field("orderId", orderId),
    logx.Field("userId", userId),
)

// ❌ 错误：普通日志，丢失 trace_id
log.Printf("order created: %d", orderId)