Go WebSocket은 양방향 통신을 어떻게 구현합니까?

Go 언어에는 WebSocket에 대한 지원이 내장되어 있으며 다음 단계를 통해 양방향 통신을 달성할 수 있습니다. WebSocket 서버 생성: HTTP 핸들러 함수를 생성합니다. HTTP 요청을 업그레이드하기 위한 업그레이드 구조를 생성합니다. WebSocket 서버를 시작합니다. WebSocket 클라이언트 생성: HTTP 요청을 생성하고 WebSocket 헤더를 설정합니다. 다이얼러 구조를 만듭니다. Dial 메서드를 사용하여 연결을 설정합니다.

Go WebSocket: 양방향 통신 가능

WebSocket은 단일 영구 TCP 연결을 통해 클라이언트와 서버 간에 실시간 데이터 교환을 허용하는 양방향 통신 프로토콜입니다. Go 언어는 개발자에게 WebSocket에 대한 기본 지원을 제공하여 양방향 통신을 간단하고 간단하게 만듭니다.

WebSocket 서버 생성

WebSocket 서버 생성에는 세 단계가 필요합니다:

1. net/http 패키지를 사용하여 http.Handler 함수를 생성합니다. WebSocket 연결을 처리합니다. net/http 包创建 http.Handler 函数，该函数处理 WebSocket 连接。
2. 创建 websocket.Upgrader 结构体，该结构体将 HTTP 请求升级为 WebSocket 连接。
3. 使用 http.ServeHTTP 方法启动 WebSocket 服务端。

package main

import (
    "log"
    "net/http"

    "github.com/gorilla/websocket"
)

func main() {
    // HTTP 处理程序
    handler := func(w http.ResponseWriter, r *http.Request) {
        upgrader := websocket.Upgrader{}
        conn, err := upgrader.Upgrade(w, r, nil)
        if err != nil {
            log.Fatal(err)
        }
        defer conn.Close()

        for {
            messageType, message, err := conn.ReadMessage()
            if err != nil {
                log.Fatal(err)
            }
            if messageType == websocket.CloseMessage {
                log.Println("Client closed connection")
                return
            }
            log.Printf("Received from client: %s", string(message))
            err = conn.WriteMessage(messageType, []byte("Echoed: "+string(message)))
            if err != nil {
                log.Fatal(err)
            }
        }
    }

    // 启动 WebSocket 服务端
    http.HandleFunc("/websocket", handler)
    err := http.ListenAndServe(":8080", nil)
    if err != nil {
        log.Fatal(err)
    }
}

创建 WebSocket 客户端

创建 WebSocket 客户端同样需要三步：

1. 使用 net/http 包创建 http.Request，并设置 "Upgrade: WebSocket" 头。
2. 创建 websocket.Dialer 结构体，该结构体用于建立 WebSocket 连接。
3. 使用 Dial
HTTP 요청을 WebSocket 연결로 업그레이드하는 websocket.Upgrader 구조를 만듭니다.

http.ServeHTTP 메서드를 사용하여 WebSocket 서버를 시작하세요.

🎜

package main

import (
    "fmt"
    "log"

    "github.com/gorilla/websocket"
)

func main() {
    dialers := websocket.Dialer{
        ReadBufferSize:  1024,
        WriteBufferSize: 1024,
    }

    conn, _, err := dialers.Dial("ws://localhost:8080/websocket", nil)
    if err != nil {
        log.Fatal(err)
    }
    defer conn.Close()

    for i := 0; i < 10; i++ {
        message := fmt.Sprintf("Hello from client %d", i)
        err := conn.WriteMessage(websocket.TextMessage, []byte(message))
        if err != nil {
            log.Fatal(err)
        }

        _, message, err = conn.ReadMessage()
        if err != nil {
            log.Fatal(err)
        }
        log.Printf("Received echo: %s", string(message))
    }
}

🎜🎜WebSocket 클라이언트 생성🎜🎜🎜WebSocket 클라이언트 생성에도 세 단계가 필요합니다. 🎜🎜🎜net/http 패키지를 사용하여 http.Request를 생성하고 "Upgrade: WebSocket" 헤더를 설정하세요. 🎜🎜WebSocket 연결을 설정하는 데 사용되는 websocket.Dialer 구조를 만듭니다. 🎜🎜다이얼 방법을 사용하여 연결을 설정하세요. 🎜🎜rrreee🎜이러한 단계를 통해 Go에서 WebSocket 양방향 통신을 쉽게 구현하고 애플리케이션에 실시간 상호 작용 기능을 추가할 수 있습니다. 🎜

위 내용은 Go WebSocket은 양방향 통신을 어떻게 구현합니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!