dqc22586 2013-07-29 04:15
浏览 133
已采纳

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

My GO version is 1.1.1

the sever recieved messages after connection close, but NoDelay was setted.

Is there something wrong

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
",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
}
  • 写回答

2条回答 默认 最新

  • dousheng3364 2013-07-29 04:56
    关注

    There doesn't seem to be anything vitally wrong with your code so I'm guessing the error is on the server end.

    If you create a local TCP server on port 5432 you can test this.

    Try running the below server code and then test your client code against it. It just echos all received data to 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)
        }
    }
    

    You should see each line sent to the client printed (without the newline) as soon as you hit enter.

    本回答被题主选为最佳回答 , 对您是否有帮助呢?
    评论
查看更多回答(1条)

报告相同问题?

悬赏问题

  • ¥60 版本过低apk如何修改可以兼容新的安卓系统
  • ¥25 由IPR导致的DRIVER_POWER_STATE_FAILURE蓝屏
  • ¥50 有数据,怎么建立模型求影响全要素生产率的因素
  • ¥50 有数据,怎么用matlab求全要素生产率
  • ¥15 TI的insta-spin例程
  • ¥15 完成下列问题完成下列问题
  • ¥15 C#算法问题, 不知道怎么处理这个数据的转换
  • ¥15 YoloV5 第三方库的版本对照问题
  • ¥15 请完成下列相关问题!
  • ¥15 drone 推送镜像时候 purge: true 推送完毕后没有删除对应的镜像,手动拷贝到服务器执行结果正确在样才能让指令自动执行成功删除对应镜像,如何解决?