4

私の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
}
4

2 に答える 2

7

コードに重大な問題があるようには見えないので、エラーはサーバー側にあると推測しています。

ポート 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)
    }
}

Enterキーを押すとすぐに、クライアントに送信された各行が（改行なしで）印刷されるはずです。

于 2013-07-29T04:56:26.790 に答える