套接字问题：goroutine陷入无限循环以及打开文件过多错误

小伙伴们有没有觉得学习Golang很有意思？有意思就对了！今天就给大家带来《套接字问题：goroutine陷入无限循环以及打开文件过多错误》，以下内容将会涉及到，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

我的程序要求无限期地向 datadog 发送指标（以便在 datadog 中进行连续的应用程序监控）。程序运行一段时间后退出，出现错误“dial udp 127.0.0.1:18125:socket:too much open files”。

func sendData(name []string, channel chan []string) {
      c, err := statsd.New("127.0.0.1:18125")
      if err != nil {
        log.Fatal(err)
      }

      v := versionDetails()
      tag := "tag:" + v
      final_tag := []string{dd_tags}
      appEpochTimeList := epochTime()
      rate := float64(1)

      for i, app := range name {
        e := c.Gauge(app, float64(appEpochTimeList[i]), final_tag , rate)
        if e != nil {
            log.Println(e)
            channel <- name
        }
        channel <- name
        log.Printf("Metrics Sent !!")
      }
  }

应用程序名称是从 config.toml 文件中读取的

解决方案

问题是您的 senddata() 函数。该函数在 for 循环中调用，并具有以下行：

c, err := statsd.new("127.0.0.1:18125")

该行将创建一个新的 datadog 客户端，它使用 unix 套接字。这解释了您的错误消息。

循环的每次迭代都会“分配”一个新的套接字。经过足够数量的循环后，无法打开套接字，导致：

套接字：打开的文件太多

要解决此问题，您应该仅创建一次客户端并将其作为参数传递给您的方法。

func sendData(client *statsd.Client, name []string, channel chan []string) {
    // do something with client...
}

func main() {
    client, err := statsd.New("127.0.0.1:18125")
    if err != nil {
        log.Fatal(err)
    }

    // do something else ...

    for res := range channel {
        go func(client *statsd.Client, appName []string) {
            time.Sleep(5 * time.Second)
            go sendData(client, appName, channel)
        }(client, res)
    }
}

到这里，我们也就讲完了《套接字问题：goroutine陷入无限循环以及打开文件过多错误》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！