workerman源码分析之启动过程详解

下面由workerman教程栏目给大家介绍workerman源码分析之启动过程,希望对需要的朋友有所帮助!

workerman源码分析之启动过程详解

workerman

版本:3.1.8(linux)

模型:GatewayWorker(Worker模型可与之类比)

注:只贴出讲解部分代码,出处以文件名形式给出,大家可自行查看

workerman最初只开发了Linux版本,win是后来增加的,基于命令行模式运行(cli)。

多进程模型

工作进程,Master、Gateway和Worker,Gateway主要用于处理IO事件,保存客户端链接状态,将数据处理请求发送给Worker等工作,Worker则是完全的业务逻辑处理,前者为IO密集型,后者为计算密集型,它们之间通过网络通信,Gateway和Worker两两间注册通信地址,所以非常方便的进行分布式部署,如果业务处理量大可以单纯的增加Worker服务。

1.jpg

它们有一个负责监听的父进程(Master),监听子进程状态,发送 signal 给子进程,接受来自终端的命令、信号等工作。父进程可以说是整个系统启动后的入口。

启动命令解析

既然以命令模式(cli)运行(注意与 fpm 的区别,后者处理来自网页端的请求),就必然有一个启动脚本解析命令,譬如说3.x版本(之前默认为daemon)新增一个 -d 参数,以表示守护进程运行,解析到该参数设置 self::$daemon = true, 随后fork子进程以脱离当前进程组,设置进程组组长等工作。

这里有两个非常重要的参数 $argc 和 $argc,前者表示参数个数,后者为一个数组,保存有命令的所有参数,比如:sudo php start.php start -d,$argv就是 array( [0]=>start.php, [1]=>start, [2]=>-d ),而解析主要用到$argv。

启动主要执行下面步骤:

1、包含自动加载器 Autoloader ,加载各 Application 下启动文件;

2、设置 _appInitPath 根目录;

3、解析,初始化参数,执行相应命令。

下面是具体实现(workerman/worker.php):

public static function parseCommand()    {        // 检查运行命令的参数        global $argv;        $start_file = $argv[0];         // 命令        $command = trim($argv[1]);                // 子命令,目前只支持-d        $command2 = isset($argv[2]) ? $argv[2] : '';                // 检查主进程是否在运行        $master_pid = @file_get_contents(self::$pidFile);        $master_is_alive = $master_pid && @posix_kill($master_pid, 0);        if($master_is_alive)        {            if($command === 'start')            {                self::log("Workerman[$start_file] is running");            }        }        elseif($command !== 'start' && $command !== 'restart')        {            self::log("Workerman[$start_file] not run");        }                // 根据命令做相应处理        switch($command)        {            // 启动 workerman            case 'start':                if($command2 === '-d')                {                    Worker::$daemonize = true;                }                break;            // 显示 workerman 运行状态            case 'status':                exit(0);            // 重启 workerman            case 'restart':            // 停止 workeran            case 'stop':                // 想主进程发送SIGINT信号,主进程会向所有子进程发送SIGINT信号                $master_pid && posix_kill($master_pid, SIGINT);                // 如果 $timeout 秒后主进程没有退出则展示失败界面                $timeout = 5;                $start_time = time();                while(1)                {                    // 检查主进程是否存活                    $master_is_alive = $master_pid && posix_kill($master_pid, 0);                    if($master_is_alive)                    {                        // 检查是否超过$timeout时间                        if(time() - $start_time >= $timeout)                        {                            self::log("Workerman[$start_file] stop fail");                            exit;                        }                        usleep(10000);                        continue;                    }                    self::log("Workerman[$start_file] stop success");                    // 是restart命令                    if($command === 'stop')                    {                        exit(0);                    }                    // -d 说明是以守护进程的方式启动                    if($command2 === '-d')                    {                        Worker::$daemonize = true;                    }                    break;                }                break;            // 平滑重启 workerman            case 'reload':                exit;        }    }

walker代码注释已经非常详尽,下面有几点细节处:

1、检查主进程是否存活:17行的逻辑与操作,如果主进程PID存在情况下,向该进程发送信号0,实际上并没有发送任何信息,只是检测该进程(或进程组)是否存活,同时也检测当前用户是否有权限发送系统信号;

码上飞 码上飞

码上飞(CodeFlying) 是一款AI自动化开发平台,通过自然语言描述即可自动生成完整应用程序。

码上飞 138 查看详情 码上飞

2、为什么主进程PID会保存?系统启动后脱离当前terminal运行,如果要执行关闭或者其他命令,此时是以另外的一个进程执行该命令,如果我们连进程PID都不知道,那该向谁发信号呢?

所以主进程PID必须保存起来,而且主进程负责监听其他子进程,所以它是我们继续操作的入口。

Worker::runAll()

php的socket编程其实和C差不多,后者对socket进行了再包裹,并提供接口给php,在php下网络编程步骤大大减少。

譬如:stream_socket_server 和 stream_socket_client 直接创建了server/client socke(php有两套socket操作函数)。wm则大量使用了前者,启动过程如下(注释已经非常详尽):

public static function runAll()    {        // 初始化环境变量        self::init();        // 解析命令        self::parseCommand();        // 尝试以守护进程模式运行        self::daemonize();        // 初始化所有worker实例,主要是监听端口        self::initWorkers();        //  初始化所有信号处理函数        self::installSignal();        // 保存主进程pid        self::saveMasterPid();        // 创建子进程(worker进程)并运行        self::forkWorkers();        // 展示启动界面        self::displayUI();        // 尝试重定向标准输入输出        self::resetStd();        // 监控所有子进程(worker进程)        self::monitorWorkers();    }

下面还是只说该过程的关键点:

1、始化环境变量,例如设置主进程名称、日志路径,初始化定时器等等;

2、解析命令行参数,主要用到 $argc 和 $argc 用法同C语言;

3、生成守护进程,以脱离当前终端(两年前大部分认为PHP无法做daemon,其实这是个误区!其实PHP在linux的进程模型很稳定,现在wm在商业的应用已经非常成熟,国内某公司每天处理几亿的连接,用于订单、支付调用,大家可以打消顾虑了);

4、初始化所有worker实例(注意,这里是在主进程做的,只是生成了一堆 server 并没有设置监听,多进程模型是在子进程做的监听,即IO复用);

5、为主进程注册信号处理函数;

6、保存主进程PID,当系统运行后,我们在终端查看系统状态或者执行关闭、重启命令,是通过主进程进行通信,所以需要知道主进程PID,我们知道在终端下敲入一个可执行命令,实则是在当前终端下新建一个子进程来执行,所以我们需要得知主进程PID,以向WM主进程发送SIGNAL,这时信号处理函数捕获该信号,并通过回调方式执行。

7、创建子进程,设置当前进程用户(root)。在多进程模型中,两类子进程,分别监听不同的server地址,我们在主进程只是创建server并没有设置监听,也没有生成指定数目的server。

原因在于,我们在一个进程多次创建同一个 socket,会报错, worker数目其实就是 socket 数量,也就是该 socket 的子进程数目,子进程继承了父进程上下文,但是只监听特定的 socket 事件;

8、在子进程中,将 server socket 注册监听事件,用到一个扩展Event,可以实现IO复用,并注册数据读取回调,同时也可注册socket连接事件回调;

9、输入输出重定向;

10、主进程监听子进程状态,在一个无限循环中调用 pcntl_signal_dispatch() 函数,用于捕获子进程退出状态,该函数会一直阻塞,直到有子进程退出时才触发;

更多workerman相关知识请关注workerman教程栏目。

以上就是workerman源码分析之启动过程详解的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/364341.html

赞 (0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
今天的课程-状态,数据类型
上一篇 2025年11月6日 04:30:06
电脑出现no bootable device怎么解决 五种方法分享
下一篇 2025年11月6日 04:30:08

相关推荐

  • Workerman的应用方向有哪些

    Workerman的应用方向有哪些Workerman的应用方向有哪些Workerman的应用方向有哪些Workerman的应用方向有哪些

    下面由workerman使用教程栏目给大家介绍workerman的应用方向有哪些,希望对需要的朋友有所帮助! Workerman不同于传统MVC框架,Workerman不仅可以用于Web开发,同时还有更广阔的应用领域,例如即时通讯类、物联网、游戏、服务治理、其它服务器或者中间件,这无疑大大提高了PH…

    2026年9月25日 • 用户投稿
    000
  • Workerman框架的理念

    Workerman框架的理念Workerman框架的理念Workerman框架的理念Workerman框架的理念

    下面由workerman教程栏目给大家介绍workerman框架的理念是什么,希望对需要的朋友有所帮助! Workerman框架的理念 极简、稳定、高性能、分布式。 极简 小即是美,Workerman内核极简,仅有几个php文件并且只暴露几个接口,学习起来非常简单。所有其它功能通过组件的方式扩展。 …

    2026年9月25日 • 用户投稿
    000
  • WorkerMan的特性

    WorkerMan的特性WorkerMan的特性WorkerMan的特性WorkerMan的特性

    下面由workerman php教程栏目给大家介绍workerman的特性,希望对需要的朋友有所帮助! WorkerMan的特性 1、纯PHP开发 使用WorkerMan开发的应用程序不依赖php-fpm、apache、nginx这些容器就可以独立运行。 这使得PHP开发者开发、部署、调试应用程序非…

    2026年9月25日 • 用户投稿
    500
  • workerman之小谈PHP中的几种运行模式

    workerman之小谈PHP中的几种运行模式workerman之小谈PHP中的几种运行模式workerman之小谈PHP中的几种运行模式workerman之小谈PHP中的几种运行模式

    下面由workerman使用教程栏目给大家介绍php中的几种运行模式,希望对需要的朋友有所帮助! 我们知道 workerman 程序需要在php-cli模式下运行,也就是命令行模式,这块我们有必要了解一下。话说PHP当下一共有4种运行模式,分别是CGI、FastCGI、CLI和Web模块模式。 CG…

    2026年9月25日 • 用户投稿
    600
  • workerman是什么意思

    workerman是什么意思workerman是什么意思workerman是什么意思workerman是什么意思

    下面由workerman入门教程栏目给大家介绍什么是workerman,希望对需要的朋友有所帮助! Workerman,高性能socket服务框架 Workerman是什么? Workerman是一款纯PHP开发的开源高性能的PHP socket 服务框架。 boardmix博思白板 boardmi…

    2026年9月25日 • 用户投稿
    700
  • WorkerMan Connection类的使用(附代码)

    WorkerMan Connection类的使用(附代码)WorkerMan Connection类的使用(附代码)WorkerMan Connection类的使用(附代码)WorkerMan Connection类的使用(附代码)

    下面由workerman教程栏目给大家介绍workerman connection类的使用,希望对需要的朋友有所帮助! 一、TcpConnection类 的使用  1、简单的TCP测试 Server.php 代码小浣熊 代码小浣熊是基于商汤大语言模型的软件智能研发助手,覆盖软件需求分析、架构设计、代…

    2026年9月25日 • 用户投稿
    000
  • workerman与thinkphp结合使用的方法

    workerman与thinkphp结合使用的方法workerman与thinkphp结合使用的方法workerman与thinkphp结合使用的方法workerman与thinkphp结合使用的方法

    下面由workerman入门教程栏目给大家介绍将workerman与thinkphp结合的方法,希望对大家有一定的帮助。 运行workerman需要安装pcntl和event或者libevent pcntl安装方法: 以php-5.5.20为例,实际情况按自己安装的PHP目录 立即学习“PHP免费学…

    2026年9月25日 • 用户投稿
    200
  • 什么是workerman?

    什么是workerman?什么是workerman?什么是workerman?什么是workerman?

    workerman是一个高性能的PHP socket 服务器框架,workerman基于PHP多进程以及libevent事件轮询库,PHP开发者只要实现一两个接口,便可以开发出自己的网络应用,例如Rpc服务、聊天室服务器、手机游戏服务器等。 workerman的目标是让PHP开发者更容易的开发出基于…

    2026年9月25日 • 用户投稿
    000
  • 怎么启动workerman

    怎么启动workerman怎么启动workerman怎么启动workerman怎么启动workerman

    注意Workerman启动停止等命令都是在命令行中完成的。 要启动Workerman,首先需要有一个启动入口文件,里面定义了服务监听的端口及协议。 启动           (推荐学习: workerman教程) 以debug(调试)方式启动 php start.php start 以daemon(…

    2026年9月25日 • 用户投稿
    000
  • workerman用什么协议

    workerman用什么协议workerman用什么协议workerman用什么协议workerman用什么协议

    workerman用什么协议?workerman支持哪些协议? WorkerMan在接口上支持各种协议,只要符合ConnectionInterface接口即可(参见定制通讯协议章节)。 为了方便开发者,WorkerMan提供了HTTP协议、WebSocket协议以及非常简单的Text文本协议、可用于…

    2026年9月25日 • 用户投稿
    100
  • TP5 如何整合 WorkerMan 以及 GatewayWorker

    TP5 如何整合 WorkerMan 以及 GatewayWorkerTP5 如何整合 WorkerMan 以及 GatewayWorkerTP5 如何整合 WorkerMan 以及 GatewayWorkerTP5 如何整合 WorkerMan 以及 GatewayWorker

    下面由workerman教程栏目给大家介绍tp5整合 workerman 以及 gatewayworker的方法,希望对需要的朋友有所帮助! TP5整合GatewayWorker Windows版安装 a)使用composer create-project topthink/think testTG…

    2026年9月25日 • 用户投稿
    100
  • workerman关闭失败

    workerman关闭失败workerman关闭失败workerman关闭失败workerman关闭失败

    运行 php start.php stop 提示 stop fail 原因:几种可能性         (推荐学习: workerman教程) 第一种可能性: 前提是以debug方式启动的workerman,开发者在终端按了ctrl z给workerman发送了SIGSTOP信号,导致workerm…

    2026年9月25日 • 用户投稿
    100
  • php workerman能做什么

    php workerman能做什么php workerman能做什么php workerman能做什么php workerman能做什么

    php workerman能做什么? Workerman是一款纯PHP开发的开源高性能的PHP socket 服务框架。 Workerman不是重复造轮子,它不是一个MVC框架,而是一个更底层更通用的socket服务框架,你可以用它开发tcp代理、梯子代理、做游戏服务器、邮件服务器、ftp服务器、甚…

    2026年9月25日 • 用户投稿
    200
  • php workerman是异步么

    php workerman是异步么php workerman是异步么php workerman是异步么php workerman是异步么

    workerman官方介绍:Workerman是一款开源高性能异步PHP socket即时通讯框架。支持高并发,超高稳定性,被广泛的用于手机app、移动通讯,微信小程序,手游服务端、网络游戏等开发。       (推荐学习: workerman教程)  支持TCP长连接,支持Websocket、HT…

    2026年9月24日 • 用户投稿
    100
  • workerman如何保持连接

    workerman如何保持连接workerman如何保持连接workerman如何保持连接workerman如何保持连接

    正常的情况客户端断开连接会向服务端发送一个fin包,服务端收到fin包后得知客户端连接断开,则立刻触发onClose事件回调。 但是有些极端情况如客户端掉电、网络关闭、拔网线、路由故障等,这些极端情况客户端无法发送fin包给服务端,服务端便无法知道连接已经断开。如果客户端与服务端定时有心跳数据传输,…

    2026年9月24日 • 用户投稿
    100
  • linux下workerman怎么启动

    linux下workerman怎么启动linux下workerman怎么启动linux下workerman怎么启动linux下workerman怎么启动

    注意Workerman启动停止等命令都是在命令行中完成的。 要启动Workerman,首先需要有一个启动入口文件,里面定义了服务监听的端口及协议。 启动 1、以debug(调试)方式启动 php start.php start 2、以daemon(守护进程)方式启动 php start.php st…

    2026年9月24日 • 用户投稿
    100
  • workerman无法启动的原因与解决方法

    workerman无法启动的原因与解决方法workerman无法启动的原因与解决方法workerman无法启动的原因与解决方法workerman无法启动的原因与解决方法

    工作中碰到workerman启动失败最常见的就是由于启动脚本找不到主进程pid文件导致的,workerman 3.2.2之前的版本主进程pid文件默认存储在/tmp/下,有些系统会定时清理/tmp/目录,导致无法启动。 解决方法: 方法1:升级workerman到3.2.2或以上版本,workerm…

    2026年9月24日 • 用户投稿
    000
  • Workerman网络编程实践:构建实时数据同步系统

    workerman网络编程实践:构建实时数据同步系统 引言:现在,随着互联网的高速发展和智能设备的普及,实时数据同步系统成为各个行业不可或缺的一部分。实时数据同步系统可以将数据快速地从一个源同步到多个目标,确保数据的准确性和及时性。本文将介绍如何使用PHP扩展库Workerman来构建一个高效的实时…

    用户投稿 2026年9月22日
    100
  • Workerman开发技巧大揭秘:提升网络应用性能的实用技巧

    workerman开发技巧大揭秘:提升网络应用性能的实用技巧 引言:Web应用程序的性能对于用户体验至关重要。网络应用性能的提升除了优化前端页面加载速度外,后端服务器的处理能力也是不可忽视的。在这方面,Workerman是一个强大的PHP框架,它可以帮助我们构建高性能的网络应用。本文将揭示一些实用的…

    用户投稿 2026年9月22日
    000
  • Workerman网络编程实践:构建可靠的即时数据同步系统

    workerman网络编程实践:构建可靠的即时数据同步系统 随着互联网和移动设备的普及,即时通讯变得越来越重要。在不同设备和平台之间实现即时通讯和数据同步已经成为开发者的常见需求。在这篇文章中,我们将探讨如何使用Workerman网络编程框架构建一个可靠的即时数据同步系统。 Workerman简介W…

    用户投稿 2026年9月22日
    100

发表回复

登录后才能评论
关注微信