go - 从 golang 中的 tcp 连接读取

标签 go architecture network-programming server distributed

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

有什么建议可以继续吗?

最佳答案

希望对您有所帮助。 ^_^

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
        }
    }
}

关于go - 从 golang 中的 tcp 连接读取,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34892507/

相关文章:

Golang amqp 重新连接

PHP - 扩展、库与类 - 何时以及为何

database - 从数据层填充域模型,还是直接查询数据库?

architecture - 面向对象分析与设计: can a process be a class?

java - 我如何知道是使用标准 Java 网络还是 Java RMI?

wcf - 有谁知道使用 WCF 为非 .NET 客户端公开 SOAP 接口(interface)的任何问题?

去阅读谷歌电子表格

go - 使用计数器,如何在服务器崩溃后继续计数?

go - 将 map 嵌入到go语言的结构中

c# - 实时环境中的 WCF 或套接字通信?