Go에서 TCP 읽기 작업을 차단하는 방법은 무엇입니까?-Golang-php.cn

Go에서 TCP 읽기 작업을 차단하는 방법은 무엇입니까?

Linda Hamilton

풀어 주다： 2024-11-03 14:03:31

원래의

797명이 탐색했습니다.

How to Achieve Blocking TCP Read Operations in Go?

TCP Read in Go: 차단 및 비차단 작업 탐구

Go에서 TCP 연결을 위한 Read 메서드는 비차단 방식으로 작동합니다. - 차단 방식. 이는 전체 데이터를 사용할 수 없더라도 읽기 작업이 즉시 반환된다는 것을 의미합니다. 이로 인해 특정 양의 데이터를 읽으려고 할 때 또는 동기화된 데이터 전송이 필요한 프로토콜을 처리할 때 문제가 발생할 수 있습니다.

TCP 읽기 비차단이 왜 필요한가요?

네트워크 TCP와 같은 통신 프로토콜은 본질적으로 스트림과 같은 방식으로 데이터를 처리합니다. 이는 데이터가 조각으로 전송 및 수신될 수 있으며 단일 데이터 패킷의 끝을 구분하는 고유한 경계가 없음을 의미합니다.

Go에서 읽기 차단을 달성하는 방법

읽기 방법은 비차단 방식이지만 차단과 유사한 방식을 달성하는 기술이 있습니다. 동작:

io.ReadAtLeast: 이 메서드는 연결에서 최소 바이트 수를 읽습니다. 연결이 즉시 충분한 데이터를 제공하지 않으면 요청된 데이터가 수신될 때까지 메서드가 차단됩니다.
io.ReadFull: 이 메서드는 연결에서 지정된 바이트 수만큼 정확하게 읽습니다. 연결이 즉시 충분한 데이터를 제공하지 않으면 전체 데이터가 수신될 때까지 메서드가 차단됩니다.

부분 읽기 관리

Read 메서드에서 수신된 데이터가 예상보다 적으므로 부분 읽기에 대한 적절한 처리를 결정하는 것이 중요합니다. 프로토콜은 데이터 패킷이나 메시지의 끝을 나타내기 위해 구분 기호나 기타 메커니즘을 사용하는 경우가 많습니다.

오류 처리 기능이 있는 샘플 코드

제공된 코드 조각에서 Read 메서드는 제대로 사용되지 않습니다. 부분 읽기를 고려하고 오류를 처리하도록 코드를 수정해야 합니다.

<code class="go">// Server Code
package main

import (
    "fmt"
    "log"
    "net"
)

func main() {
    listener, err := net.ListenTCP("tcp", &net.TCPAddr{IP: net.ParseIP("127.0.0.1"), Port: 4243})
    if err != nil {
        log.Fatal(err)
    }
    defer listener.Close()
    for {
        conn, err := listener.AcceptTCP()
        if err != nil {
            log.Fatal(err)
        }
        conn.SetNoDelay(false)
        data := make([]byte, 512)
        for {
            n, err := conn.Read(data)
            if err != nil {
                fmt.Println(err)
                break
            }
            fmt.Println(data[:n])
        }
    }
}</code>

로그인 후 복사

<code class="go">// Client Code
package main

import (
    "log"
    "net"
)

func main() {
    conn, err := net.DialTCP("tcp", nil, &net.TCPAddr{IP: net.ParseIP("127.0.0.1"), Port: 4243})
    if err != nil {
        log.Fatal(err)
    }
    conn.SetNoDelay(false)
    conn.Write([]byte("Hello World"))
}</code>

로그인 후 복사

코드 전체에서 일관되게 오류를 확인하여 잠재적인 문제가 즉시 식별되고 처리되도록 해야 합니다.

위 내용은 Go에서 TCP 읽기 작업을 차단하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!