使用Echo构建Go服务遇dig注入错误：缺失类型及连接问题排查

从错误日志和代码来看，问题出在两个核心环节：dig依赖注入的缺失配置和GRPC连接生命周期管理不当。

核心错误原因 #

1. dig无法构造NotificationsRepositoryImpl实例
   错误日志中missing type: grpc.NotificationsRepositoryImpl明确指出，dig容器找不到该类型的构造方式。你的NotificationsRepositoryImpl结构体没有添加dig.In标签，导致dig无法识别它的内部依赖（Registry、Client），同时你可能也没有将该结构体的构造逻辑正确注册到dig容器中。

2. GRPC连接提前关闭
   错误中的close tcp [::]:30504: use of closed network connection说明，在dig尝试注入GRPC相关依赖时，对应的网络连接已经被关闭，导致依赖初始化失败。

具体修复步骤 #

1. 修复dig注入配置 #

• 给NotificationsRepositoryImpl添加dig.In标签，让dig能自动解析其内部依赖：

  // internal/app/repo/grpc/notifications.contract.go
  package grpc
  
  type (
    NotificationsRepositoryImpl struct {
      dig.In  // 添加这行标签
      Registry grpc.RegistryGrpcConnection
      Client   packets.NotificationsClient
      Connected bool
    }
  )
  

• 确保将所有相关构造函数注册到dig容器中，包括NotificationsRepository、RegistryGrpcConnection和NotificationsClient：

  // 在容器初始化的代码中（比如main.go或类似的启动文件）
  func initDI() (*dig.Container, error) {
    di := dig.New()
  
    // 注册NotificationsRepository
    if err := di.Provide(grpc.NewNotificationsRepository); err != nil {
      return nil, err
    }
  
    // 注册RegistryGrpcConnection（假设你有对应的构造函数）
    if err := di.Provide(grpc.NewRegistryGrpcConnection); err != nil {
      return nil, err
    }
  
    // 注册NotificationsClient（根据你的实际构造逻辑）
    if err := di.Provide(func(reg grpc.RegistryGrpcConnection) (packets.NotificationsClient, error) {
      return packets.NewNotificationsClient(reg.Conn), nil
    }); err != nil {
      return nil, err
    }
  
    // 注册其他依赖，比如UserSvc、HttpCtrl等
    if err := di.Provide(service.NewUserSvc); err != nil {
      return nil, err
    }
  
    return di, nil
  }
  

2. 修复GRPC连接生命周期 #

• 确保GRPC连接由dig容器托管，避免提前关闭。给连接类型添加销毁钩子，在容器关闭时再关闭连接：

  // internal/app/repo/grpc/registry.go（示例）
  package grpc
  
  type RegistryGrpcConnection struct {
    Conn *grpc.ClientConn
  }
  
  func NewRegistryGrpcConnection(cfg *infra.App) (*RegistryGrpcConnection, error) {
    conn, err := grpc.Dial(cfg.GRPCRegistryAddr, grpc.WithInsecure())
    if err != nil {
      return nil, err
    }
    return &RegistryGrpcConnection{Conn: conn}, nil
  }
  
  // 定义关闭方法
  func (r *RegistryGrpcConnection) Close() error {
    return r.Conn.Close()
  }
  
  // 注册时添加销毁钩子
  if err := di.Provide(NewRegistryGrpcConnection, dig.Dispose(func(r *RegistryGrpcConnection) error {
    return r.Close()
  })); err != nil {
    return nil, err
  }
  

• 检查代码中是否有提前关闭GRPC连接的逻辑，比如错误的defer conn.Close()放在了构造函数外部，导致连接在注入前就被销毁。

3. 验证依赖链完整性 #

使用dig的Inspect方法检查容器中的注册项，确认所有依赖都已正确注册：

if err := di.Inspect(func(i *dig.InspectInfo) {
  fmt.Println("已注册的依赖提供者：")
  for _, s := range i.Providers {
    fmt.Printf("- %v\n", s.Func)
  }
}); err != nil {
  log.Fatalf("检查容器注册项失败：%v", err)
}

额外注意事项 #

• 同包内其他仓库出现相同问题，说明是通用的配置错误，按照上述步骤统一修复即可。
• 确保所有依赖的构造函数返回值和参数类型与容器中的注册项匹配，避免类型不兼容导致的注入失败。

内容的提问来源于stack exchange，提问作者new line