workerman_connection 测试WebStock 功能
Description
整理PHP 实现webstock 功能的相关流程。感谢workerman 开发作者提供开源组件。
安装 composer
# curl -sS https://getcomposer.org/installer | php
如果安装 composer 提示PHP 版本不够按照如下处理,否则跳过。
提示版本不够,现在是5.3.3 只好准备升级到5.6
先进行卸载旧版本。
# yum list installed | grep php
# yum remove php.x86_64 php-cli.x86_64 php-common.x86_64 php-fpm.x86_64 php-gd.x86_64 php-mbstring.x86_64 php-mcrypt.x86_64 php-mysql.x86_64 php-pdo.x86_64 php-xml.x86_64 删掉显示出来的所有组件
接下来安装PHP5.6
# rpm -Uvh https://mirror.webtatic.com/yum/el6/latest.rpm 升级一下yum 工具
# yum clean all 清除
# yum install php56w.x86_64 php56w-cli.x86_64 php56w-common.x86_64 php56w-fpm.x86_64 php56w-gd.x86_64 php56w-ldap.x86_64 php56w-mbstring.x86_64 php56w-mcrypt.x86_64 php56w-mysql.x86_64 php56w-pdo.x86_64 php56w-xml.x86_64
验证安装版本
# php -v (显示 5.6.35)
# /etc/init.d/php-fpm restart 重新启动
安装WebStock 所需要的组件
安装前检查很重要
# curl -Ss http://www.workerman.net/check.php|php 检查缺啥
PHP Version >= 5.3.3 [OK]
Extension pcntl check [OK]
Extension posix check [fail] (缺啥补啥)
补充缺少的部分
# yum install php56w-process 安装缺少的 posix
# mv composer.phar /usr/local/bin/composer 让命令全局调用
# cd (切换到项目目录)
安装:workerman
# composer require workerman/workerman
安装:gateway-worker
# composer require workerman/gateway-worker
代码测试
下载本项目的文件,这里假设你防止的目录是网站根目录下 ws 文件夹中。
配置
配置 ws/start_businessworker.php BusinessWorker类其实也是基于基础的Worker开发的。BusinessWorker是运行业务逻辑的进程,BusinessWorker收到Gateway转发来的事件及请求时会默认调用Events.php中的onConnect、onMessage、onClose方法处理事件及数据,开发者正是通过实现这些回调控制业务及流程。
$worker->name 是你的工作进程名称,随便起名即可别重名
$worker->registerAddress 是webstock 服务器的地址,目标指向你的webstock 服务器,这个在分布式处理需要注意,这里都在一台主机上测试,所以IP为127.0.0.1
其他不用改,不要动,保存退出
举例
use \Workerman\Worker;
use \Workerman\WebServer;
use \GatewayWorker\Gateway;
use \GatewayWorker\BusinessWorker;
use \Workerman\Autoloader;
// bussinessWorker 进程
$worker = new BusinessWorker();
// worker名称
$worker->name = 'YourAppBusinessWorker';
// bussinessWorker进程数量
$worker->count = 4;
// 服务注册地址
$worker->registerAddress = '127.0.0.1:2346';
// 如果不是在根目录启动,则运行runAll方法
if(!defined('GLOBAL_START')) {
Worker::runAll();
}
配置 ws/start_gateway.php Gateway类用于初始化Gateway进程。Gateway进程是暴露给客户端的让其连接的进程。所有客户端的请求都是由Gateway接收然后分发给BusinessWorker处理
$gateway->name
$gateway->count
$gateway->lanIp
$gateway->startPort
$gateway->registerAddress
$gateway->pingInterval
$gateway->pingData
直接看注释吧。
use \Workerman\Worker;
use \Workerman\WebServer;
use \GatewayWorker\Gateway;
use \GatewayWorker\BusinessWorker;
use \Workerman\Autoloader;
// gateway 进程,这里使用Text协议,可以用telnet测试
$gateway = new Gateway("websocket://0.0.0.0:2345");
// gateway名称,status方便查看
$gateway->name = 'YourAppGateway';
// gateway进程数
$gateway->count = 4;
// 本机ip,分布式部署时使用内网ip
$gateway->lanIp = '127.0.0.1';
// 内部通讯起始端口,假如$gateway->count=4,起始端口为4000
// 则一般会使用4000 4001 4002 4003 4个端口作为内部通讯端口
$gateway->startPort = 2900;
// 服务注册地址
$gateway->registerAddress = '127.0.0.1:2346';
// 心跳间隔
$gateway->pingInterval = 20;
// 心跳数据
$gateway->pingData = '{"type":"ping"}';
配置 ws/start_register.php Register类其实也是基于基础的Worker开发的。Gateway进程和BusinessWorker进程启动后分别向Register进程注册自己的通讯地址,Gateway进程和BusinessWorker通过Register进程得到通讯地址后,就可以建立起连接并通讯了。
要修改的只有text 协议地址,这里面要和
use \Workerman\Worker;
use \GatewayWorker\Register;
// register 服务必须是text协议
$register = new Register('text://0.0.0.0:2346');
// 如果不是在根目录启动,则运行runAll方法
if(!defined('GLOBAL_START')) {
Worker::runAll();
}
逻辑工作原理
1.Register、Gateway、BusinessWorker进程启动
2.Gateway、BusinessWorker进程启动后向Register服务进程发起长连接注册自己
3.Register服务收到Gateway的注册后,把所有Gateway的通讯地址保存在内存中
4.Register服务收到BusinessWorker的注册后,把内存中所有的Gateway的通讯地址发给BusinessWorker
5.BusinessWorker进程得到所有的Gateway内部通讯地址后尝试连接Gateway
6.如果运行过程中有新的Gateway服务注册到Register(一般是分布式部署加机器),则将新的Gateway内部通讯地址列表将广播给所有BusinessWorker,BusinessWorker收到后建立连接
7.如果有Gateway下线,则Register服务会收到通知,会将对应的内部通讯地址删除,然后广播新的内部通讯地址列表给所有BusinessWorker,BusinessWorker不再连接下线的Gateway
8.至此Gateway与BusinessWorker通过Register已经建立起长连接
9.客户端的事件及数据全部由Gateway转发给BusinessWorker处理,BusinessWorker默认调用Events.php中的onConnect onMessage onClose处理业务逻辑。
10.BusinessWorker的业务逻辑入口全部在Events.php中,包括onWorkerStart进程启动事件(进程事件)、onConnect连接事件(客户端事件)、onMessage消息事件(客户端事件)、onClose连接关闭事件(客户端事件)、onWorkerStop进程退出事件(进程事件)
执行测试
进入服务器的ws 目录下
php start.php start 这会启动所有服务
启动后截图
控制台截图
里面会生成一个假的OPEN-ID 这个OPEN-ID 用来沟通这个用户的客户端“OPENID_1539063500148”
查看客户端控制台
看到消息表示测试成功。
特别说明
send_message.php 中的代码实际上放到任何框架下都可以执行,这个完美的进行了解耦操作。