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 如何防范常见的网络攻击,如 DDoS?

    在 workerman 中可以有效防范 ddos 攻击。1) 通过流量监控和请求限制识别并阻止异常请求。2) 使用中间件实现流量分析和限制。3) 结合 redis 进行更精细的流量控制和持久化存储。 引言 在当今互联网时代,网络安全问题日益突出,DDoS(分布式拒绝服务)攻击更是让许多开发者头疼。作…

    2026年8月28日
    400
  • 基于 Workerman 开发定时任务系统,有哪些实现方式?

    workerman 提供了多种实现定时任务系统的方法。1) 使用 timer::add 方法可以设置定时任务,如每分钟执行一次。2) 高级用法包括动态添加或删除任务,使用 timer::del 方法。3) 性能优化建议包括任务并行和任务分片,以提高系统效率。 引言 在现代的 Web 开发中,定时任务…

    2026年8月28日
    000
  • Workerman 日志记录异常,无法定位错误信息怎么办?

    解决 workerman 日志记录异常的方法包括:1. 确认日志配置正确,检查路径和权限;2. 调整日志级别至debug;3. 添加自定义日志记录;4. 检查服务器磁盘空间;5. 使用logviewer工具;6. 将日志输出到控制台。通过这些步骤,可以有效定位和解决日志记录问题,提高开发效率。 在使…

    2026年8月28日
    100
  • 基于OpenTelemetry的Workerman分布式追踪方案

    在workerman中引入分布式追踪的原因是:1)诊断问题,2)性能优化,3)日志关联。实现方案包括:1)集成opentelemetry sdk,2)创建和管理追踪span,3)在worker间传递追踪上下文,4)考虑性能开销、数据采样和存储查询。 在探讨基于OpenTelemetry的Worker…

    2026年8月28日
    200
  • 物联网场景:Workerman+MQTT 5.0协议深度整合

    workerman 和 mqtt 5.0 协议的整合可以高效管理物联网设备并实现实时通信。1. 在 workerman 中集成 mqtt 客户端库,如 php-mqtt/client。2. 启动 workerman 服务器并连接到 mqtt broker,订阅和发布消息。3. 注意性能优化、安全性、…

    2026年8月28日
    300
  • 使用Workerman实现WebSocket服务

    使用workerman实现websocket服务的步骤包括:1) 使用简洁的api快速搭建websocket服务器,只需几行代码;2) 处理连接建立、消息接收和连接关闭的回调函数;3) 优化连接管理、消息处理和错误处理;4) 注意资源管理和垃圾回收,以提升性能。 你想知道如何使用Workerman实…

    2026年8月28日
    100
  • Workerman在ARM架构(如苹果M系列芯片)的兼容性优化

    workerman在arm架构上兼容性良好,通过优化可实现高性能。1)使用php 8.0及以上版本,2)调整worker数量以利用多核优势,3)优化内存分配策略,4)使用pcntl扩展提升进程管理效率。 Workerman在ARM架构(如苹果M系列芯片)的兼容性优化 当谈到在ARM架构上优化Work…

    2026年8月27日
    000
  • ReactPHP与Workerman的架构对比

    选择异步和事件驱动的架构是因为它们能显著提高应用程序性能,特别是在处理大量并发连接或i/o密集型任务时。1)reactphp基于事件循环,适合处理大量异步i/o操作;2)workerman通过多进程和多线程,适用于高并发连接和高性能需求。 谈到ReactPHP和Workerman的架构对比,我们需要…

    2026年8月27日
    100
  • Workerman如何与Laravel/Symfony集成?

    Workerman如何与Laravel/Symfony集成?这个问题实际上涉及到如何将一个高性能的PHP WebSocket服务器与现代PHP框架进行无缝集成。让我从这个角度出发,详细展开这方面的讨论。 好的,那么我们就来聊聊如何将Workerman与Laravel或Symfony集成吧。我会从实际…

    2026年8月26日
    100
  • 如何编写Workerman的单元测试?

    编写workerman的单元测试需要考虑其异步非阻塞特性。步骤如下:1.准备测试环境,使用workermanconnectiontcpconnection模拟tcp连接,并安装phpunit。2.编写测试用例,测试worker服务的onconnect、onmessage和onclose事件。3.运行…

    2026年8月26日
    000
  • 如何开发Workerman插件?

    开发workerman插件的步骤包括:1.理解workerman的架构和插件生命周期;2.定义一个继承自plugininterface的插件类,实现onconnect、onmessage、onclose等方法;3.注意资源管理和性能优化,避免内存泄漏和阻塞事件循环;4.确保插件的可维护性和可读性,通…

    2026年8月26日
    000
  • Workerman服务如何防御新型DDoS攻击(如HTTP/2 Rapid Reset)?

    新型ddos攻击如http/2 rapid reset对传统防御措施有效,因为它们利用http/2协议特性耗尽服务器资源。防御策略包括:1. 限制并发连接和请求,2. 监控和检测异常流量,3. 使用http/2特性进行防御,4. 结合第三方ddos防护服务。 在讨论如何防御新型DDoS攻击如HTTP…

    2026年8月26日
    000
  • Workerman的进程模型(多进程/单线程)解析

    workerman采用多进程/单线程模型的原因是它能在保持高并发能力的同时,简化开发和调试过程。1) 多进程利用多核cpu,提高并发能力。2) 单线程避免多线程编程的复杂性和死锁问题。3) 每个进程独立处理连接,减少内存泄漏风险。尽管如此,进程间通信和状态共享需要特别注意,建议通过redis解决,并…

    2026年8月26日
    000
  • Workerman 5.0新特性解读

    workerman 5.0带来了性能提升、协程支持和扩展的协议支持。1)性能优化使其在处理大量连接时表现出色。2)内置协程支持简化了异步任务开发。3)新增对http/2和http/3的支持,提升了现代web应用的数据传输效率。 在编程世界里,Workerman一直是处理高并发和实时通信的利器,随着5…

    2026年8月25日
    000
  • Workerman的未来路线图

    workerman未来将专注于提升性能、扩展多语言支持、加强生态系统集成和提高易用性。1.通过优化底层实现和网络协议提升性能。2.逐步支持go、python等语言。3.加强与docker、kubernetes的集成。4.推出更多工具和文档提高易用性。 关于Workerman的未来路线图,我认为Wor…

    2026年8月25日
    000
  • php长连接什么

    PHP长连接指在常驻内存环境中复用数据库或缓存连接,减少频繁创建开销。1. 传统FPM模式每次请求重建连接,效率低;2. 长连接通过持久化连接实现复用,常见于Swoole、Workerman等环境;3. MySQL可通过PDO或mysqli持久连接,Redis可在协程中复用连接;4. 结合协程与连接…

    2025年12月13日
    000
  • php代码代码热更新怎么实现_php代码热部署与代码更新性能优化方法指南

    答案:PHP热更新需综合缓存、部署和架构策略。通过OPcache配置、软链接切换、FPM平滑重启或Swoole的reload机制实现代码生效;结合容器滚动更新、灰度发布与监控回滚,确保更新快速稳定。 PHP 本身是解释型语言,代码修改后通常只需保存文件即可生效,无需重启服务,这天然支持“热更新”。但…

    2025年12月12日
    300
  • php怎么调试接口定时任务_php接口定时触发与任务调度调试方法

    答案:调试PHP接口定时任务需确保任务按时执行并定位错误。首先确认cron设置正确,通过日志记录脚本执行时间;检查系统cron日志及PHP CLI环境一致性。其次模拟接口请求,使用curl手动触发或在脚本中调用接口,并记录响应内容。接着开启错误报告与异常捕获,将错误写入日志文件以便排查。最后可借助S…

    2025年12月12日
    500
  • php怎么调试接口连接池优化_php接口数据库连接池配置与性能优化方法

    答案:通过持久连接、PHP-FPM进程模型优化及Swoole协程连接池,结合合理配置与监控,可有效提升PHP接口数据库连接性能。 调试和优化 PHP 接口中的数据库连接池,核心在于减少频繁创建销毁连接的开销、提升并发处理能力,并合理监控与配置资源。虽然 PHP 本身是短生命周期脚本语言,不像 Jav…

    2025年12月12日
    300
  • php代码数据库连接数过多怎么优化_php代码连接数限制与并发性能优化方法

    答案:优化PHP项目数据库连接需控制连接数、减少无效连接并提升复用。1. 谨慎使用持久连接以降低开销,但需处理状态残留问题;2. 推荐Swoole协程+连接池实现连接复用与数量限制;3. 显式关闭连接并避免循环中重复创建;4. 调整MySQL的max_connections和超时参数以回收空闲连接;…

    2025年12月12日
    700

发表回复

登录后才能评论
关注微信