Go에서 Unix 소켓을 사용하여 양방향 통신을 달성하는 방법은 무엇입니까?

Go의 Unix 소켓: 양방향 통신 설정

Unix 소켓을 사용하여 간단한 클라이언트-서버 아키텍처를 구현하려고 시도했지만 문제에 직면했습니다. 단방향 데이터 흐름 문제. 코드를 자세히 살펴보고 문제를 해결해 보겠습니다.

클라이언트 코드에서 서버에 메시지를 성공적으로 보냈지만 서버가 응답하지 않습니다. 이는 서버의 응답을 읽는 중요한 단계를 놓치고 있음을 의미합니다. 아래 수정된 클라이언트 코드에는 서버에서 데이터 읽기를 처리하기 위한 리더 고루틴을 추가했습니다.

// Client code with a reader goroutine
package main

import (
    "io"
    "log"
    "net"
    "time"
)

func reader(r io.Reader) {
    buf := make([]byte, 1024)
    for {
        n, err := r.Read(buf[:])
        if err != nil {
            return
        }
        println("Client got:", string(buf[0:n]))
    }
}

func main() {
    c, err := net.Dial("unix", "/tmp/echo.sock")
    if err != nil {
        panic(err)
    }
    defer c.Close()

    go reader(c)
    for {
        _, err := c.Write([]byte("hi"))
        if err != nil {
            log.Fatal("write error:", err)
            break
        }
        time.Sleep(1e9)
    }
}

서버 측에서는 코드가 올바르게 보입니다. 그러나 아래 수정된 서버 코드에 표시된 것처럼 고루틴의 오류를 처리하고 완료되면 연결을 닫는 것이 필수적입니다.

// Server code with error handling and connection closing
package main

import (
    "log"
    "net"
)

func echoServer(c net.Conn) {
    defer c.Close()  // Ensure connection is closed when the goroutine exits

    for {
        buf := make([]byte, 512)
        nr, err := c.Read(buf)
        if err != nil {
            log.Fatal("read error:", err)
        }

        data := buf[0:nr]
        _, err = c.Write(data)
        if err != nil {
            log.Fatal("write error:", err)
        }
    }
}

func main() {
    l, err := net.Listen("unix", "/tmp/echo.sock")
    if err != nil {
        log.Fatal("listen error:", err)
    }

    for {
        fd, err := l.Accept()
        if err != nil {
            log.Fatal("accept error:", err)
        }

        go echoServer(fd)
    }
}

이러한 수정이 적용되면 이제 클라이언트-서버 통신이 완전히 양방향이 되어야 합니다. 방향성이 있어 데이터가 양방향으로 흐를 수 있습니다.

위 내용은 Go에서 Unix 소켓을 사용하여 양방향 통신을 달성하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!