Golang开发：使用Websocket实现实时聊天应用

林译川

2026-11-08 • 👁 0人浏览过

Golang开发：使用Websocket实现实时聊天应用在当今的互联网时代，实时通信已经成为了人们生活中不可或缺的一部分。无论是即时消息、实时聊天还是实时更新，都需要一种高效稳定的通信方式来实现。而Websocket正是一种非常适合实时通信的协议。 Golang是一种简洁高效的编程语言，它的并发性能非常出色，非常适合用来开发实时通信应用。这篇文章将会向大家介绍如何使用Golang的Websocket库来实现一个实时聊天应用，并提供相应的代码示例。首先，我们需要创建一个Golang的项目，并引入Golang的Websocket库。立即学习 “ go语言免费学习笔记（深入） ”；

package main

import (
    "log"
    "net/http"

    "github.com/gorilla/websocket"
)

接下来，我们需要定义一些全局变量和结构体。

var clients = make(map[*websocket.Conn]bool) // 客户端集合
var broadcast = make(chan Message)           // 广播消息通道

// 消息结构体
type Message struct {
    Username string `json:"username"`
    Message  string `json:"message"`
}

然后，我们需要实现一个处理Websocket连接的函数。 WebSocket 8.18.2 WebSocket 8.18.2 是该协议规范的一个重要迭代版本，主要优化了连接稳定性与数据传输效率。它通过全双工通信机制，允许客户端与服务器在单一长连接上实时交换数据，大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力，适用于即时通讯、在线游戏及金融行情推送等低延迟场景，为开发者提供更可靠的实时网络交互基础。下载

func handleWebSocket(w http.ResponseWriter, r *http.Request) {
    // 升级HTTP连接为Websocket连接
    upgrader := websocket.Upgrader{}
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Fatal(err)
    }

    // 将连接添加到客户端集合中
    clients[conn] = true

    // 关闭连接时，从客户端集合中移除
    defer func() {
        delete(clients, conn)
        conn.Close()
    }()

    // 循环接收和发送消息
    for {
        var message Message
        err := conn.ReadJSON(&message)
        if err != nil {
            log.Printf("error: %v", err)
            delete(clients, conn)
            break
        }
        broadcast <- message
    }
}

接下来，我们需要实现一个用于将消息广播给所有客户端的函数。

func broadcastMessages() {
    for {
        // 从广播通道中接收消息
        message := <-broadcast

        // 将消息发送给所有客户端
        for client := range clients {
            err := client.WriteJSON(message)
            if err != nil {
                log.Printf("error: %v", err)
                client.Close()
                delete(clients, client)
            }
        }
    }
}

最后，我们需要在main函数中启动Websocket服务器。

func main() {
    // 设置静态文件目录
    fs := http.FileServer(http.Dir("public"))
    http.Handle("/", fs)

    // 设置Websocket路由
    http.HandleFunc("/ws", handleWebSocket)

    // 启动Websocket服务器
    go broadcastMessages()

    // 开始监听端口
    log.Println("Server started on :8080")
    err := http.ListenAndServe(":8080", nil)
    if err != nil {
        log.Fatal(err)
    }
}

接下来，我们可以创建一个HTML页面，用来实现用户界面。





  
  实时聊天应用



  实时聊天应用

至此，我们已经完成了一个使用Golang的Websocket库来实现实时聊天应用的示例。通过这个示例，我们可以深入理解Websocket的工作原理，并学会如何用Golang来开发实时通信应用。当然，在实际项目中还有很多细节和安全性的考虑，例如对消息进行验证、使用SSL加密等等。但通过这个示例，您已经可以有一个很好的起点来构建自己的实时聊天应用。祝您编码愉快！

实时聊天应用

相关文章