duanju_track_hapi/app/queue/redis/TiktokTrack.php

<?php

namespace app\queue\redis;

use Webman\RedisQueue\Consumer;
use App\services\TrackService;
use support\facade\Logger;

class TiktokTrack implements Consumer
{
    // 要消费的队列名
    public $queue = 'tiktok_track';

    // 连接名，对应 plugin/webman/redis-queue/redis.php 里的连接`
    public $connection = 'default';

    // 消费
    public function consume($data)
    {
        //Logger::app(time());
        TrackService::cronDeal();
    }
}