当前位置：首页 > 文章列表 > Golang > Go问答 > 无法通过 Golang 应用程序在 Kubernetes 中检测到 TCP 服务缺少 Pod

无法通过 Golang 应用程序在 Kubernetes 中检测到 TCP 服务缺少 Pod

来源：stackoverflow 2024-02-26 17:33:22 0浏览收藏

有志者，事竟成！如果你在学习Golang，那么本文《无法通过 Golang 应用程序在 Kubernetes 中检测到 TCP 服务缺少 Pod》，就很适合你！文章讲解的知识点主要包括，若是你对本文感兴趣，或者是想搞懂其中某个知识点，就请你继续往下看吧~

问题内容

我有一个 statsd 客户端，它通过 tcp 推送到 kubernetes 托管的 statsd 服务。

当我在服务器上重新部署服务并更新其 pod 时，数据停止流动，但 statsd 客户端上没有错误。

基于此线程，我在我的 golang 库中添加了读取检测，以查看是否收到消息，但什么也没有。

我启动连接，从客户端发送 statsd 数据包，然后一段时间后，我将 statsd 服务缩小到 0 个 pod，但客户端继续成功地从 tcp 通道读写，没有错误！

当我将部署规模缩小到 1 时，旧客户端不会重新连接，并且客户端和服务器将继续永远保持非通信状态。

当 kubernetes 服务中服务器副本变为 0 时，如何从客户端收到错误？

statsd 客户端是 https://github.com/alexcesaro/statsd 的一个分支

请注意，我们知道 statsd 主要用于 udp，但这是一种自定义风格，出于多种原因，我们需要 tcp 中的一个实例（已经有多个 udp 实例，并且没有此问题） p>

...
    c.w, err = net.DialTimeout(c.network, c.addr, 5*time.Second)
...

func (c *conn) checkTCPConnectionOpen() error {
    if c.network[:3] == "tcp" {
        one := []byte{}
        _, err := c.w.Read(one)
        return err
    }
    return nil
}

func (c *conn) flush(n int) {
    if len(c.buf) == 0 {
        return
    }
    if n == 0 {
        n = len(c.buf)
    }

    err := c.checkTCPConnectionOpen()
    c.handleError(err)

    _, err = c.w.Write(c.buf[:n])
    c.handleError(err)
    if n < len(c.buf) {
        copy(c.buf, c.buf[n:])
    }
    c.buf = c.buf[:len(c.buf)-n]
}