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

标签 sockets tcp go

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

最佳答案

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

如果您在端口 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)
    }
}

您应该会在按下回车键后立即看到发送给客户端的每一行都被打印出来(没有换行符)。

关于sockets - golang tcp 套接字在写入后不立即发送消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/17915952/

相关文章:

sockets - 如何在TCP连接中实现请求响应?

linux - 当 FIN 被接收且套接字发送缓冲区中仍有数据时,系统会做什么?

mongodb - mgo NewObjectId 在插入时损坏

oracle - 如何解析层级数据

c - 如何修复 GCC 错误 : "asm/socket.h: No such file" on Sli-Taz Linux?

linux - 如何刷新原始 AF_PACKET 套接字以获取正确的过滤数据包

java - 套接字未从服务器接收或发送消息

c - 使用 INADDR_LOOPBACK 的环回示例不起作用

go - 使用文件方案读取 url 作为 ReadFile 文件名的惯用方法是什么?

sockets - 套接字编程 - 多人射击游戏服务器如何处理计时?