Go의 `net.Conn.Read` 함수는 TCP 메시지 경계를 어떻게 처리합니까?

Go의 TCP 소켓 읽기 기능 이해

영구 TCP 소켓의 경우 중요한 측면 중 하나는 들어오는 데이터를 처리하는 것입니다. 효과적으로. net.Conn.Read 함수는 이러한 목적으로 일반적으로 사용되지만 메시지 경계를 어떻게 결정하는지에 대한 의문이 제기됩니다.

TCP 메시지 프레이밍

다른 통신 프로토콜과 달리 , TCP는 본질적으로 메시지 프레이밍을 제공하지 않습니다. 메시지 경계를 나타내는 구분 기호 없이 데이터를 연속적인 바이트 스트림으로 처리합니다. 따라서 프레이밍 메커니즘을 정의하고 구현하는 것은 애플리케이션 계층의 책임입니다.

Go의 접근 방식

Go의 net.Conn 구현에서는 메시지 프레이밍이 다음에서 처리된다고 가정합니다. 응용 프로그램 수준. 이를 통해 애플리케이션은 원시 바이트 스트림을 읽고 정의된 프로토콜에 따라 이를 해석할 수 있습니다.

사용 예

질문에 제공된 코드는 다음을 사용하여 데이터를 수신하는 방법을 보여줍니다. net.Conn.Read in a loop:

func (tcpSocket *TCPServer) HandleConnection(conn net.Conn) {
    for {
        // Read message size and data without any message framing
        messageSize, err := conn.Read(recieveBuffer)
        if err != nil {
            return
        }
        // ...
    }
}

코드가 메시지 크기를 명시적으로 정의하지 않기 때문에 문제가 발생합니다. 수신된 바이트 스트림 내에서 결정됩니다.

해결책: Bufio Reader 및 수동 구문 분석

이 문제를 해결하려면 TCP 연결을 bufio.Reader로 래핑하는 것이 좋습니다. . 이는 스트림을 구문 분석하는 데 더 효율적이고 편리한 방법을 제공합니다. bufio.Reader를 사용하여 메시지 프레이밍을 구현하는 방법에 대한 예:

buff := make([]byte, 50)
c := bufio.NewReader(conn)

for {
    // Read message length from the first byte
    size, err := c.ReadByte()
    if err != nil {
        return err
    }
    // Read the remaining message data
    _, err := io.ReadFull(c, buff[:int(size)])
    if err != nil {
        return err
    }
    fmt.Printf("Received %x\n", buff[:int(size)])
}

이 예에서는 먼저 단일 바이트를 읽어 메시지 크기를 결정합니다. 그런 다음 io.ReadFull을 사용하여 메시지의 나머지 바이트를 읽습니다. 이 접근 방식은 명시적인 메시지 프레이밍을 제공하고 다양한 크기의 메시지로 작업할 수 있게 해줍니다.

TCP 메시지 프레이밍의 작동 방식을 이해하고 bufio.Reader와 같은 적절한 도구를 활용하면 영구 TCP 소켓에서 들어오는 데이터를 효과적으로 처리할 수 있습니다. 가세요.

위 내용은 Go의 `net.Conn.Read` 함수는 TCP 메시지 경계를 어떻게 처리합니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!