Swoole 自定义项目初始化事件处理的实现
为什么80%的码农都做不了架构师?>>>
最近使用基于 Swoole 开发的 imi 框架 开发项目,碰到一个需求,就是想要做项目初始化处理。当初始化处理完成前,不想让 Swoole 处理请求。因为可能有一些值没有加载进来,处理请求极有可能出现问题。
下面给出了思考过程及解决问题的demo代码。
首先分析了一下,Swoole 是多进程模式运行的,分为 Master、Manager、Worker 进程。
Master 进程就是我们启动服务的 cli 命令文件所在进程,在这里面初始化有一个问题,这里所有加载的类、全局变量,其它 Worker 进程里都可以使用,无法热重启生效。
Manager 进程的情况基本和上面差不多。
那么只有在 Worker 进程做处理了,但如果写在 WorkerStart 事件里,每个 Worker 进程都会去执行。
WorkerStart 事件定义:
function onWorkerStart(swoole_server $server, int $worker_id);
$worker_id是一个从0-$worker_num之间的数字,表示这个Worker进程的ID
那这个就好办了,直接判断workerid为0的去触发项目初始化事件。剩下还有一个问题就是,如何在初始化执行完成前,让所有 Worker 进程暂时都不处理请求。
思考并尝试了一下,这个问题可以通过协程挂起来解决,demo 代码如下:
<?phpuse Swoole\Coroutine;$http = new swoole_http_server('127.0.0.1', 8080);$http->on('WorkerStart', function(swoole_http_server $server, $workerId){$initFlagFile = __DIR__ . '/init.flag';if(0 === $server->worker_id && (!is_file($initFlagFile) || file_get_contents($initFlagFile) != $server->manager_pid)){// 处理项目初始化事件initApp();// 写入文件,保证不再重复触发项目初始化事件file_put_contents($initFlagFile, $server->manager_pid);// 当前worker进程恢复协程resumeCos();// 通知其它worker进程for($i = 1; $i < $server->setting['worker_num']; ++$i){$server->sendMessage('init', $i);}}
});$http->on('PipeMessage', function(swoole_http_server $server, $srcWorkerId, $data) {if(0 === $srcWorkerId && 'init' === $data && !defined('APP_INITED')){// 其它worker进程恢复协程resumeCos();}
});$http->on('request', function (swoole_http_request $request, swoole_http_response $response) {// 判断未初始化完毕,则挂起协程if(!defined('APP_INITED')){$GLOBALS['WORKER_START_END_RESUME_COIDS'][] = Coroutine::getuid();Coroutine::suspend();}$response->header('content-type', 'text/html;charset=utf-8');$response->end('IMI 是一款基于 Swoole 开发的协程 PHP 开发框架,拥有常驻内存、协程异步非阻塞IO等优点。官方网站:<a href="https://imiphp.com" target="_blank">https://imiphp.com</a>');
});$http->start();/*** 处理项目初始化事件,比如这里延时5秒,模拟初始化处理** @return void*/
function initApp()
{$count = 5;for($i = 0; $i < $count; ++$i){echo 'initing ', ($i + 1), '/', $count, PHP_EOL;sleep(1);}
}/*** 恢复协程** @return void*/
function resumeCos()
{define('APP_INITED', true);$coids = $GLOBALS['WORKER_START_END_RESUME_COIDS'] ?? [];fwrite(STDOUT, 'suspend co count: ' . count($coids) . PHP_EOL);foreach($coids as $id){Coroutine::resume($id);}
}
通过在 request 事件中判断是否初始化完毕,如果没有初始化完成,则挂起当前协程,将协程ID加入全局变量。
当第0个 worker 进程执行完初始化后,通过向其他 worker 进程发送消息,唤醒曾经挂起的协程们,在初始化期间进来的请求,这时候会被执行。
转载于:https://my.oschina.net/yurun/blog/2050809
Swoole 自定义项目初始化事件处理的实现相关推荐
- 前端学习(2453):项目初始化
# 一.项目初始化## 使用 Vue CLI 创建项目> 注意:不要使用 Git Bash 执行项目创建操作,使用 cmd 或者 powershell 之类的工具.> 如果你还没有安装 V ...
- git 客户端 所有客户端 钩子_git自定义项目钩子和全局钩子
钩子介绍 自定义钩子分为:项目钩子和全局钩子 自定义全局钩子: 全局钩子目录结构: (注意:excludes目录结构是我们自定义的目录,规则逻辑在update.d/update.py脚本里实现的,非g ...
- 【插件】打造属于自己的cnpm/npm安装,生成自定义项目架构
一些废话(直接看代码的可跳过) 现在前端圈子框架繁多,不乏一些自主研发或合作开发的公司内部框架,模块/组件化.框架设计理念.架构分析.底层封装等去搭建高楼大厦的骨架,为的就是"维护.复用.二 ...
- 献给初学iOS的小盆友们------微博app项目开发之一项目初始化
献给初学iOS的小盆友们--微博app项目开发之一 项目初始化 本人自学iOS也有七八个月了,不敢说学到很深入了,但也算入了门.此次微博app项目参考了传智播客培训教材,主要学习内容有架构思想,封装思 ...
- 百变星君---项目初始化搭建
目录 一:项目初始化: 二:配置MYSQL数据库: 三:配置Redis数据库: 四:配置模块化: 五:自定义JSON的返回格式: 六:再次登录断开连接 一:项目初始化: 1:在app/settings ...
- 三、moyu-alibaba项目初始化
项目初始化 目录 项目初始化 1. 项目结构 2. 技术选型 3. maven依赖 1. 父工程: moyu-alibaba的pom.xml 2. 版本管理模块moyu-boom的pom.xml 3. ...
- vue 项目初始化时,npm run dev报错解决方法
vue 项目初始化时,npm run dev报错解决方法 参考文章: (1)vue 项目初始化时,npm run dev报错解决方法 (2)https://www.cnblogs.com/ruilin ...
- electron-vue脚手架项目初始化时提示: Failed to download repo simulatedgreg/electron-vue: Response code Server E
场景 Electron中与Vue集成流程: https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/details/106630153 在上面实现Elect ...
- 用Visual Studio2019自定义项目模板
项目模板简介 众所周知,在我们使用VS新建项目时,都需要选择一个项目模板,如下图: 我们选择完项目模板进行创建,创建完成之后,可以发现项目中已经包含了一些基础的文件.例如MVC: 可以看到,MVC项目 ...
最新文章
- oracle rman异机恢复
- C# winform打印总结 z
- Make it run, make it right, make it fast
- dos中定义变量与引用变量以及四则运算
- 学长毕业日记 :本科毕业论文写成博士论文的神操作20170320
- string.find()与string::npos
- [Java基础]模块化概述
- 数组shift方法_数组shift()方法以及JavaScript中的示例
- WuJiuVideoX视频小说图片站群程序开源源码
- html5 ul li 自动收回,vue遍历四个ul ,每个ul中有四个li.如何不破坏html结构?
- 破解版PDF编辑器————Adobe Acrobat DC
- Scratch(四十八):植物大战僵尸
- base64和base32的区分方法
- 模拟退火算法应用(Java)
- octobercms mysql_如何在Ubuntu 16.04 LTS上安装OctoberCMS
- java oa系统二次开发_浅谈OA系统的二次开发
- 时钟芯片 服务器,通用实时时钟芯片
- HTTP就绪状态和HTTP状态码
- 使用 Eslint + husky + lint-staged + Prettier 提高前端项目质量、统一项目代码风格
- 卓克科学思维必修课0821