从 golang 中的 tcp 连接读取答案

【问题标题】：Reading from a tcp connection in golang从 golang 中的 tcp 连接读取
【发布时间】：2016-01-20 05:54:57
【问题描述】：

在类似 bytes_read, err := conn.Read(tmp) 的语句中，我希望尝试读取 x 秒，如果没有开始读取，我希望代码继续检查一些连接，然后再次循环并尝试读。我可以使用 select-case 并生成两个 goroutine，一个尝试读取，另一个用于超时。但是在这里，如果首先发生超时，代码将继续执行，检查条件并再次生成一个例程以尝试从连接中读取，而之前的读取例程仍然存在。我希望之前的例程在超时发生时终止。

有什么建议可以继续吗？

【问题讨论】：

也许你需要的只是 SetReadDeadline 用于 conn。 if netErr, ok := err.(net.Error); ok && netErr.Timeout() doSomething
@Justlike 谢谢！这就是我需要的。但是你能帮我语法吗？我正在使用 err2 := conn.SetReadDeadline(time.Now().Add(5 * time.Second)) | bytes_read, err := conn.Read(tmp) | err.Timeout() 导致 err.Timeout 未定义的错误（类型错误没有字段或方法 Timeout）。我想检查 Timeout() 是真还是假
^_^ 查看下面的帖子。

标签： go architecture network-programming server distributed

【解决方案1】：

希望这可以帮助你。 ^_^

for {
    // set SetReadDeadline
    err := conn.SetReadDeadline(time.Now().Add(5 * time.Second))
    if err != nil {
        log.Println("SetReadDeadline failed:", err)
        // do something else, for example create new conn
        return
    }

    recvBuf := make([]byte, 1024)

    n, err = conn.Read(recvBuf[:]) // recv data
    if err != nil {
        if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
            log.Println("read timeout:", err)
            // time out
        } else {
            log.Println("read error:", err)
            // some error else, do something else, for example create new conn
        }
    }
}

【讨论】：