与大猩猩一起创建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

>创建

在