Melaksanakan Komunikasi WebSocket dan Mekanisme Denyutan Jantung dengan GoFrame: Panduan Praktis-Golang-php.cn

Melaksanakan Komunikasi WebSocket dan Mekanisme Denyutan Jantung dengan GoFrame: Panduan Praktis

DDD

Lepaskan： 2024-12-19 14:32:09

asal

241 orang telah melayarinya

Implementing WebSocket Communication and Heartbeat Mechanism with GoFrame: A Hands-on Guide

Dalam pembangunan web moden, komunikasi masa nyata menjadi semakin penting. WebSocket menonjol sebagai teknologi yang sesuai untuk melaksanakan komunikasi dua hala antara pelanggan dan pelayan. Panduan ini akan memandu anda melaksanakan komunikasi WebSocket dan mekanisme degupan jantung yang mantap menggunakan GoFrame.

Apa yang Anda Akan Pelajari

Menyediakan pelayan WebSocket dengan GoFrame
Melaksanakan komunikasi WebSocket sebelah pelanggan
Mengendalikan sambungan WebSocket serentak
Membina mekanisme degupan jantung yang boleh dipercayai
Amalan terbaik untuk aplikasi WebSocket sedia pengeluaran

Prasyarat

Pengetahuan asas pengaturcaraan Go
Rangka kerja GoFrame dipasang
Pemahaman tentang asas protokol WebSocket

Menyediakan Pelayan WebSocket

Mari kita mulakan dengan mencipta pelayan WebSocket asas:

package main

import (
    "github.com/gogf/gf/v2/frame/g"
    "github.com/gogf/gf/v2/net/ghttp"
    "github.com/gogf/gf/v2/os/gctx"
)

func main() {
    ctx := gctx.New()
    s := g.Server()
    s.BindHandler("/ws", func(r *ghttp.Request) {
       ws, err := r.WebSocket()
       if err != nil {
          g.Log().Error(ctx, err)
          return
       }
       defer ws.Close()

       for {
          msgType, msg, err := ws.ReadMessage()
          if err != nil {
             return
          }
          if err = ws.WriteMessage(msgType, msg); err != nil {
             return
          }
       }
    })
    s.SetPort(8399)
    s.Run()
}

Salin selepas log masuk

Ini mencipta pelayan gema ringkas yang mendengar pada port 8399 dan menggemakan semula sebarang mesej yang diterima.

Pelaksanaan Bahagian Pelanggan

Berikut ialah pelaksanaan asas klien HTML/JavaScript:

<!DOCTYPE html>
<html>
<head>
    <title>WebSocket Client</title>
</head>
<body>
    <script>
        const socket = new WebSocket('ws://localhost:8399/ws');

        socket.onopen = function(e) {
            console.log('Connection established');
            socket.send('Hello, server!');
        };

        socket.onmessage = function(event) {
            console.log('Message received:', event.data);
        };

        socket.onclose = function(event) {
            console.log('Connection closed');
        };
    </script>
</body>
</html>

Salin selepas log masuk

Mengendalikan Sambungan Serentak

Dalam persekitaran pengeluaran, anda perlu mengendalikan berbilang sambungan dengan cekap. Begini caranya untuk melaksanakan kumpulan sambungan:

import "github.com/gogf/gf/v2/os/gmlock"

var (
    connPool = make(map[string]*ghttp.WebSocket)
    mu       = gmlock.New()
)

func addConn(id string, ws *ghttp.WebSocket) {
    mu.Lock()
    connPool[id] = ws
    mu.Unlock()
}

func removeConn(id string) {
    mu.Lock()
    delete(connPool, id)
    mu.Unlock()
}

func broadcastMessage(ctx context.Context, id string, message []byte) {
    mu.RLock(id)
    defer mu.RUnlock(id)

    for _, ws := range connPool {
       go func(ws *ghttp.WebSocket) {
          if err := ws.WriteMessage(websocket.TextMessage, message); err != nil {
             g.Log().Error(ctx, err)
          }
       }(ws)
    }
}

Salin selepas log masuk

Melaksanakan Mekanisme Denyutan Jantung

Berikut ialah pelaksanaan degupan jantung sedia pengeluaran:

package main

import (
    "github.com/gogf/gf/v2/frame/g"
    "github.com/gogf/gf/v2/net/ghttp"
    "github.com/gogf/gf/v2/os/gctx"
)

func main() {
    ctx := gctx.New()
    s := g.Server()
    s.BindHandler("/ws", func(r *ghttp.Request) {
       ws, err := r.WebSocket()
       if err != nil {
          g.Log().Error(ctx, err)
          return
       }
       defer ws.Close()

       for {
          msgType, msg, err := ws.ReadMessage()
          if err != nil {
             return
          }
          if err = ws.WriteMessage(msgType, msg); err != nil {
             return
          }
       }
    })
    s.SetPort(8399)
    s.Run()
}

Salin selepas log masuk

Pengendalian Denyutan Jantung Sebelah Pelanggan

<!DOCTYPE html>
<html>
<head>
    <title>WebSocket Client</title>
</head>
<body>
    <script>
        const socket = new WebSocket('ws://localhost:8399/ws');

        socket.onopen = function(e) {
            console.log('Connection established');
            socket.send('Hello, server!');
        };

        socket.onmessage = function(event) {
            console.log('Message received:', event.data);
        };

        socket.onclose = function(event) {
            console.log('Connection closed');
        };
    </script>
</body>
</html>

Salin selepas log masuk

Amalan dan Petua Terbaik

Pengendalian Ralat: Sentiasa laksanakan pengendalian ralat yang betul untuk kegagalan sambungan dan tamat masa.
Pembersihan Sambungan: Pastikan sumber dibersihkan dengan betul apabila sambungan ditutup.
Selang Denyutan Jantung: Pilih selang degupan jantung yang sesuai berdasarkan keperluan aplikasi anda (10-30 saat adalah perkara biasa).
Saiz Mesej: Pertimbangkan untuk melaksanakan had saiz mesej untuk mengelakkan masalah ingatan.
Logik Sambungan Semula: Laksanakan penyambungan semula automatik pada bahagian pelanggan.

Perangkap Biasa yang Perlu Dielakkan

Tidak melaksanakan pembersihan sambungan yang betul
Mengabaikan tamat masa degupan jantung
Tidak mengendalikan senario penyambungan semula
Tiada pengendalian ralat untuk isu rangkaian
Operasi menyekat dalam gelung sambungan utama

Kesimpulan

Dengan sokongan WebSocket GoFrame, anda boleh melaksanakan komunikasi masa nyata yang mantap dengan mudah dalam aplikasi anda. Gabungan pengendalian sambungan yang betul, mekanisme degupan jantung dan pengurusan sambungan serentak memastikan pelaksanaan WebSocket yang boleh dipercayai dan berskala.

Ingat kepada:

Uji pelaksanaan anda di bawah keadaan rangkaian yang berbeza
Pantau kesihatan sambungan dalam pengeluaran
Melaksanakan pengendalian ralat dan mekanisme pemulihan yang betul
Pertimbangkan strategi penskalaan untuk bilangan sambungan yang besar

Sumber

Dokumentasi GoFrame
Spesifikasi Protokol WebSocket
Repositori GitHub GoFrame

Kini anda mempunyai asas yang kukuh untuk melaksanakan komunikasi WebSocket dalam aplikasi GoFrame anda. Selamat mengekod! ?

Atas ialah kandungan terperinci Melaksanakan Komunikasi WebSocket dan Mekanisme Denyutan Jantung dengan GoFrame: Panduan Praktis. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!