当前位置:首页 > PHP > 正文内容

php多进程实现任务管理器,定时执行任务,支持守护

高老师7年前 (2019-04-03)PHP1830

主要原理是通过PHP创建多个子进程,在子进程中发送进程闹钟信号,然后再监听闹钟信号中继续发送闹钟信号。同时通过父进程设置非阻塞运行。代码如下:

<?php
/**
 * 订单任务
 */
class Order
{
    public function run()
    {
        file_put_contents("log1.txt", '我是订单任务,本次运行时间:' . date('Y-m-d H:i:s') . "\r\n", FILE_APPEND);
    }
}

/**
 * 商品任务
 */
class Goods
{
    public function run()
    {
        file_put_contents("log2.txt", '我是商品任务,本次运行时间:' . date('Y-m-d H:i:s') . "\r\n", FILE_APPEND);
    }
}


/**
 * Task任务核心
 */
class Console
{
    /**
     * 定时任务配置和执行时间间隔
     */
    protected static $tasks = [
        'Order' => 5,
        'Goods' => 10,
    ];

    /**
     * 初始化为每个任务分配进程
     */
    public static function init()
    {
        $tasks = self::$tasks;

        foreach ($tasks as $task => $second)
        {
            //创建子进程
            $pid = pcntl_fork();

            if ($pid == -1)
            {
                die ('创建子进程失败!');
            }
            elseif ($pid)
            {
                //等待子进程执行完成回收,并且设置非阻塞
                pcntl_wait($status, WNOHANG);
            }
            else
            {
                self::process($task, $second);
                //子进程执行完成关闭,避免重复fork
                die();
            }
        }
    }

    /**
     * 子进程闹钟处理任务
     */
    public static function process($task, $second)
    {
        //安装信号管理
        pcntl_signal(SIGALRM, function () use ($task, $second) {
            pcntl_alarm($second);
            $taskObj = new $task();
            call_user_func([$taskObj, 'run']);
        }, false);

        //发送闹钟信号
        pcntl_alarm($second);

        //调用等待信号的处理器
        while (true)
        {
            pcntl_signal_dispatch();
        }
    }
}

//初始化
Console::init();

程序执行后.主进程会根据已经配置的任务数来分配子进程,每个子进程来定时执行对应的任务,可以用来做redis消费者。

以上只是给你一个思路来实现,你还可以直接用我开源的定时器直接使用,访问地址:https://gitee.com/392223903/EasyTask

扫描二维码推送至手机访问。

版权声明:本文由高久峰个人博客发布,如需转载请注明出处。

本文链接:https://blog.20230611.cn/post/82.html

分享给朋友:

“php多进程实现任务管理器,定时执行任务,支持守护” 的相关文章

php调用 java webservice接口

php调用 java webservice接口

php调用Webservice基本语法如下:$url ='xxxxxxx.cn'  //链接服务器端 $client = new SoapClient($url);通过以上语法已经连接到webservice,也可将wsdl在本地使用,...

PHP yield  PHP协程,PHP协程用法学习

PHP yield PHP协程,PHP协程用法学习

【一】.迭代器迭代是指反复执行一个过程,每执行一次叫做一次迭代。比如下面的代码就叫做迭代:1.  <?php   2.  $data = ['1', '2', &...

PHP最快方式模拟curl,PHP最快爬虫模拟方法

PHP最快方式模拟curl,PHP最快爬虫模拟方法

有时候我们需要爬一个接口,但是这个接口需要很多参数,包括header和cookie要去编写,使用php curl模拟实在太慢。我们可以通过浏览器的network来复制请求为curl命令。例如我需要模拟请求接口地址:https://www.xkmz.cc/Ajax/Debug/delly,我们只需要在...

php jsonp转json,php jsonp转数组,php jsonp转对象

php jsonp转json,php jsonp转数组,php jsonp转对象

将jsonp转为PHP数组和对象。/**  * jsonp转数组|Jsonp转json  * @param string $jsonp jsonp字符串  * @param bool $as...

php位运算符详解

php位运算符详解

文章篇幅较长,如果不喜欢看文章的,此处抛出韩顺丰老师的位运算视频,韩老师应该是全网讲php位运算符最详细的一个老师了。链接:https://pan.baidu.com/s/14xj7er8eVSUcJ-jYXyA0GA  提取码:731m 链接:https://pan.baidu.com...

php event异常处理,php set_exception_handler无效

php event异常处理,php set_exception_handler无效

(1).今天遇到一件奇怪的事情,在event事件中是无法自定义异常处理,例如我们使用set_exception_handler来统一处理异常。例如下面的代码:<?php error_reporting(E_ALL); set_error_handler(function ($errn...