纯Go实现的轻量级推送系统源码.zip

# golwpush [](https://tip.golang.org/doc/go1.18) [](https://goreportcard.com/report/github.com/NullpointerW/golwpush) ## 特性 * 轻量级 * 高性能 * 纯Golang实现 * 消息确认机制 * 支持丢失消息持久化/重传 * 支持单个/多个/广播推送 * 通过聚合广播消息合并发送，减少io调用，大幅提升网络吞吐量 * 心跳支持 * 客户端连接的统计信息 ## 项目结构 ``` | app --服务端\客户端启动入口 | err --异常定义 package --- | httphandler --http请求处理 | logger --日志存储服务 | persist --消息持久化 | netrw --tcp数据包读取(解决`粘包`) | protocol --消息编解码 | utlis --各种工具 | bus.go --(总线)管理所有客户端的连接对象 core --- | broadcast.go --广播推送实现 | api.go --功能接口定义 | conn.go --连接处理 ``` ## 安装 golang1.18，基于gomod管理依赖。 * 下载golwpush ``` go get github.com/NullpointerW/golwpush ``` * 安装依赖 ``` export GOPROXY=goproxy.io go mod download ``` * 运行service服务 ``` go run ./app ``` * 运行client客户端 ``` go run ./app/clinet ``` ## 测试 * 单个uid推送 ``` curl http://localhost:8000/push?id=1 -X POST -d '{"user_id": "1", "coin":100, "success":1, "text":"recv_OK!" }' ``` * 多个uid推送 ``` curl http://localhost:8000/multiPush -X POST -d '{"ids":[1,59,2035] , "msg":"recv_OK!" }' ``` * 广播推送 ``` curl http://localhost:8000/broadcast -X POST -d '{"user_id": "all", "coin":100, "success":1, "text":"recv_OK!" }' ``` * 查看当前总连接数 ``` curl http://localhost:8000/count ``` * 查看用户连接信息 ``` curl http://localhost:8000/info?id=1 ```