讲师中心 微信公众号

工具推荐

视频效率加速
剧云
剧云

中文短剧剧本制作平台

updream

一键生成高质量推广成片

Seko
Seko

AI短剧一键生成成片

立刻MV
立刻MV

低成本歌曲 MV、视频生成

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

风静小哥_1866

风静小哥_1866

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

|

794人浏览过

|

来源于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语言免费学习笔记(深入)”;

cn-json-diff
cn-json-diff

比较两个 JSON 文件并显示差异。支持嵌套结构、数组及值变更。纯 Python 标准库实现,无需 API 密钥。

下载
  • 必须设置三类响应头: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.Upgrade 和 conn.ReadMessage,结果压测半小时连接全掉——因为没处理网络抖动、NAT 超时、客户端休眠等问题。

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

  • 必须启动独立 goroutine 调用 conn.SetPingHandler + 定期 conn.WriteMessage(websocket.PingMessage, nil)
  • conn.SetReadDeadline 和 conn.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 示例里,但线上出问题时,它们才是第一现场。

热门AI工具

更多
WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

Laper
Laper Hot

Laper是专为编剧、导演和制片人推出的 AI 原生剧本创作工具。

切问学术

切问学术是一款AI论文写作工具,复旦大学NLP团队推出的AI学术智能体。

码上飞
码上飞 Hot

一款基于自然语言的AI应用开发平台,可根据用户描述自动生成应用程序,帮助个人和团队快速完成应用原型与开发。

小橡皮AI

一款AI工具,主要用于小橡皮一键去AI味,将机器味重的内容改得更有活人感,防止因为 AI 内容被平台打上 AI 标签,以及限流,适合需要提升相关任务效率的用户。

Seko
Seko Hot

一款AI视频创作工具,主要用于商汤科技推出的创编一体的AI短视频创作Agent,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

Flowith
Flowith Hot

Flowith是一款基于画布和智能体工作流的 AI 协作工作空间。

相关专题

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

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

2295

2023.08.07

json是什么
json是什么

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

3742

2023.08.23

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

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

1236

2023.10.13

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

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

4319

2025.09.10

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

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

320

2023.12.20

登录token无效
登录token无效

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

15146

2023.09.14

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

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

1765

2023.09.14

token怎么获取
token怎么获取

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

4237

2023.12.21

Postman身份认证怎么配置
Postman身份认证怎么配置

本专题从实际API接口调试场景出发,讲解Postman身份认证的完整配置流程,包括常见认证协议介绍、授权参数设置、访问令牌填写、OAuth 2.0授权及认证失败排查,帮助用户正确完成接口授权与访问验证。

40

2026.11.06

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
phpEnv手册
phpEnv手册

共0课时 | 0人学习

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn