Go TCP 読み取りはノンブロッキングです: 不完全なデータ受信に対処します
Go では、TCP 読み取りはノンブロッキングです。つまり、すぐに戻ります。たとえそれが予想よりも少なかったとしても、利用可能なデータがあれば。この動作は、必要な量のデータが受信されるまで待機する C のブロッキング読み取りとは異なります。
ノンブロッキング読み取りの理由
TCP はバイトのストリームとして動作します。 、送信中に断片化される可能性があります。したがって、受信したバイト数のみに基づいてメッセージの終わりを判断することは不可能です。これには、メッセージ境界を決定するためのカスタム区切り文字またはその他のメカニズムが必要です。
不完全なデータに対する解決策
特定のバイト数を読み取るには、io.ReadAtLeast または io.ReadFull を使用します。 。任意の条件については、エラーがなくなるか、指定された条件が満たされるまで Read 呼び出しをループします。
例:
<code class="go">package main import ( "fmt" "net" "time" ) func main() { conn, _ := net.Dial("tcp", "127.0.0.1:4243") // Set a deadline to prevent hanging reads _ = conn.SetReadDeadline(time.Now().Add(10 * time.Second)) // Loop to read until a newline is encountered for { buf := make([]byte, 512) n, err := conn.Read(buf) if err != nil { fmt.Println(err) break } if n > 0 { str := string(buf[:n]) if str[len(str)-1] == '\n' { fmt.Println(str) break } } } }</code>
その他の考慮事項
以上がGo のノンブロッキング TCP 読み取りで不完全なデータ受信を処理するにはどうすればよいですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。