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

Question

我的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("%s\n",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}

Answer 1

您的代码似乎没有任何严重错误，所以我猜测错误出在服务器端。

如果您在端口 5432 上创建本地 TCP 服务器，您可以对此进行测试。

尝试运行以下服务器代码，然后针对它测试您的客户端代码。它只是将所有接收到的数据回显到标准输出。

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)

    }

}

按下回车键后，您应该会看到发送到客户端的每一行都被打印出来（没有换行符）。

Answer 2

问题出在服务器端。

func handleConnection(conn net.Conn) {

// I didn't put it in for loop

message, err := bufio.NewReader(conn).ReadString('\n')

}