当前位置:   article > 正文

webstock php,workerman_connection

php webstock

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进程退出事件(进程事件)

56e56b160f80f42daab45be263dc4cae.png

执行测试

进入服务器的ws 目录下

php start.php start 这会启动所有服务

启动后截图

198bbee13b27e74089acab8ac53f338b.png

控制台截图

cbc59d748f78f5a855d6e47b1249d9e8.png

里面会生成一个假的OPEN-ID 这个OPEN-ID 用来沟通这个用户的客户端“OPENID_1539063500148”

查看客户端控制台

6922f614d1fc1c15ceffeabc62f683e9.png

看到消息表示测试成功。

特别说明

send_message.php 中的代码实际上放到任何框架下都可以执行,这个完美的进行了解耦操作。

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/笔触狂放9/article/detail/634589
推荐阅读
相关标签
  

闽ICP备14008679号