gateway/

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/liangjfblue/gpusher

Links

Open Source Insights

README ¶

gateway(网关)

维护与client的连接, 转发消息到logic处理
接收logic的下发推送消息, 发送给client
保存连接信息, 负载情况到redis, 提供web模块http查询

客户端连接相关设计

bucket--> connChannel--> connect

connect: 客户端连接的抽象结构, 持有net.Conn和msgChan, 监听msgChan并write消息到client的goroutine. 主要用于推送消息到通道消息的转换, 推到msgChan, 监听goroutine收到推送消息write给client

connChannel: connect抽象的业务逻辑处理, 负责token添加和校验, connect的add/delete/close, 启动connect goroutine和提供写消息到connect通道的接口

bucket: connChannel的桶集合. 负责connChannel的缓存, 使用hash分片, 提高查询效率

Directories ¶

Path	Synopsis
api * * * @author liangjf * @create on 2020/6/4 * @version 1.0	* * * @author liangjf * @create on 2020/6/4 * @version 1.0
cmd
common * * * @author liangjf * @create on 2020/5/21 * @version 1.0	* * * @author liangjf * @create on 2020/5/21 * @version 1.0
config * * * @author liangjf * @create on 2020/5/20 * @version 1.0	* * * @author liangjf * @create on 2020/5/20 * @version 1.0
proto
server * * * @author liangjf * @create on 2020/5/20 * @version 1.0	* * * @author liangjf * @create on 2020/5/20 * @version 1.0
service
connect * * * @author liangjf * @create on 2020/5/20 * @version 1.0 * * * @author liangjf * @create on 2020/5/20 * @version 1.0 * * * @author liangjf * @create on 2020/5/21 * @version 1.0 * * * @author liangjf * @create on 2020/5/21 * @version 1.0	* * * @author liangjf * @create on 2020/5/20 * @version 1.0 * * * @author liangjf * @create on 2020/5/20 * @version 1.0 * * * @author liangjf * @create on 2020/5/21 * @version 1.0 * * * @author liangjf * @create on 2020/5/21 * @version 1.0
message * * * @author liangjf * @create on 2020/7/1 * @version 1.0	* * * @author liangjf * @create on 2020/7/1 * @version 1.0
rpc * * * @author liangjf * @create on 2020/6/1 * @version 1.0	* * * @author liangjf * @create on 2020/6/1 * @version 1.0
transport * * * @author liangjf * @create on 2020/5/20 * @version 1.0 * * * @author liangjf * @create on 2020/5/20 * @version 1.0 * * * @author liangjf * @create on 2020/5/20 * @version 1.0 * * * @author liangjf * @create on 2020/5/21 * @version 1.0 * * * @author liangjf * @create on 2020/5/20 * @version 1.0 * * * @author liangjf * @create on 2020/5/20 * @version 1.0	* * * @author liangjf * @create on 2020/5/20 * @version 1.0 * * * @author liangjf * @create on 2020/5/20 * @version 1.0 * * * @author liangjf * @create on 2020/5/20 * @version 1.0 * * * @author liangjf * @create on 2020/5/21 * @version 1.0 * * * @author liangjf * @create on 2020/5/20 * @version 1.0 * * * @author liangjf * @create on 2020/5/20 * @version 1.0

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL