教你在tp6中实现毫秒级定时任务功能

导入 workerman

1. composer require workerman/workerman

创建 Timer 命令

1. php think make:command Timer

实现 Timer

1. class Timer extends Command
2. {
3.     /**
4.      * @var int
5.      */
6.     protected $timer;
8.     /**
9.      * @var int|float
10.      */
11.     protected $interval = 2;
13.     protected function configure()
14.     {
15.         // 指令配置
16.         $this->setName('timer')
17.             ->addArgument('status', Argument::REQUIRED, 'start/stop/reload/status/connections')
18.             ->addOption('d', null, Option::VALUE_NONE, 'daemon（守护进程）方式启动')
19.             ->addOption('i', null, Option::VALUE_OPTIONAL, '多长时间执行一次')
20.             ->setDescription('开启/关闭/重启 定时任务');
21.     }
23.     protected function init(Input $input, Output $output)
24.     {
25.         global $argv;
27.         if ($input->hasOption('i'))
28.             $this->interval = floatval($input->getOption('i'));
30.         $argv[1] = $input->getArgument('status') ?: 'start';
31.         if ($input->hasOption('d')) {
32.             $argv[2] = '-d';
33.         } else {
34.             unset($argv[2]);
35.         }
36.     }
38.     protected function execute(Input $input, Output $output)
39.     {
40.         $this->init($input, $output);
42.         //创建定时器任务
43.         $task = new Worker();
44.         $task->count = 1;
46.         $task->onWorkerStart = [$this, 'start'];
47.         $task->runAll();
48.     }
50.     public function stop()
51.     {
52.         //手动暂停定时器
53.         \Workerman\Lib\Timer::del($this->timer);
54.     }
56.     public function start()
57.     {
58.         $last = time();
59.         $task = [6 => $last, 10 => $last, 30 => $last, 60 => $last, 180 => $last, 300 => $last];
60.         
61.         $this->timer = \Workerman\Lib\Timer::add($this->interval, function () use (&$task) {
62.             //每隔2秒执行一次
63.             try {
64.                 $now = time();
65.                 foreach ($task as $sec => $time) {
66.                     if ($now - $time >= $sec) {
67.                         //每隔$sec秒执行一次
68.                         $task[$sec] = $now;
69.                     }
70.                 }
71.             } catch (\Throwable $e) {
72.             }
73.         });
74.     }
77. }

Timer 参数说明

1. Usage:
2.   timer [options] [--] <status>
4. Arguments:
5.   status                start/stop/reload/status/connections
7. Options:
8.       --d               daemon（守护进程）方式启动
9.       --i[=I]           多长时间执行一次,可以精确到0.001

注册 Timer 命令
修改 console.php 文件

1. 'commands' => [
2.         //定时任务命令
3.         'timer'=>\app\command\Timer::class,
4.     ],

启动定时器

1. php think timer start

关闭定时器

1. php think timer stop