Panduan Pembangunan Soket Web golang: Melaksanakan fungsi pengurusan jadual dalam talian berbilang orang-Golang-php.cn

Panduan Pembangunan Soket Web golang: Melaksanakan fungsi pengurusan jadual dalam talian berbilang orang

WBOY

Lepaskan： 2023-12-02 09:09:26

asal

673 orang telah melayarinya

golang Websocket开发指南：实现多人在线日程管理功能

Panduan Pembangunan Soket Web Golang: Melaksanakan Fungsi Pengurusan Jadual Dalam Talian Berbilang Orang

Pengenalan:
Dengan kadar pantas dan keperluan pelbagai tugas dalam kehidupan moden, kita sering perlu membuat pelarasan dan penyelarasan dalam jadual. Fungsi pengurusan jadual dalam talian berbilang orang boleh membantu berbilang orang bekerjasama dan berkongsi jadual dalam masa nyata, meningkatkan kecekapan kerja. Artikel ini akan memperkenalkan cara menggunakan teknologi Golang dan Websocket untuk melaksanakan fungsi pengurusan jadual dalam talian berbilang orang dan melampirkan contoh kod khusus. . Mulakan modul Go baharu menggunakan arahan berikut:

go mod init schedule

Salin selepas log masuk

go get -u github.com/gin-gonic/gin
go get -u github.com/gorilla/websocket

Salin selepas log masuk

Buat pelayan Websocket:

main.go

package main

import (
    "log"
    "net/http"

    "github.com/gin-gonic/gin"
    "github.com/gorilla/websocket"
)

func main() {
    router := gin.Default()

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

    router.GET("/ws", func(c *gin.Context) {
        conn, err := upgrader.Upgrade(c.Writer, c.Request, nil)
        if err != nil {
            log.Println("Failed to upgrade connection:", err)
            return
        }

        // TODO: 处理连接和消息
    })

    router.Run(":8000")
}

Salin selepas log masuk

Dalam kod di atas, kami menggunakan rangka kerja Gin untuk mencipta HTTP mudah pelayan, dan mendaftarkan laluan Websocket pada laluan /ws. Dalam fungsi pemprosesan penghalaan, kami menaik taraf sambungan HTTP Naik Taraf kepada sambungan Websocket dan mendapatkan sambungan yang diwujudkan dengan klien.
```
connections := make(map[*websocket.Conn]bool) // 存储所有连接的映射表

router.GET("/ws", func(c *gin.Context) {
    conn, err := upgrader.Upgrade(c.Writer, c.Request, nil)
    if err != nil {
        log.Println("Failed to upgrade connection:", err)
        return
    }

    connections[conn] = true

    for {
        _, msg, err := conn.ReadMessage()
        if err != nil {
            log.Println("Error reading message:", err)
            delete(connections, conn)
            conn.Close()
            break
        }

        // 广播消息给所有连接
        for conn := range connections {
            err := conn.WriteMessage(websocket.TextMessage, msg)
            if err != nil {
                log.Println("Error broadcasting message:", err)
                delete(connections, conn)
                conn.Close()
            }
        }
    }
})
```
Salin selepas log masuk
Dalam kod di atas, kami menggunakan jadual pemetaan sambungan untuk menyimpan semua sambungan. Apabila sambungan baharu diwujudkan, kami menambah sambungan pada jadual pemetaan. Pada masa yang sama, kami membaca mesej daripada pelanggan melalui gelung tak terhingga dan menyiarkan mesej itu ke semua sambungan.