Go와 함께 WebSocket 서버 생성-Golang-php.cn

Go와 함께 WebSocket 서버 생성

Mary-Kate Olsen

풀어 주다： 2025-01-27 04:02:08

원래의

403명이 탐색했습니다.

Creating a WebSocket Server in Go with Gorilla

Gorilla로 실시간 Go WebSocket 서버 구축

WebSocket은 클라이언트와 서버 간의 실시간 양방향 통신을 위한 강력한 솔루션을 제공합니다. 이 튜토리얼에서는 인기 있는 Gorilla WebSocket 라이브러리를 활용하여 Go에서 WebSocket 서버를 생성하는 과정을 안내합니다.

WebSocket과 Gorilla의 이해

WebSocket은 HTTP의 요청-응답 모델과 달리 지속적인 전이중 통신 채널을 제공합니다. 이러한 지속적인 연결을 통해 효율적이고 지속적인 데이터 교환이 가능합니다.

Gorilla WebSocket 라이브러리는 Go에서 WebSocket 구현을 단순화하여 핸드셰이크, 메시지 I/O 및 연결 수명 주기를 관리합니다.

프로젝트 설정

이 튜토리얼에서는 기본 WebSocket 서버와 클라이언트를 구축합니다.

연결을 허용하는 WebSocket 서버.
서버와 상호작용하는 클라이언트.

디렉토리 구조

다음과 같이 프로젝트를 구성하세요.

<code>websocket-server/
├── main.go           # Application entry point
├── handlers/         # WebSocket handler functions
│   └── websocket.go  # Handles WebSocket connections and messages
├── static/           # Client-side HTML/JS files
│   └── index.html    # Simple client interface
└── go.mod            # Go module file</code>

로그인 후 복사

고릴라 웹소켓 설치

Gorilla WebSocket 패키지 설치:

<code class="language-bash">go get -u github.com/gorilla/websocket</code>

로그인 후 복사

WebSocket 서버 구축

1단계: `main.go`

만들기 main.go:

<code class="language-go">package main

import (
    "fmt"
    "log"
    "net/http"
    "websocket-server/handlers"
)

func main() {
    http.HandleFunc("/ws", handlers.HandleWebSocket)
    http.Handle("/", http.FileServer(http.Dir("./static")))
    port := ":8080"
    fmt.Printf("Server running on http://localhost%s\n", port)
    log.Fatal(http.ListenAndServe(port, nil))
}</code>

로그인 후 복사

/ws에서 HTTP 서버를 설정하고 정적 파일을 제공하며 WebSocket 연결을 처리합니다.

2단계: WebSocket 핸들러(`websocket.go`)

handlers 디렉토리에서 websocket.go:

를 생성합니다.

<code class="language-go">package handlers

import (
    "fmt"
    "net/http"

    "github.com/gorilla/websocket"
)

var upgrader = websocket.Upgrader{
    CheckOrigin: func(r *http.Request) bool { return true },
}

func HandleWebSocket(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        fmt.Println("Upgrade failed:", err)
        return
    }
    defer conn.Close()
    fmt.Println("Client connected")
    for {
        _, msg, err := conn.ReadMessage()
        if err != nil {
            fmt.Println("Read failed:", err)
            break
        }
        fmt.Printf("Received: %s\n", msg)
        if err := conn.WriteMessage(websocket.TextMessage, msg); err != nil {
            fmt.Println("Write failed:", err)
            break
        }
    }
}</code>

로그인 후 복사

이 핸들러는 HTTP 연결을 업그레이드하고 메시지를 읽고 다시 에코합니다.