GoFrame으로 WebSocket 통신 및 하트비트 메커니즘 구현: 실습 가이드-Golang-php.cn

GoFrame으로 WebSocket 통신 및 하트비트 메커니즘 구현: 실습 가이드

DDD

풀어 주다： 2024-12-19 14:32:09

원래의

240명이 탐색했습니다.

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

현대 웹 개발에서는 실시간 커뮤니케이션이 점점 더 중요해지고 있습니다. WebSocket은 클라이언트와 서버 간의 양방향 통신을 구현하기 위한 최고의 기술입니다. 이 가이드는 GoFrame을 사용하여 WebSocket 통신과 강력한 하트비트 메커니즘을 구현하는 과정을 안내합니다.

당신이 배울 내용

GoFrame으로 WebSocket 서버 설정
클라이언트 측 WebSocket 통신 구현
동시 WebSocket 연결 처리
신뢰할 수 있는 하트비트 메커니즘 구축
생산 준비가 완료된 WebSocket 애플리케이션 모범 사례

전제 조건

Go 프로그래밍 기본지식
GoFrame 프레임워크 설치
WebSocket 프로토콜 기본 이해

WebSocket 서버 설정

기본 WebSocket 서버를 만드는 것부터 시작해 보겠습니다.

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()
}

로그인 후 복사

이렇게 하면 포트 8399에서 수신 대기하고 수신하는 모든 메시지를 다시 에코하는 간단한 에코 서버가 생성됩니다.

클라이언트측 구현

기본 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>

로그인 후 복사

동시 연결 처리

프로덕션 환경에서는 여러 연결을 효율적으로 처리해야 합니다. 연결 풀을 구현하는 방법은 다음과 같습니다.

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)
    }
}

로그인 후 복사

하트비트 메커니즘 구현

생산 준비가 완료된 하트비트 구현은 다음과 같습니다.

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()
}

로그인 후 복사

클라이언트측 하트비트 처리

<!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>

로그인 후 복사