主要原理是通过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
<?php //对比$this和self /* * $this更倾向于对象本身 * */ class Par{ public  ...
<!doctype html> <html> <head> <meta charset="utf-8"> <title>demo</title> </head> <bod...
首先下载wkhtmltox-0.12.4_linux-generic-amd64.tar.xz (不要下载RPM包,依赖太多,需要x-server支持),并解压,执行测试运行正常tar wkhtmltox-0.12.4_linux-generic-amd64.tar.xzcd...
//$ak开发密钥,$cityname城市名称(支持省县乡详细地址) public function getposition($ak,$cityname){ $callback=array('lng'=>0,'l...
php多进程应用场景主要是非web端,fpm下是不支持多进程的,非类linux操作系统都不支持,请在cli模式使用.可以使用多进程做任务分发,批量计算,批量文件处理,批量爬虫,网络运维等等。下面看一份简单的入门demo//创建子进程 $pid=pcntl_fork(); //返回-1,创建失败,不...
(1)swoole启动的主进程是master进程负责全局管理,然后master进程会再fork一个manager进程。(2)manager进程开始统一管理进程创建回收管理。(3)manager进程根据设置的worker_num和task_worker_num来创建work进程和task进程因此启动s...