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