主要原理是通过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
因项目需要需要统计用户无限下级计算分销佣金,计算每月分红,计算无限下级团队的业绩,需要先获得某个会员的无限下级成员。先看看数据库中的member表字段id username &...
最近在公司开发一个新的项目假设项目域名是a.com,需要接入b.com的单点登陆系统。(1).首先我们会在a.com的登陆页面用iframe引入b.com来显示登陆界面,实际上登陆验证操作都是在b.com上面(2).当b.com验证通过,会在前端ajax请求a.com的回调地址,这个回调地址目的就是...
在项目下的composer配置文件修改(PaySdk是我这里一个支付sdk的目录,包含各种各样的支付sdk,这样写的意思让composer自动把PaySdk下的所有文件自动加载):"autoload": { &...
<?php //如果支持exec函数,可以使用的方式 exec('chcp 65001'); //如果exec函数因安全问题禁用,可以使用的方式 pclose(popen('chcp 65001', 'r'));...
经常我们下载国外资源容易被墙,可以通过php脚本获取远程文件流然后输出给我们的浏览器来下载。<?php //设置下载文件的url $url = 'https://mirrors.huaweicloud.com/ubuntukylin/ubuntukylin-19....
众所周知MyISAM引擎不支持事务,但是我只是知道不支持事务,并未测试具体的表现是什么,测试代码如下:try { //开启事务 Db::startTrans(); &...