0

0

如何在Golang中实现基础的消息推送_Golang WebSocket消息推送示例

P粉602998670

P粉602998670

发布时间:2026-01-02 10:44:03

|

443人浏览过

|

来源于php中文网

原创

正确做法是分离连接管理与消息分发:维护客户端连接池,通过 channel 或 map 管理活跃连接,另启 goroutine 监听广播通道,由 HTTP 接口、定时任务等外部事件触发向指定或全体客户端推送。

如何在golang中实现基础的消息推送_golang websocket消息推送示例

gorilla/websocket 实现基础消息推送,核心不是“连上就发”,而是“连上后能被外部触发推送”——比如 HTTP 接口调用、定时任务或业务事件触发。直接在 WebSocket handler 里写死 WriteMessage 只能回显,无法做到“服务端主动推”。

为什么不能只靠 handleConnections 循环读写?

单纯在连接处理函数里 for { conn.ReadMessage(); conn.WriteMessage(...) } 只能实现回显或点对点 echo,无法响应外部事件(如管理员发公告、订单状态更新)。真正的推送必须解耦:连接管理 + 消息分发分离。

  • 常见错误现象:http.HandleFunc("/ws", ...) 里没启动广播 goroutine,导致 broadcast channel 无人监听,broadcast 永远阻塞
  • 关键设计点:必须用一个全局 chan(如 broadcast)作为消息中转站,再由独立 goroutine 拉取并遍历 clients 发送
  • 性能影响:若不加缓冲,make(chan string) 是无缓冲 channel,一旦某个 client 写失败卡住,整个广播会停摆;建议用带缓冲的 make(chan []byte, 100)

upgrader.CheckOrigin 不设为 true 就连不上?

开发阶段不放开跨域,浏览器前端用 new WebSocket("ws://localhost:8080/ws") 会直接报 Connection closed before receiving a handshake response。这不是协议错误,是 gorilla/websocket 默认拒绝非同源请求。

  • 正确做法:明确允许跨域,但别用 return true 上线——应校验 r.Header.Get("Origin") 是否在白名单内
  • 调试时可临时写成:CheckOrigin: func(r *http.Request) bool { return r.Header.Get("Origin") == "http://localhost:3000" || r.Header.Get("Origin") == "" }
  • 注意:某些代理(如 Nginx)可能不透传 Origin 头,此时需检查反向代理配置

如何从 HTTP 接口触发 WebSocket 推送?

这是“推送”的刚需场景:比如收到 POST /api/push,把消息发给所有在线用户。不能在 HTTP handler 里直接遍历 clientsWriteMessage,因为 clients 是 map,而 *websocket.Conn 非并发安全,且写操作可能阻塞。

10Web
10Web

AI驱动的WordPress网站自动构建器,托管和页面速度助推器

下载

立即学习go语言免费学习笔记(深入)”;

  • 安全做法:HTTP handler 只往 broadcast channel 发消息,由已存在的 handleMessages() goroutine 统一处理
  • 示例接口逻辑:
    func pushHandler(w http.ResponseWriter, r *http.Request) {
        var req struct{ Msg string }
        json.NewDecoder(r.Body).Decode(&req)
        broadcast <- []byte(req.Msg) // 注意:这里发的是 []byte,不是 string
        w.WriteHeader(http.StatusOK)
    }
  • 容易踩的坑:如果广播逻辑里用 client.WriteJSON(msg),但 msg 是 string 类型,会 panic;统一用 []byte 或封装结构体更稳

真正难的不是“怎么发”,而是“发的时候连接还健在吗”。每个 *websocket.Conn 都要配心跳(PingHandler)、超时控制(SetReadDeadline)和异常捕获,否则 clients map 里会堆积大量已断开却未清理的连接,广播时反复报 use of closed network connection ——这个细节,90% 的入门示例都漏掉。

相关专题

更多
golang如何定义变量
golang如何定义变量

golang定义变量的方法:1、声明变量并赋予初始值“var age int =值”;2、声明变量但不赋初始值“var age int”;3、使用短变量声明“age :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

174

2024.02.23

golang有哪些数据转换方法
golang有哪些数据转换方法

golang数据转换方法:1、类型转换操作符;2、类型断言;3、字符串和数字之间的转换;4、JSON序列化和反序列化;5、使用标准库进行数据转换;6、使用第三方库进行数据转换;7、自定义数据转换函数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

225

2024.02.23

golang常用库有哪些
golang常用库有哪些

golang常用库有:1、标准库;2、字符串处理库;3、网络库;4、加密库;5、压缩库;6、xml和json解析库;7、日期和时间库;8、数据库操作库;9、文件操作库;10、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

335

2024.02.23

golang和python的区别是什么
golang和python的区别是什么

golang和python的区别是:1、golang是一种编译型语言,而python是一种解释型语言;2、golang天生支持并发编程,而python对并发与并行的支持相对较弱等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

206

2024.03.05

golang是免费的吗
golang是免费的吗

golang是免费的。golang是google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的开源编程语言,采用bsd开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

388

2024.05.21

golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

194

2025.06.09

golang相关判断方法
golang相关判断方法

本专题整合了golang相关判断方法,想了解更详细的相关内容,请阅读下面的文章。

189

2025.06.10

golang数组使用方法
golang数组使用方法

本专题整合了golang数组用法,想了解更多的相关内容,请阅读专题下面的文章。

191

2025.06.17

php源码安装教程大全
php源码安装教程大全

本专题整合了php源码安装教程,阅读专题下面的文章了解更多详细内容。

74

2025.12.31

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go 教程
Go 教程

共32课时 | 3.2万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号