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

workerman

版本：3.1.8（linux）

模型：GatewayWorker（Worker模型可与之类比）

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

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

多进程模型

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

它们有一个负责监听的父进程（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，实际上并没有发送任何信息，只是检测该进程（或进程组）是否存活，同时也检测当前用户是否有权限发送系统信号；

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  # php  # c语言  # 分布式  # gateway  # Array  # 命令行参数  # 循环  # 继承  # 接口  # 堆  # signal  # Event  # 事件  # linux 

相关栏目： 【 网站优化151355 】 【 网络推广146373 】 【 网络技术251813 】 【 AI营销90571 】

相关推荐： 教学论文网站制作软件有哪些,写论文用什么软件 ？  PHP正则匹配日期和时间(时间戳转换)的实例代码  如何在云主机快速搭建网站站点？  Laravel怎么自定义错误页面_Laravel修改404和500页面模板  如何选择可靠的免备案建站服务器？  如何快速查询网址的建站时间与历史轨迹？  Laravel distinct去重查询_Laravel Eloquent去重方法  为什么要用作用域操作符_php中访问类常量与静态属性的优势【解答】  如何彻底卸载建站之星软件？  香港服务器租用每月最低只需15元？  Java类加载基本过程详细介绍  Laravel如何保护应用免受CSRF攻击？（原理和示例）  千库网官网入口推荐 千库网设计创意平台入口  Win11怎样安装网易有道词典_Win11安装词典教程【步骤】  1688铺货到淘宝怎么操作 1688一键铺货到自己店铺详细步骤  iOS验证手机号的正则表达式  Laravel Vite是做什么的_Laravel前端资源打包工具Vite配置与使用  电商网站制作价格怎么算,网上拍卖流程以及规则？  制作旅游网站html,怎样注册旅游网站？  Laravel如何发送系统通知_Laravel Notifications实现多渠道消息通知  DeepSeek是免费使用的吗 DeepSeek收费模式与Pro版本功能详解  网站制作报价单模板图片,小松挖机官方网站报价？  大连网站制作费用,大连新青年网站，五年四班里的视频怎样下载啊？  Laravel如何安装使用Debugbar工具栏_Laravel性能调试与SQL监控插件【步骤】  怎样使用JSON进行数据交换_它有什么限制  如何快速启动建站代理加盟业务？  Laravel怎么写单元测试_PHPUnit在Laravel项目中的基础测试入门  如何在IIS7上新建站点并设置安全权限？  高端企业智能建站程序：SEO优化与响应式模板定制开发  教你用AI将一段旋律扩展成一首完整的曲子  在线教育网站制作平台,山西立德教育官网？  Laravel如何使用查询构建器？（Query Builder高级用法）  Python企业级消息系统教程_KafkaRabbitMQ高并发应用  Laravel如何实现密码重置功能_Laravel密码找回与重置流程  Laravel怎么配置S3云存储驱动_Laravel集成阿里云OSS或AWS S3存储桶【教程】  Android使用GridView实现日历的简单功能  ,网页ppt怎么弄成自己的ppt？  成都网站制作公司哪家好,四川省职工服务网是做什么用？  如何快速搭建高效WAP手机网站？  如何用IIS7快速搭建并优化网站站点？  电商网站制作多少钱一个,电子商务公司的网站制作费用计入什么科目？  Laravel如何实现多语言支持_Laravel本地化与国际化(i18n)配置教程  Laravel中间件起什么作用_Laravel Middleware请求生命周期与自定义详解  详解ASP.NET 生成二维码实例（采用ThoughtWorks.QRCode和QrCode.Net两种方式）  如何在IIS7中新建站点？详细步骤解析  如何实现javascript表单验证_正则表达式有哪些实用技巧  武汉网站设计制作公司,武汉有哪些比较大的同城网站或论坛，就是里面都是武汉人的？  laravel怎么配置Redis作为缓存驱动_laravel Redis缓存配置教程  Laravel模型关联查询教程_Laravel Eloquent一对多关联写法  Laravel怎么使用Session存储数据_Laravel会话管理与自定义驱动配置【详解】