套接字 – golang tcp套接字在立即写入后不发送消息

发布时间：2020-12-16 09:24:24 所属栏目：大数据来源：网络整理

导读：我的GO版本是1.1.1 连接关闭后,服务器收到消息,但是设置了NoDelay. 有什么不对 addr,_ := net.ResolveTCPAddr("tcp","localhost:5432")conn,err := net.DialTCP("tcp",nil,addr)defer conn.Close()if err != nil { fmt.Println("connect fail") return}err =

我的GO版本是1.1.1

连接关闭后,服务器收到消息,但是设置了NoDelay.

有什么不对

addr,_ := net.ResolveTCPAddr("tcp","localhost:5432")
conn,err := net.DialTCP("tcp",nil,addr)
defer conn.Close()
if err != nil {
    fmt.Println("connect fail")
    return
}
err = conn.SetNoDelay(true)
if err != nil {
    fmt.Println(err.Error())
}

for {
    var message string
    _,err := fmt.Scanln(&message)
    if err != nil && err.Error() != "unexpected newline" {
        fmt.Println("input finished",err)
        break
    }

    if message == "" {
        fmt.Println("no input,end")
        break
    }
    // message = fmt.Sprintf("%sn",message) 
    //fmt.Fprintf(conn,message) // send immediately but following message won't send any more
    conn.Write([]byte(message)) // won't send until connection close
}

解决方法

您的代码似乎没有任何重大错误,所以我猜测错误是在服务器端.

如果在端口5432上创建本地TCP服务器,则可以对此进行测试.

尝试运行以下服务器代码,然后针对它测试客户端代码.它只是将所有收到的数据发送到stdout.

package main

import (
    "io"
    "log"
    "net"
    "os"
)

func main() {
    l,err := net.Listen("tcp","localhost:5432")
    if err != nil {
        log.Fatal(err)
    }
    defer l.Close()
    for {
        conn,err := l.Accept()
        if err != nil {
            log.Fatal(err)
        }
        go func(c net.Conn) {
            defer c.Close()
            io.Copy(os.Stdout,c)
        }(conn)
    }
}

您应该在输入后立即看到打印到客户端的每一行(没有换行符).

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!