netsvr
是一个网关程序,它在如下架构中处于网关层:
netsvr
主要负责:
- 承载客户的websocket连接,并支持存储连接的:唯一id、主题标签、session信息
- 承载业务进程的tcp连接
- 接收客户连接发来的数据,并按一定的路由策略转发到对应的业务进程
- 接收业务进程发来的数据,并按数据中包含的cmd指令:或转发给客户连接,或自己处理并返回给业务进程
本网关程序实现了下面这套指令,所有业务进程与网关交互都必须基于这套指令。
业务进程可以用php、go或其它语言实现,如果是php、go,则已经生成好对应的代码,直接引入即可。
更高级的sdk
,比如需要广播到多台网关机器啥的,需要自己封装。
- proto描述:https://github.com/buexplain/netsvr-protocol
- proto生成的php代码:
composer require buexplain/netsvr-protocol-php
- proto生成的go代码:
go get -u github.com/buexplain/netsvr-protocol-go
采用固定包头 + 包体协议
,包头
是一个uint32
,表示接下来的包体
有多长,注意包头
表示的长度
,不包含包头
自己的4字节
。
包头
采用大端序,包体
是protobuf编码的数据。
如果采用swoole开发业务进程,则协分包协议设置如下:
$socket = new \Swoole\Coroutine\Socket(AF_INET, SOCK_STREAM, 0);
//设置分包协议
$socket->setProtocol([
'open_length_check' => true,
'package_length_type' => 'N',
'package_length_offset' => 0,
'package_body_offset' => 4,
]);
首先是业务进程启动的时候需要将自己注册到网关中,发起注册的时候需要提供一个workerId
,workerId
的区间是:[1,999]
。
多个业务进程可以注册同一个workerId
。
然后是客户端发送数据的时候需要在数据头部写入三个字节(不足,补零)的workerId
,用于表示该数据要被哪个workerId
的业务进程处理。
如果一个workerId
包含多个业务进程,则采用轮询策略进行转发。
客户端发送数据的示例:001{"cmd":11,"data":"{}"}
,其中的001
表示,数据要被转发到workerId
为1
的业务进程。
- netsvr.go 是本网关程序的启动入口。
- business.go 是为了测试本网关程序的业务进程启动入口。
- stress.go 是为了压测本网关程序的压测进程启动入口,它可以大规模的向网关发起websocket连接。
- build.sh 是编译脚本,把项目clone下来后,直接跑它(依赖go环境),会自动编译出Windows、Linux、Mac三端的网关程序、业务进程程序、压测进程程序。
启动顺序是:网关 --> 业务进程 --> 压测进程
还望有条件的老哥,可以把玩一下这个项目,然后在Linux下做个小小压测,然后把数据贴出来瞅瞅。 我感觉数据不会太差,因为这个网关程序用的websocket包是:nbio,它是一个异步包,Linux下稳定快速。