浅析thinkphp6中怎么使用workerman【教程分享】
发布时间 - 2022-12-08 00:00:00 点击率：次thinkphp6中怎么使用workerman？下面本篇文章给大家介绍一下thinkphp6整合workerman的教程，希望对大家有所帮助。
thinkphp6整合workerman教程
thinkphp6安装workerman命令：
composer require topthink/think-worker
第一步，创建一个自定义命令类文件，运行指令。【相关推荐：《workerman教程》】
php think make:command Spider spider
会生成一个app\command\Spider命令行指令类，我们修改内容如下：
setName('spider')
->addArgument('status', Argument::OPTIONAL, "status")
->addArgument('controller_name', Argument::OPTIONAL, "controller_name/controller_name")
->addArgument('mode', Argument::OPTIONAL, "d")
->setDescription('spider control');
/**
* 以上设置命令格式为:php think spider [status] [controller_name/controller_name] [d]
* think 为thinkphp框架入口文件
* spider 为在框架中注册的命令,上面setName设置的
* staus 为workerman框架接受的命令
* controller_name/controller_name 为控制器名称,以正斜线分割,执行制定控制器,为空或缺省则启动所有控制器,控制器列表在controller_name属性中注册
* d 最后一个参数为wokerman支持的-d-g参数,但是不用加-,直接使用d或者g
* php think spider start collect/SendMsg
*/
}
/**
* execute
* tp框架自定义指令特性
* 执行命令后的逻辑
* @param mixed $input
* @param mixed $output
* @return mixed
*/
protected function execute(Input $input, Output $output)
{
//获得status参数,即think自定义指令中的第一个参数,缺省报错
$status = $input->getArgument('status');
if(!$status){
$output->writeln('pelase input control command , like start');
exit;
}
//获得控制器名称
$controller_str = $input->getArgument('controller_name');
//获得模式,d为wokerman的后台模式(生产环境)
$mode = $input->getArgument('mode');
//分析控制器参数,如果缺省或为all,那么运行所有注册的控制器
$controller_list = $this->controller_names;
if($controller_str != '' && $controller_str != 'all' )
{
$controller_list = explode('/',$controller_str);
}
//重写mode参数,改为wokerman接受的参数
if($mode == 'd'){
$mode = '-d';
}
if($mode == 'g'){
$mode = '-g';
}
//将wokerman需要的参数传入到其parseCommand方法中,此方法在start类中重写
Start::$argvs = [
'think',
$status,
$mode
];
$output->writeln('start running spider');
$programs_ob_list = [];
//实例化需要运行的控制器
foreach ($controller_list as $c_key => $controller_name) {
$class_name = 'app\\'.$this->model_name.'\controller\\'.$controller_name;
$programs_ob_list[] = new $class_name();
}
//将控制器的相关回调参数传到workerman中
foreach (['onWorkerStart', 'onConnect', 'onMessage', 'onClose', 'onError', 'onBufferFull', 'onBufferDrain', 'onWorkerStop', 'onWorkerReload'] as $event) {
foreach ($programs_ob_list as $p_key => $program_ob) {
if (method_exists($program_ob, $event)) {
$programs_ob_list[$p_key]->$event = [$program_ob,$event];
}
}
}
Start::runAll();
}
}例如我们创建一个定时器的命令app\server\controller创建WebhookTimer.php
执行start命令行
php think spider start执行stop命令
php think spider stop执行全部进程命令
php think spider start all d在
app\command\Spider.php文件public $controller_names = ['WebhookTimer','其他方法','其他方法'];
其他方法 就是
app\server\controller下创建的其他类文件方法完结
Start.php文件
socket ?: $this->protocol . '://' . $this->host . ':' . $this->port, $this->context); } /** * parseCommand * 重写wokerman的解析命令方法 * @return mixed */ public static function parseCommand() { if (static::$_OS !== OS_TYPE_LINUX) { return; } // static::$argvs; // Check static::$argvs; $start_file = static::$argvs[0]; $available_commands = array( 'start', 'stop', 'restart', 'reload', 'status', 'connections', ); $usage = "Usage: php yourfile[mode]\nCommands: \nstart\t\tStart worker in DEBUG mode.\n\t\tUse mode -d to start in DAEMON mode.\nstop\t\tStop worker.\n\t\tUse mode -g to stop gracefully.\nrestart\t\tRestart workers.\n\t\tUse mode -d to start in DAEMON mode.\n\t\tUse mode -g to stop gracefully.\nreload\t\tReload codes.\n\t\tUse mode -g to reload gracefully.\nstatus\t\tGet worker status.\n\t\tUse mode -d to show live status.\nconnections\tGet worker connections.\n"; if (!isset(static::$argvs[1]) || !in_array(static::$argvs[1], $available_commands)) { if (isset(static::$argvs[1])) { static::safeEcho('Unknown command: ' . static::$argvs[1] . "\n"); } exit($usage); } // Get command. $command = trim(static::$argvs[1]); $command2 = isset(static::$argvs[2]) ? static::$argvs[2] : ''; // Start command. $mode = ''; if ($command === 'start') { if ($command2 === '-d' || static::$daemonize) { $mode = 'in DAEMON mode'; } else { $mode = 'in DEBUG mode'; } } static::log("Workerman[$start_file] $command $mode"); // Get master process PID. $master_pid = is_file(static::$pidFile) ? file_get_contents(static::$pidFile) : 0; $master_is_alive = $master_pid && posix_kill($master_pid, 0) && posix_getpid() != $master_pid; // Master is still alive? if ($master_is_alive) { if ($command === 'start') { static::log("Workerman[$start_file] already running"); exit; } } elseif ($command !== 'start' && $command !== 'restart') { static::log("Workerman[$start_file] not run"); exit; } // execute command. switch ($command) { case 'start': if ($command2 === '-d') { static::$daemonize = true; } break; case 'status': while (1) { if (is_file(static::$_statisticsFile)) { @unlink(static::$_statisticsFile); } // Master process will send SIGUSR2 signal to all child processes. posix_kill($master_pid, SIGUSR2); // Sleep 1 second. sleep(1); // Clear terminal. if ($command2 === '-d') { static::safeEcho("\33[H\33[2J\33(B\33[m", true); } // Echo status data. static::safeEcho(static::formatStatusData()); if ($command2 !== '-d') { exit(0); } static::safeEcho("\nPress Ctrl+C to quit.\n\n"); } exit(0); case 'connections': if (is_file(static::$_statisticsFile) && is_writable(static::$_statisticsFile)) { unlink(static::$_statisticsFile); } // Master process wil l send SIGIO signal to all child processes. posix_kill($master_pid, SIGIO); // Waiting amoment. usleep(500000); // Display statisitcs data from a disk file. if(is_readable(static::$_statisticsFile)) { readfile(static::$_statisticsFile); } exit(0); case 'restart': case 'stop': if ($command2 === '-g') { static::$_gracefulStop = true; $sig = SIGTERM; static::log("Workerman[$start_file] is gracefully stopping ..."); } else { static::$_gracefulStop = false; $sig = SIGINT; static::log("Workerman[$start_file] is stopping ..."); } // Send stop signal to master process. $master_pid && posix_kill($master_pid, $sig); // Timeout. $timeout = 5; $start_time = time(); // Check master process is still alive? while (1) { $master_is_alive = $master_pid && posix_kill($master_pid, 0); if ($master_is_alive) { // Timeout? if (!static::$_gracefulStop && time() - $start_time >= $timeout) { static::log("Workerman[$start_file] stop fail"); exit; } // Waiting amoment. usleep(10000); continue; } // Stop success. static::log("Workerman[$start_file] stop success"); if ($command === 'stop') { exit(0); } if ($command2 === '-d') { static::$daemonize = true; } break; } break; case 'reload': if($command2 === '-g'){ $sig = SIGQUIT; }else{ $sig = SIGUSR1; } posix_kill($master_pid, $sig); exit; default : if (isset($command)) { static::safeEcho('Unknown command: ' . $command . "\n"); } exit($usage); } } }
更多编程相关知识，请访问：编程教学！！
# thinkphp # workerman # 自定义 # 重写 # 创建一个 # 命令行 # 第一个 # 多个 # 在此 # 给大家 # 报错 # 介绍一下
相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】
相关推荐： 东莞专业网站制作公司有哪些,东莞招聘网站哪个好？ Laravel如何部署到服务器_线上部署Laravel项目的完整流程与步骤 Laravel怎么解决跨域问题_Laravel配置CORS跨域访问 微信小程序 require机制详解及实例代码 高端网站建设与定制开发一站式解决方案 中企动力 Android 常见的图片加载框架详细介绍 Laravel怎么清理缓存_Laravel optimize clear命令详解 实例解析Array和String方法 如何在腾讯云服务器上快速搭建个人网站？ Laravel如何设置自定义的日志文件名_Laravel根据日期或用户ID生成动态日志【技巧】 微信小程序 scroll-view组件实现列表页实例代码 Linux系统命令中screen命令详解 iOS发送验证码倒计时应用 php后缀怎么变mp4格式错误_修改扩展名提示格式不对怎么办【技巧】 jquery插件bootstrapValidator表单验证详解 Laravel API资源(Resource)怎么用_格式化Laravel API响应的最佳实践 实例解析angularjs的filter过滤器 Laravel如何实现多对多模型关联？（Eloquent教程） javascript事件捕获机制【深入分析IE和DOM中的事件模型】 独立制作一个网站多少钱,建立网站需要花多少钱？ Laravel如何使用查询构建器？（Query Builder高级用法） php静态变量怎么调试_php静态变量作用域调试技巧【解答】 佛山企业网站制作公司有哪些,沟通100网上服务官网？ Win11怎么开启自动HDR画质_Windows11显示设置HDR选项 Laravel 419 page expired怎么解决_Laravel CSRF令牌过期处理 Laravel如何使用Sanctum进行API认证？（SPA实战） 香港服务器建站指南：外贸独立站搭建与跨境电商配置流程 如何在宝塔面板中创建新站点？ 如何用已有域名快速搭建网站？ 百度输入法ai组件怎么删除 百度输入法ai组件移除工具 Laravel如何实现数据导出到PDF_Laravel使用snappy生成网页快照PDF【方案】 Laravel如何实现用户密码重置功能？（完整流程代码） 制作企业网站建设方案,怎样建设一个公司网站？ PythonWeb开发入门教程_Flask快速构建Web应用 Laravel怎么实现一对多关联查询_Laravel Eloquent模型关系定义与预加载【实战】 无锡营销型网站制作公司,无锡网选车牌流程？ Windows Hello人脸识别突然无法使用 Laravel如何创建自定义Facades？（详细步骤） EditPlus中的正则表达式 实战(2) uc浏览器二维码扫描入口_uc浏览器扫码功能使用地址 Windows10电脑怎么查看硬盘通电时间_Win10使用工具检测磁盘健康 如何解决hover在ie6中的兼容性问题 如何在 Python 中将列表项按字母顺序编号（a.、b.、c. …） 如何构建满足综合性能需求的优质建站方案？ Laravel如何实现API资源集合？（Resource Collection教程） Laravel与Inertia.js怎么结合_使用Laravel和Inertia构建现代单页应用 如何在HTML表单中获取用户输入并结合JavaScript动态控制复利计算循环 🚀拖拽式CMS建站能否实现高效与个性化并存？ node.js报错：Cannot find module 'ejs'的解决办法 轻松掌握MySQL函数中的last_insert_id()
l send SIGIO signal to all child processes.
posix_kill($master_pid, SIGIO);
// Waiting amoment.
usleep(500000);
// Display statisitcs data from a disk file.
if(is_readable(static::$_statisticsFile)) {
readfile(static::$_statisticsFile);
}
exit(0);
case 'restart':
case 'stop':
if ($command2 === '-g') {
static::$_gracefulStop = true;
$sig = SIGTERM;
static::log("Workerman[$start_file] is gracefully stopping ...");
} else {
static::$_gracefulStop = false;
$sig = SIGINT;
static::log("Workerman[$start_file] is stopping ...");
}
// Send stop signal to master process.
$master_pid && posix_kill($master_pid, $sig);
// Timeout.
$timeout = 5;
$start_time = time();
// Check master process is still alive?
while (1) {
$master_is_alive = $master_pid && posix_kill($master_pid, 0);
if ($master_is_alive) {
// Timeout?
if (!static::$_gracefulStop && time() - $start_time >= $timeout) {
static::log("Workerman[$start_file] stop fail");
exit;
}
// Waiting amoment.
usleep(10000);
continue;
}
// Stop success.
static::log("Workerman[$start_file] stop success");
if ($command === 'stop') {
exit(0);
}
if ($command2 === '-d') {
static::$daemonize = true;
}
break;
}
break;
case 'reload':
if($command2 === '-g'){
$sig = SIGQUIT;
}else{
$sig = SIGUSR1;
}
posix_kill($master_pid, $sig);
exit;
default :
if (isset($command)) {
static::safeEcho('Unknown command: ' . $command . "\n");
}
exit($usage);
}
}
}