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