? ??????? ???? ?? ??? ??? ?? ??? ???? ????. ?? ???? ???? ????? ???? ?? ??? ?? ??? ?? ?? ??? ???. ThinkPHP 6? ??? ??? ?? ? ??? ?? ??? ?????. ? ????? ??? ??? ??? ?? ThinkPHP 6? ???? ??? ?????.

1. ??? ??? ?? ? ??

1. Redis ??

Redis? ??????, ?? ? ??? ???? ???? ?? ?? ???? ??? ?? ???? ?????. ? ???? ????? ?? ??? Redis? ?? ? ???? ???? ???. Redis? ????? ?? ??? ?? ??? ????? ?????.

2. ??? ?? ??

ThinkPHP ?? ?? config/queue.php?? ??? ??? ?????. ??? ??? ????.

return [
    // 默認(rèn)驅(qū)動(dòng)
    'default' => env('queue.driver', 'redis'),

    // 隊(duì)列連接參數(shù)
    'connections' => [
        'sync' => [
            'driver' => 'sync',
        ],
        'redis' => [
            'driver' => 'redis',
            'connection' => 'default',
            'queue' => env('queue.redis.queue', 'default'),
            'retry_after' => 90,
            'block_for' => null,
        ],
    ],

    // 監(jiān)聽(tīng)的任務(wù)類(lèi)命名空間
    'queue_class' => [
        // 'AppJobs'
    ],
];

? ? ???? redis? ???? ?? ??? ???????. ?? ??, ?? ????, ??? ??? ?? ?? ???? Redis ????? ?? ????? ???? ?????. queue_class? ??? ???? ???? ??????? ?????? ? ?????.

3. ??? ??? ??

????? ??? ???? ???? ???? ?? ??? ??? ??? ??? ? ????. ?? ??? ????:

php think queue:listen

2. ???? ???? ??? ???

1. ??? ??? ?? ??

app/job ????? ??? ??? ?? ???? ??? ?? ??? ?????. ?? ?? ???? ??? ?? ??? SnedMailJob? ??? ????.

<?php
namespace appjob;

use appcommonMail;
use thinkqueueJob;

class SendMailJob
{
    /**
     * Send the email message.
     *
     * @param  Job  $job
     * @param  array  $data email message data
     */
    public function fire(Job $job, $data)
    {
        try {
            // 發(fā)送郵件
            Mail::send($data['to'], $data['subject'], $data['content']);

            // 執(zhí)行任務(wù)成功，刪除任務(wù)
            $job->delete();
        } catch (Exception $e) {
            // 執(zhí)行任務(wù)失敗，重新放入任務(wù)隊(duì)列中
            // 系統(tǒng)會(huì)自動(dòng)新建一個(gè)可重試任務(wù)并放入隊(duì)列，該任務(wù)結(jié)束后重新嘗試執(zhí)行當(dāng)前任務(wù)
            $job->release(); // 或者 $job->failed();
        }
    }
}

2. ???? ??? ?????

???? ??? ?? ?? ?? ??? ?? ??? ???? ?????.

use thinkacadeQueue;

// 添加一條SendMailJob任務(wù)到隊(duì)列中
Queue::push(new SendMailJob($to, $subject, $content));

?? $ to, $subject, $content? ???? ???, ?? ? ?????.

3. ??? ???? ??? ?????

??? ???? ??? ? ??? ???? ????? ??? ?????. ????? ???? ??? ????? ???? ?????. ??? ??? ? ??? ???? ??? ????? ????? ?? ?? ??(.env ???? ?? ??)? ??? ??? ??? ?? ???? ?????.

3. ??

? ????? ??? ??? ?? ? ??, ?? ?? ?? ??, ???? ?? ?? ? ??? ??? ?? ??? ???? ?? ??? ??? ThinkPHP6? ???? ??? ?????. ?? ???? ???? ???????? ?? ??? ???? ??? ???? ???? ? ????.

? ??? ?? ??? ??? ThinkPHP6? ???? ??? ??????? ?? ?????. ??? ??? PHP ??? ????? ?? ?? ??? ?????!