0

0

Go语言实现简单消息推送_Golang通知项目实战

P粉602998670

P粉602998670

发布时间:2026-01-14 22:21:30

|

774人浏览过

|

来源于php中文网

原创

短轮询适合小规模通知,需用Redis缓存消息并清空已读;SSE需严格设置响应头和flush;WebSocket须处理心跳、超时与重连;微信推送需自动刷新Token并重试。

go语言实现简单消息推送_golang通知项目实战

http.HandleFunc 做短轮询,够用但别硬扛高并发

多数内部系统或小规模后台通知(比如运营后台给审核员弹个“新工单来了”),直接用短轮询最省事。它不依赖长连接、不操心重连、浏览器兼容性拉满——IE11 都能跑。

但要注意:messages 用内存 map 存只是演示,真实场景必须换成 Redis 或带过期的本地缓存(如 freecache),否则进程重启消息就丢了;另外别忘了在返回后清空或标记已读,否则用户每次请求都拿到同一堆消息。

  • 客户端 JS 可用 setInterval(() => fetch("/poll?user_id=123"), 30000) 控制频率
  • 服务端要加 w.Header().Set("Cache-Control", "no-cache"),防止代理缓存响应
  • 如果用户量上万,每 30 秒一次全量拉取,QPS 就是 用户数 / 30,很容易打爆 API 网关

handleEvents 实现 SSE 推送时,响应头和流式写入缺一不可

SSE 是 Web 场景下最轻量的单向推送方案,比 WebSocket 少一堆连接管理逻辑,适合日志流、状态广播、实时告警等场景。但它不是“发个 response 就完事”,必须严格满足协议要求。

常见失败现象:浏览器控制台报 Failed to load resource: net::ERR_INCOMPLETE_CHUNKED_ENCODING,基本就是响应头漏了、没 flush、或者中途 panic 导致连接中断。

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

  • 必须设置三类响应头:w.Header().Set("Content-Type", "text/event-stream")w.Header().Set("Cache-Control", "no-cache")w.Header().Set("Connection", "keep-alive")
  • 每次写入后必须调用 w.(http.Flusher).Flush(),否则数据卡在缓冲区不下发
  • 不要用 json.NewEncoder(w).Encode() 直接写,得手动拼 data: {...}\n\n 格式,否则浏览器解析不了

WebSocket 不是“装上 gorilla/websocket 就行”,心跳和连接生命周期得自己兜底

WebSocket 适合需要双向通信的场景(比如客服聊天、协同编辑),但 Go 里用 github.com/gorilla/websocket 时,很多人只写了 upgrader.Upgradeconn.ReadMessage,结果压测半小时连接全掉——因为没处理网络抖动、NAT 超时、客户端休眠等问题。

BlessAI
BlessAI

Bless AI 提供五个独特的功能:每日问候、庆祝问候、祝福、祷告和名言的文本生成和图片生成。

下载

核心不是“连上”,而是“连得久、断得明、重连快”。微信小程序、iOS Safari 对空闲连接尤其敏感,60 秒没数据就可能静默关闭。

  • 必须启动独立 goroutine 调用 conn.SetPingHandler + 定期 conn.WriteMessage(websocket.PingMessage, nil)
  • conn.SetReadDeadlineconn.SetWriteDeadline 必须设,且 pongWait 要大于 ping 周期(官方建议 pingPeriod = (pongWait * 9) / 10
  • 所有 conn.WriteMessage 调用都要包在 defer conn.Close() 的保护范围内,避免 goroutine 泄漏

微信服务号/企业微信推送别自己拼 URL,Token 刷新和错误重试必须自动化

微信系推送表面是 HTTP 请求,实际水很深:Access Token 2 小时过期、每日调用量有限、42001 错误要主动刷新、45009 是限流得退避重试……手写一个 http.Post 发文本消息,上线三天准出问题。

关键不是“能不能发”,而是“发失败了有没有记录、有没有告警、有没有自动补发”。企业级系统里,一次推送失败往往意味着业务流程卡死。

  • Token 必须存在可刷新的全局单例(如用 sync.Once + time.AfterFunc 提前 5 分钟刷新)
  • 所有微信 API 调用都要封装 DoWithRetry,对 40001/42001/45009 等错误码做指数退避(time.Sleep(time.Second )
  • 发送成功后,至少记录 msgid 和接收方 userid 到数据库,便于后续查证是否送达

真正难的从来不是“怎么推”,而是“推没推成功”“谁没收到”“失败要不要重试”“重试几次合适”——这些逻辑不会出现在 hello world 示例里,但线上出问题时,它们才是第一现场。

相关专题

更多
json数据格式
json数据格式

JSON是一种轻量级的数据交换格式。本专题为大家带来json数据格式相关文章,帮助大家解决问题。

411

2023.08.07

json是什么
json是什么

JSON是一种轻量级的数据交换格式,具有简洁、易读、跨平台和语言的特点,JSON数据是通过键值对的方式进行组织,其中键是字符串,值可以是字符串、数值、布尔值、数组、对象或者null,在Web开发、数据交换和配置文件等方面得到广泛应用。本专题为大家提供json相关的文章、下载、课程内容,供大家免费下载体验。

532

2023.08.23

jquery怎么操作json
jquery怎么操作json

操作的方法有:1、“$.parseJSON(jsonString)”2、“$.getJSON(url, data, success)”;3、“$.each(obj, callback)”;4、“$.ajax()”。更多jquery怎么操作json的详细内容,可以访问本专题下面的文章。

309

2023.10.13

go语言处理json数据方法
go语言处理json数据方法

本专题整合了go语言中处理json数据方法,阅读专题下面的文章了解更多详细内容。

74

2025.09.10

resource是什么文件
resource是什么文件

Resource文件是一种特殊类型的文件,它通常用于存储应用程序或操作系统中的各种资源信息。它们在应用程序开发中起着关键作用,并在跨平台开发和国际化方面提供支持。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

149

2023.12.20

登录token无效
登录token无效

登录token无效解决方法:1、检查token的有效期限,如果token已经过期,需要重新获取一个新的token;2、检查token的签名,如果签名不正确,需要重新获取一个新的token;3、检查密钥的正确性,如果密钥不正确,需要重新获取一个新的token;4、使用HTTPS协议传输token,建议使用HTTPS协议进行传输 ;5、使用双因素认证,双因素认证可以提高账户的安全性。

6084

2023.09.14

登录token无效怎么办
登录token无效怎么办

登录token无效的解决办法有检查Token是否过期、检查Token是否正确、检查Token是否被篡改、检查Token是否与用户匹配、清除缓存或Cookie、检查网络连接和服务器状态、重新登录或请求新的Token、联系技术支持或开发人员等。本专题为大家提供token相关的文章、下载、课程内容,供大家免费下载体验。

803

2023.09.14

token怎么获取
token怎么获取

获取token值的方法:1、小程序调用“wx.login()”获取 临时登录凭证code,并回传到开发者服务器;2、开发者服务器以code换取,用户唯一标识openid和会话密钥“session_key”。想了解更详细的内容,可以阅读本专题下面的文章。

1059

2023.12.21

Java 桌面应用开发(JavaFX 实战)
Java 桌面应用开发(JavaFX 实战)

本专题系统讲解 Java 在桌面应用开发领域的实战应用,重点围绕 JavaFX 框架,涵盖界面布局、控件使用、事件处理、FXML、样式美化(CSS)、多线程与UI响应优化,以及桌面应用的打包与发布。通过完整示例项目,帮助学习者掌握 使用 Java 构建现代化、跨平台桌面应用程序的核心能力。

36

2026.01.14

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
进程与SOCKET
进程与SOCKET

共6课时 | 0.3万人学习

Redis+MySQL数据库面试教程
Redis+MySQL数据库面试教程

共72课时 | 6.3万人学习

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

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