GolangWebSocket实时通信开发示例

Golang利用gorilla/websocket库可高效构建WebSocket实时通信服务，通过HTTP服务器升级连接，使用Hub管理客户端注册、消息广播与连接维护。

Golang在实时通信领域，尤其是处理WebSocket连接方面，表现得相当出色，这很大程度上得益于其原生的并发模型。用它来构建一个高性能、可扩展的实时通信服务，效率高，代码也相对简洁。

构建一个Golang WebSocket实时通信服务，核心在于管理连接、处理消息以及确保消息的正确分发。我通常会采用

gorilla/websocket

天天团购系统

天天团购系统是一套强大的开源团购程序，采用PHP+mysql开发，系统内置支付宝、财付通、GOOGLE地图等接口，支持短信发送团购券和实物团购快递发货等；另外可通过Ucenter模块，与网站已有系统无缝整合，实现用户同步注册、登陆、退出。 天天团购系统是一套创新的开源团购程序，拥有多达10项首创功能，同时支持虚拟和实物团购，内置类似淘宝的快递配送体系，并提供强大的抽奖、邀请返利等营销功能，让您轻松

下载

首先，我们需要一个HTTP服务器来升级连接。这是基础。

package main

import (
    "log"
    "net/http"
    "time"

    "github.com/gorilla/websocket"
)

// 定义一些常量，用于控制心跳和超时
const (
    writeWait = 10 * time.Second    // 允许写入消息的最大时间
    pongWait = 60 * time.Second     // 等待客户端pong回复的最大时间
    pingPeriod = (pongWait * 9) / 10 // 向客户端发送ping的周期，略小于pongWait
    maxMessageSize = 512             // 允许从客户端读取的最大消息大小
)

// upgrader 用于将HTTP连接升级为WebSocket连接
var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
    CheckOrigin: func(r *http.Request) bool {
        // 在生产环境中，这里应该严格检查Origin头，防止跨站WebSocket劫持。
        // 例如：return r.Header.Get("Origin") == "http://your-trusted-domain.com"
        // 暂时为了示例方便，直接返回true
        return true 
    },
}

// Client 代表一个WebSocket连接的客户端
type Client struct {
    hub *Hub
    conn *websocket.Conn
    send chan []byte // 用于从hub发送消息到客户端的缓冲通道
}

// readPump 从WebSocket连接读取消息，并发送到hub
func (c *Client) readPump() {
    defer func() {
        c.hub.unregister <- c // 客户端断开时通知hub注销
        c.conn.Close()        // 关闭WebSocket连接
    }()
    c.conn.SetReadLimit(maxMessageSize) // 设置最大读取消息大小
    c.conn.SetReadDeadline(time.Now().Add(pongWait)) // 设置读取超时
    c.conn.SetPongHandler(func(string) error { // 收到pong时重置读取超时
        c.conn.SetReadDeadline(time.Now().Add(pongWait))
        return nil
    })
    for {
        _, message, err := c.conn.ReadMessage()
        if err != nil {
            if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway, websocket.CloseAbnormalClosure) {
                log.Printf("error reading message: %v", err)
            }
            break // 发生错误或连接关闭，退出循环
        }
        // 收到消息后，可以广播给所有客户端，或者进行其他处理
        c.hub.broadcast <- message
    }
}

// writePump 从hub接收消息，并写入WebSocket连接
func (c *Client) writePump() {
    ticker := time.NewTicker(pingPeriod) // 定时发送ping
    defer func() {
        ticker.Stop()
        c.conn.Close()