php单例模式教程学习(PHP下用Swoole实现Actor并发模型的方法)
php单例模式教程学习
PHP下用Swoole实现Actor并发模型的方法什么是Actor?
Actor对于PHPer来说,可能会比较陌生,写过Java的同学会比较熟悉,Java一直都有线程的概念(虽然PHP有Pthread,但不普及),它是一种非共享内存的并发模型,每个Actor内的数据独立存在,Actor之间通过消息传递的形式进行交互调度,且Actor是一种高度抽象化的编程模型,非常适合于游戏、硬件行业。
Swoole协程与信箱
得益于Swoole4.x,我们可以基于Swoole的协程与Channel快速实现一个信箱模式调度。模拟代码如下:
|
use Swoole\Coroutine\Channel; go( function (){ //创建十个信箱通道 $mailBoxes = []; for ( $i = 1; $i <= 10; $i ++){ $mailBoxes [ $i ] = new Channel(16); } //模拟master 邮局调度,随机像一个信箱投递消息 go( function () use ( $mailBoxes ){ while (1){ \co::sleep(2); $key = rand(1,10); ( $mailBoxes [ $key ])->push(time()); } }); //模拟actor 实体消费 for ( $i = 1; $i <= 10; $i ++){ go( function () use ( $mailBoxes , $i ){ while (1){ $msg = ( $mailBoxes [ $i ])->pop(); echo "Actor {$i} recv msg : {$msg} \n" ; } }); } }); |
以上代码执行输出:
php test.php
Actor 8 recv msg : 1559622691
Actor 10 recv msg : 1559622693
Actor 1 recv msg : 1559622695
Actor 5 recv msg : 1559622697
协程通道每次在POP遇到无数据的时候,都会自动让出执行权(具体可以去看Swoole协程调度)
Actor库
基于上面的原理,我们实行了一个多进程分布的协程Actor库
|
composer require easyswoole/actor=2.x-dev |
我们依赖dev库进行测试,生产可以自己依赖stable版本
进程关系
Easyswoole的Actor模型中,存在两组进程,一组是proxy进程,用来实现Actor对外服务,一组是worker进程,proxy进程与worker进程之间通过unixsock进行通讯,而Actor实例就均匀的分布worker之中。
样例代码
比如在一个聊天室中,我们可以定义一个房间模型。
|
namespace EasySwoole\Actor\Test; use EasySwoole\Actor\AbstractActor; use EasySwoole\Actor\ActorConfig; class RoomActor extends AbstractActor { public static function configure(ActorConfig $actorConfig ) { $actorConfig ->setActorName( 'Room' ); } public function onStart() { //每当一个RoomActor实体被创建的时候,都会执行该回调 var_dump( 'room actor ' . $this ->actorId(). ' start' ); } public function onMessage( $msg ) { //每当一个RoomActor实体收到外部消息的时候,都会执行该回调当 var_dump( 'room actor ' . $this ->actorId(). ' onmessage: ' . $msg ); return 'reply at ' .time(); } public function onExit( $arg ) { //每当一个RoomActor实体退出的时候,都会执行该回调 var_dump( 'room actor ' . $this ->actorId(). ' exit at arg: ' . $arg ); return 'exit at ' .time(); } protected function onException(\Throwable $throwable ) { //每当一个RoomActor出现异常的时候,都会执行该回调 var_dump( $throwable ->getMessage()); } } |
在cli模式下创建一个Actor服务
|
use EasySwoole\Actor\Actor; use EasySwoole\Actor\Test\RoomActor; use EasySwoole\Actor\ProxyProcess; Actor::getInstance()->register(RoomActor:: class ); $list = Actor::getInstance()->generateProcess(); foreach ( $list [ 'proxy' ] as $proxy ){ /** @var ProxyProcess $proxy */ $proxy ->getProcess()->start(); } foreach ( $list [ 'worker' ] as $actors ){ foreach ( $actors as $actorProcess ){ /** @var ProxyProcess $actorProcess */ $actorProcess ->getProcess()->start(); } } while ( $ret = \Swoole\Process::wait()) { echo "PID={$ret['pid']}\n" ; } |
创建一个cli测试脚本
|
use EasySwoole\Actor\Actor; use EasySwoole\Actor\Test\RoomActor; Actor::getInstance()->register(RoomActor:: class ); go( function (){ $actorId = RoomActor::client()->create( 'create arg1' ); var_dump( $actorId ); \co::sleep(3); var_dump(RoomActor::client()->send( $actorId , 'this is msg' )); \co::sleep(3); var_dump(RoomActor::client()-> exit ( $actorId , 'this is exit arg' )); \co::sleep(3); RoomActor::client()->create( 'create arg2' ); \co::sleep(3); RoomActor::client()->create( 'create arg3' ); \co::sleep(3); var_dump(RoomActor::client()->sendAll( 'sendAll msg' )); \co::sleep(3); var_dump(RoomActor::client()->status()); \co::sleep(3); var_dump(RoomActor::client()->exitAll( 'sendAll exit' )); }); |
以上代码执行结果如下:
服务端
|
php test.php string(40) "room actor 00101000000000000000001 start" string(57) "room actor 00101000000000000000001 onmessage: this is msg" string(64) "room actor 00101000000000000000001 exit at arg: this is exit arg" string(40) "room actor 00101000000000000000002 start" string(40) "room actor 00103000000000000000001 start" string(57) "room actor 00101000000000000000002 onmessage: sendAll msg" string(57) "room actor 00103000000000000000001 onmessage: sendAll msg" string(60) "room actor 00101000000000000000002 exit at arg: sendAll exit" string(60) "room actor 00103000000000000000001 exit at arg: sendAll exit" |
客户端
|
php test2.php string(23) "00101000000000000000001" string(19) "reply at 1559623925" string(18) "exit at 1559623928" bool(true) array (3) { [1]=> int(1) [2]=> int(0) [3]=> int(1) } bool(true) |
更多细节可以在EasySwoole项目官网得到文档支持 http://easyswoole.com/
喜欢EasySwoole项目的,可以给个star https://github.com/easy-swoole/easyswoole
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持开心学习网。
原文链接:https://segmentfault.com/a/1190000019382531
- php中trim函数(PHP中ltrim函数的用法与实例讲解)
- php7用什么替代mysql(mysqli扩展无法在PHP7下升级问题的解决)
- php上传文件的要求(PHP 文件上传限制问题)
- php 获取证书列表(用PHP做了一个领取优惠券活动的示例代码)
- tp5微信支付接口开发案例(PHP实现的微信APP支付功能示例基于TP5框架)
- php中isset函数有什么功能(PHP中的empty、isset、isnull的区别与使用实例)
- php如何定时执行某项(php解决crontab定时任务不能写入文件问题的方法分析)
- phpredis怎么设置队列(php使用lua+redis实现限流,计数器模式,令牌桶模式)
- php 与asp对比(asp.net和php的区别点总结)
- php新建文件夹代码(php新建文件的方法实例)
- php定时执行PHP(Cpanel下Cron Jobs定时执行PHP的方法)
- phpdate函数使用方法(PHP中strtr与str_replace函数运行性能简单测试示例)
- php提供哪些函数来避免sql的注入(PHP与SQL语句写一句话木马总结)
- phptime函数与时区设置(php常用日期时间函数实例小结)
- nginx 怎么搭建web服务器(Linux+Nginx+Php架设高性能WEB服务器)
- php脚本通过文件路径批量上传文件(php遍历目录下文件并按修改时间排序操作示例)
- 素人恋爱综艺火药味十足 男生为赢得芳心集体扯头花,真是出好戏(素人恋爱综艺火药味十足)
- 《囧妈》为何受抵制 春节七部影片撤档背后的责任与博弈(囧妈为何受抵制)
- 提醒 2019年起河南驾考要开设科目五 官方回应来了(2019年起河南驾考要开设科目五)
- 省 市书法家协会 送万福进万家 活动走进禹州美丽乡村(省市书法家协会)
- 点赞 禹州苌庄正式撤乡建镇 未来发展不可估量(禹州苌庄正式撤乡建镇)
- 它荣获 中国生态魅力镇 称号 就在咱们禹州,一起来看看(中国生态魅力镇)
热门推荐
- 阿里云服务器linux怎么使用(阿里云服务器linux系统挂载数据盘图文教程)
- web服务器架设和管理(浅谈Web服务器的安装与配置)
- html正则表达式案例(关于html字符串正则判断和匹配的具体使用)
- tracert命令图解(tracert命令怎么用?tracert命令使用详解)
- python的os模块操作(Python OS模块实例详解)
- html53d效果代码(HTML5 直播疯狂点赞动画实现代码 附源码)
- 支付宝接口中notify_url 与 return_url 的区别
- python3.x base64怎么加密解密(python3.x实现base64加密和解密)
- laravel后台框架(laravel-admin的多级联动方法)
- lnmp怎么连接服务器(LNMP系列教程之 解决sendmail不能发送邮件问题)
排行榜
- 1
- 2
- 3
- 4
- 5
- 6
- 7
- 8
- 9