duanju_track_hapi/process/Task.php

<?php
namespace process;

use Workerman\Crontab\Crontab;
use support\Log;
use App\services\TrackService;
use Webman\RedisQueue\Redis;

class Task
{
    public function onWorkerStart()
    {
        // 每一秒执行
        new Crontab('*/1 * * * * *', function(){
            //TrackService::cronDeal();
            //echo date('Y-m-d H:i:s')."\n";
             // 队列名
            $queue = 'tiktok_track';
            // 投递消息
            Redis::send($queue, []);
            // usleep(300000);
            // Redis::send($queue, []);
            // usleep(300000);
            // Redis::send($queue, []);
        });
        
    }
}