0

0

PHP 中实现毫秒级 SIGALRM 信号触发的轻量级方案

聖光之護

聖光之護

发布时间:2026-03-03 16:19:00

|

349人浏览过

|

来源于php中文网

原创

PHP 中实现毫秒级 SIGALRM 信号触发的轻量级方案

本文介绍一种不依赖 swoole 等扩展、纯 php 实现的毫秒级定时 sigalrm 信号机制,通过长期驻留的子进程协同主进程完成高精度中断调度,并附带可直接运行的封装类与关键注意事项。

本文介绍一种不依赖 swoole 等扩展、纯 php 实现的毫秒级定时 sigalrm 信号机制,通过长期驻留的子进程协同主进程完成高精度中断调度,并附带可直接运行的封装类与关键注意事项。

在 PHP 原生扩展中,pcntl_alarm(int $seconds) 仅支持秒级精度,无法满足毫秒级(如 200ms、1.5s)定时中断需求。虽然 Swoole\Process::alarm() 提供了微秒级支持,但其强依赖 PECL 扩展,不符合“裸机 PHP”(bare-bones PHP)场景要求。本文提供一个纯 PHP、无外部依赖、资源可控的替代方案:利用 proc_open 启动一个长期运行的轻量级中断管理子进程,主进程通过管道向其下发带延迟的 SIGALRM 触发指令,从而实现亚秒级信号调度。

该方案核心思想是分离关注点

  • 主进程专注业务逻辑与信号处理;
  • 子进程专注高精度时间轮询与信号投递,避免频繁 fork 开销;
  • 双进程通过 php://fd/3(自定义文件描述符)建立低开销通信通道。

以下是精简、健壮、可复用的完整实现:

<?php

class Interrupter
{
    private ?InterrupterProcess $process = null;

    public function __construct()
    {
        pcntl_async_signals(true);
        pcntl_signal(SIGALRM, [$this, 'handleSignal']);
    }

    public function interrupt(float $delaySeconds): void
    {
        if ($delaySeconds <= 0) {
            throw new InvalidArgumentException('Delay must be positive');
        }

        if ($this->process === null) {
            $this->process = new InterrupterProcess();
        }

        $this->process->setInterrupt(posix_getpid(), $delaySeconds);
    }

    public function handleSignal(int $signal): void
    {
        if ($signal === SIGALRM) {
            echo "[INTERRUPT] Signal received at " . date('H:i:s.u') . "\n";
            // 此处可执行中断响应逻辑,如跳出循环、清理资源等
        }
    }

    public function __destruct()
    {
        $this->process?->destroy();
    }
}

class InterrupterProcess
{
    private $process;
    private $writePipe;

    private const PROCESS_CODE = <<<'CODE'
<?php
declare(strict_types=1);
$readPipe = fopen('php://fd/3', 'r');
$interrupts = [];

while (true) {
    $r = [$readPipe];
    $w = null;
    $e = null;

    $now = microtime(true);
    $minExpiry = !empty($interrupts) ? min($interrupts) : $now + 1;
    $timeout = $minExpiry - $now;

    // stream_select 支持微秒级超时(int sec, int usec)
    $sec = (int)$timeout;
    $usec = (int)(fmod($timeout, 1) * 1_000_000);
    if ($timeout < 0) { $sec = $usec = 0; }

    if (@stream_select($r, $w, $e, $sec, $usec) > 0) {
        $line = fgets($readPipe);
        if ($line !== false) {
            $req = json_decode($line, true);
            if (isset($req['pid']) && isset($req['microtime'])) {
                $interrupts[$req['pid']] = $req['microtime'];
            }
        }
    }

    $now = microtime(true);
    foreach ($interrupts as $pid => $expiry) {
        if ($expiry <= $now) {
            @posix_kill($pid, SIGALRM);
            unset($interrupts[$pid]);
        }
    }
}
CODE;

    public function __construct()
    {
        $descriptors = [
            ['pipe', 'r'], // stdin
            STDOUT,
            STDERR,
            ['pipe', 'r'], // fd 3: custom pipe for IPC
        ];

        $this->process = proc_open(['php', '-d', 'error_reporting=0'], $descriptors, $pipes);

        if (!is_resource($this->process)) {
            throw new RuntimeException('Failed to start interrupter process');
        }

        $this->writePipe = $pipes[3];
        fwrite($pipes[0], self::PROCESS_CODE);
        fclose($pipes[0]);
    }

    public function setInterrupt(int $pid, float $delaySeconds): bool
    {
        if (!$this->writePipe || feof($this->writePipe)) {
            return false;
        }

        $payload = json_encode([
            'pid' => $pid,
            'microtime' => microtime(true) + $delaySeconds
        ]) . "\n";

        return fwrite($this->writePipe, $payload) !== false;
    }

    public function destroy(): void
    {
        if ($this->writePipe && !feof($this->writePipe)) {
            fclose($this->writePipe);
        }
        if ($this->process) {
            proc_terminate($this->process, 9);
            proc_close($this->process);
        }
    }
}

// ✅ 使用示例
$interrupter = new Interrupter();

for ($i = 0; $i < 3; $i++) {
    echo "[LOOP {$i}] Starting 10s sleep at " . date('H:i:s') . "...\n";

    // 2.3 秒后触发 SIGALRM(精确到 ~10ms 级别)
    $interrupter->interrupt(2.3);

    // 模拟长任务 —— 将被提前中断
    $start = time();
    while (time() - $start < 10) {
        usleep(100000); // 避免 CPU 空转
    }
}

关键优势说明

微信小程序公众号SaaS管理系统
微信小程序公众号SaaS管理系统

微信小程序公众号SaaS管理系统是一款完全开源的微信第三方管理系统,为中小企业提供最佳的小程序集中管理解决方案。可实现小程序的快速免审核注册(免300元审核费),可批量发布小程序模板,同步升级版本等功能。基础版本提供商城和扫码点餐两种小程序模板。商户端可以实现小程序页面模块化设计和自动生成小程序源代码并直接发布。

下载

立即学习PHP免费学习笔记(深入)”;

  • 单子进程复用:避免每次 alarm() 都 fork 新进程,显著降低系统开销与调度延迟;
  • 微秒级精度保障:子进程使用 stream_select($r, $w, $e, $sec, $usec) 实现纳秒级就绪等待(底层调用 select(2) 或 epoll_wait),实际误差通常
  • 异步安全:主进程始终以 pcntl_async_signals(true) 启用异步信号处理,确保 SIGALRM 不被阻塞;
  • 自动清理:__destruct 确保进程与管道资源在脚本结束时释放,防止僵尸进程。

⚠️ 重要注意事项

  • 仅限 CLI 模式:pcntl 和 posix 扩展在 Web SAPI(如 Apache/FPM)中不可用或行为异常,本方案必须运行于 CLI 环境
  • 信号不可靠性:SIGALRM 是不可排队信号,若在前一个未处理完时再次触发,将被合并丢失——建议中断处理逻辑保持极简(如仅设标志位),复杂逻辑移至主循环检查;
  • 进程隔离限制:子进程无法访问主进程内存或对象,所有通信必须通过序列化(如 JSON)完成;
  • 调试建议:启用 pcntl_signal_get_handler(SIGALRM) 验证回调注册成功;用 strace -p $(pgrep -f 'interrupter.php') -e trace=select,kill 监控底层系统调用。

综上,该方案在不引入第三方扩展的前提下,以清晰的进程协作模型,为 PHP 提供了生产可用的毫秒级信号定时能力,适用于 CLI 守护进程、批处理超时控制、协程模拟等典型场景。

相关文章

PHP速学教程(入门到精通)
PHP速学教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
swoole为什么能常驻内存
swoole为什么能常驻内存

swoole常驻内存的特性:1. 事件驱动模型减少内存消耗;2. 协程并行执行任务占用更少内存;3. 协程池预分配协程消除创建开销;4. 静态变量保留状态减少内存分配;5. 共享内存跨协程共享数据降低内存开销。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

305

2024.04.10

json数据格式
json数据格式

JSON是一种轻量级的数据交换格式。本专题为大家带来json数据格式相关文章,帮助大家解决问题。

452

2023.08.07

json是什么
json是什么

JSON是一种轻量级的数据交换格式,具有简洁、易读、跨平台和语言的特点,JSON数据是通过键值对的方式进行组织,其中键是字符串,值可以是字符串、数值、布尔值、数组、对象或者null,在Web开发、数据交换和配置文件等方面得到广泛应用。本专题为大家提供json相关的文章、下载、课程内容,供大家免费下载体验。

546

2023.08.23

jquery怎么操作json
jquery怎么操作json

操作的方法有:1、“$.parseJSON(jsonString)”2、“$.getJSON(url, data, success)”;3、“$.each(obj, callback)”;4、“$.ajax()”。更多jquery怎么操作json的详细内容,可以访问本专题下面的文章。

328

2023.10.13

go语言处理json数据方法
go语言处理json数据方法

本专题整合了go语言中处理json数据方法,阅读专题下面的文章了解更多详细内容。

81

2025.09.10

string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

910

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

598

2024.08.29

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

294

2025.08.29

Swift iOS架构设计与MVVM模式实战
Swift iOS架构设计与MVVM模式实战

本专题聚焦 Swift 在 iOS 应用架构设计中的实践,系统讲解 MVVM 模式的核心思想、数据绑定机制、模块拆分策略以及组件化开发方法。内容涵盖网络层封装、状态管理、依赖注入与性能优化技巧。通过完整项目案例,帮助开发者构建结构清晰、可维护性强的 iOS 应用架构体系。

2

2026.03.03

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
PHP课程
PHP课程

共137课时 | 12.8万人学习

JavaScript ES5基础线上课程教学
JavaScript ES5基础线上课程教学

共6课时 | 11.3万人学习

PHP新手语法线上课程教学
PHP新手语法线上课程教学

共13课时 | 1.0万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号