與大猩猩一起創建WebSocket服務器-Golang-PHP中文網

與大猩猩一起創建WebSocket服務器

Mary-Kate Olsen

發布： 2025-01-27 04:02:08

原創

403 人瀏覽過

Creating a WebSocket Server in Go with Gorilla

>使用大猩猩

建構即時GO Websocket伺服器 Websockets為客戶和伺服器之間的即時雙向通訊提供了強大的解決方案。本教學指導您透過在GO中建立WebSocket伺服器，利用流行的Gorilla Websocket庫。

目錄的

了解Websocket和Gorilla

與HTTP的Request-Response模型不同，Websocket提供了持續的全雙工通訊管道。這種恆定的連接允許有效，連續的資料交換。

>大猩猩Websocket庫簡化了Websocket在GO中的實現，管理握手，訊息I/O和連接生命週期。

>項目設定

本教學建構了基本的WebSocket伺服器與客戶端：

> websocket伺服器接受連線。

客戶與伺服器互動的客戶

目錄結構
整理您的專案如下：

>安裝大猩猩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>

登入後複製

>建置Websocket伺服器

>步驟1：

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

登入後複製

建立

：

`main.go`這設定了HTTP伺服器，提供靜態文件，並在

>中處理WebSocket連接

步驟2：websocket處理程序（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：

`websocket.go`這個處理程序升級HTTP連接，讀取訊息並迴聲。

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>

登入後複製

處理傳入訊息。您可以將其擴展到實現廣播或訊息持久性之類的功能。

運行應用程式

>步驟1：簡單客戶端（

）HandleWebSocket

>建立

在