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

有志者，事竟成！如果你在学习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]
}

解决方案

好吧，这不是 Kubernetes 问题，而是 golang 问题。

这基本上是 How to know TCP connection is closed in Golang net package? 的重复

您想要使用 TCP 连接是否有特殊原因？看起来 Statsd 支持 UDP 模式 see here。如果您选择通过 UDP 运行服务器，那么您在 Statsd 客户端上实现弹性的愿望似乎会得到更好的满足。

以上就是《无法通过 Golang 应用程序在 Kubernetes 中检测到 TCP 服务缺少 Pod》的详细内容，更多关于的资料请关注golang学习网公众号！