xiaoshan/application/job/DemoJob.php

<?php
namespace app\job;

use app\utils\LogUtil;
use think\queue\Job;

/**
 * 任务队列 示例
 * Class DemoJob
 * @package app\task
 * Author: Panda joeyoung0314@qq.com
 * Gitee: https://gitee.com/xertao
 */
class DemoJob{
    const LOG_MODULE = 'DemoJob';
    public function __construct()
    {
        //日志统一写入
        register_shutdown_function([new LogUtil, 'close']);
        LogUtil::getInstance('Job/'); //设置日志存入通道
    }

    /**
     * fire是消息队列默认调用的方法
     * @param Job $job 当前的任务对象
     * @param array|mixed $data 发布任务时自定义的数据
     */
    public function fire(Job $job,$data)
    {
        LogUtil::info('任务队列', self::LOG_MODULE,__FUNCTION__, $data);
        $job->delete();//任务执行成功后删除
    }
}