GatewayWorker流程
GatewayWorker流程手里的项目遇到个需求,就了解了一下GatewayWorker。本来打算用这个了,但是最后还是选择了workerman。简单说一下GatewayWorker流程吧因为项目需求用的php做设备通信。设备客户端使用tcp进行长连接。还要和小程序的应用层进行http连接。所以最初选择GatewayWorker。因为GatewayWorker用于快速开发TCP长连接应用,可..
GatewayWorker流程
手里的项目遇到个需求,就了解了一下GatewayWorker。本来打算用这个了,但是最后还是选择了workerman。简单说一下GatewayWorker流程吧
因为项目需求用的php做设备通信。设备客户端使用tcp进行长连接。还要和小程序的应用层进行http连接。所以最初选择GatewayWorker。因为GatewayWorker用于快速开发TCP长连接应用,可以方便的实现客户端与客户端的通讯。Gateway与Worker之间是基于socket长连接通讯,也就是说Gateway、Worker可以部署在不同的服务器上,非常容易实现分布式部署,扩容服务器
1.原理
Register、Gateway、BusinessWorker进程启动
register负责缓存设置
Gateway负责和客户端的链接
BusinessWorker负责业务处理
三个服务启动后,Gateway会把客户端的连接信息保存到register内存中。BusinessWorker是接受Register发过来的Gateway连接信息,BusinessWorker接收到信息后。就会尝试和gateway进行连接。至此Gateway与BusinessWorker通过Register已经建立起长连接
客户端的事件及数据全部由Gateway转发给BusinessWorker处理
所有的业务操作在events.php完成即可。其他文件不用修改。
当客户端连接时触发
public static function onConnect($client_id)
{
// 向当前client_id发送数据
Gateway::sendToClient($client_id, "Hello $client_id\r\n");
// 向所有人发送
Gateway::sendToAll("$client_id login\r\n");
}
可以看到。这里操作的都是gateway类,其实gateway类里面调用的还是businessWorker。所以这里不要混淆
当客户端发来消息时触发
public static function onMessage($client_id, $message)
{
// 向所有人发送
Gateway::sendToAll("$client_id said $message\r\n");
}
当用户断开连接时触发
public static function onClose($client_id)
{
echo '断开';
// 向所有人发送
GateWay::sendToAll("$client_id logout\r\n");
}
如果想开启第三方扩展,如redis。切记不要在连接时初始化,因为workerman的数据是存放在共享内存中。当启动进程时就会初始化,如果在客户端连接时初始化会覆盖操作。可以在onworkerstart进程启动时初始化redis
/**
* 当进程开启时开启redis数据库
*/
public static function onWorkerStart($businessWorker)
{
global $redis ;
$redis = new Redis();
}
注意:客户端只能连接Gateway端口,不要连接Register端口。客户端和服务端的协议要保持一致。长连接需要开启心跳
2、启动与停止
启动
以debug(调试)方式启动
php start.php start
以daemon(守护进程)方式启动
php start.php start -d
停止
php start.php stop
重启
php start.php restart
平滑重启
php start.php reload
查看状态
php start.php status
文件目录
gatewayworker下载地址:链接:https://pan.baidu.com/s/1x4onXfhy62Ttmxx1bpfxwA 密码:tvc3
更多推荐
所有评论(0)