return [
    'default'     => 'redis', // 默认驱动
    'connections' => [
        'redis' => [
            'type'       => 'redis',
            'host'       => '127.0.0.1', // Redis主机
            'port'       => 6379,        // 端口
            'password'   => '',          // 密码（如有）
            'select'     => 0,           // 数据库索引
            'timeout'    => 0,           // 超时时间
            'persistent' => false,       // 是否长连接
        ],
    ],
];

<?php
namespace app\utils;

use PHPMailer\PHPMailer\PHPMailer;
use PHPMailer\PHPMailer\Exception;
use think\facade\Config;
use think\facade\Log;

class Emailer
{
    private $emailer;

    /**
     * 初始化邮件配置
     * @throws Exception
     */
    function __construct()
    {
        $this->emailer = new PHPMailer(true); 
        $this->emailer->isSMTP();                                     
        $this->emailer->Host = Config::get("email.host");             
        $this->emailer->SMTPAuth = true;                              
        $this->emailer->Username = Config::get("email.send_user");     
        $this->emailer->Password = Config::get("email.password");      
        $this->emailer->SMTPSecure = Config::get("email.encryption");  
        $this->emailer->Port = Config::get("email.port");              
        $this->emailer->CharSet = 'UTF-8';                            
        $this->emailer->SMTPAutoTLS = true;                            
    }

    /**
     * 发送邮件
     * @param string $reciver 收件人邮箱
     * @param string $subject 邮件主题
     * @param string $content 邮件内容
     * @param bool $isHTML 是否为HTML内容
     * @return array 发送结果
     */
    function send(
        string $reciver = "2022471677@qq.com",
        string $subject = "",
        string $content = "",
        bool $isHTML = false
    ): array {
        try {
            // 参数校验
            if (empty($subject)) throw new \InvalidArgumentException("邮件主题不能为空");
            if (empty($content)) throw new \InvalidArgumentException("邮件内容不能为空");
            if (!filter_var($reciver, FILTER_VALIDATE_EMAIL)) {
                throw new \InvalidArgumentException("收件人邮箱格式不正确: {$reciver}");
            }

            // 清理历史收件人
            $this->emailer->clearAddresses();

            // 设置发件人
            $sendUser = Config::get("email.send_user");
            $this->emailer->setFrom($sendUser, Config::get("email.send_name", "28.7Blog"));

            // 设置收件人及内容
            $this->emailer->addAddress($reciver);
            $this->emailer->isHTML($isHTML);
            $this->emailer->Subject = $subject;
            $this->emailer->Body = $content;
            if ($isHTML) {
                $this->emailer->AltBody = strip_tags($content); // 纯文本替代内容
            }

            // 执行发送
            $this->emailer->send();
            Log::channel("queuejob")->info("邮件发送成功，收件人: {$reciver}，主题: {$subject}");
            return [
                'success' => true,
                'message' => "邮件已成功发送至: {$reciver}"
            ];

        } catch (Exception $e) {
            $errorMsg = "邮件发送失败: " . $e->getMessage();
            Log::channel("queuejob")->error("{$errorMsg}，收件人: {$reciver}，主题: {$subject}");
            return ['success' => false, 'message' => $errorMsg];
        } catch (\InvalidArgumentException $e) {
            $errorMsg = "参数错误: " . $e->getMessage();
            Log::channel("queuejob")->error($errorMsg);
            return ['success' => false, 'message' => $errorMsg];
        } catch (\Exception $e) {
            $errorMsg = "未知错误: " . $e->getMessage();
            Log::channel("queuejob")->error($errorMsg);
            return ['success' => false, 'message' => $errorMsg];
        }
    }
}

<?php
namespace app\job;

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

class SendEmailJob
{
    /**
     * 执行队列任务
     * @param Job $job 任务对象
     * @param array $data 任务参数（收件人、主题、内容等）
     */
    public function fire(Job $job, array $data)
    {
        try {
            // 解析任务参数
            $reciver = $data['reciver'] ?? '';
            $subject = $data['subject'] ?? '';
            $content = $data['content'] ?? '';
            $isHTML = $data['isHTML'] ?? false;

            // 调用邮件工具发送
            $emailer = new Emailer();
            $result = $emailer->send($reciver, $subject, $content, $isHTML);

            // 处理任务结果
            if ($result['success']) {
                $job->delete(); // 成功：删除任务
                Log::channel("queuejob")->info("邮件任务执行成功，收件人: {$reciver}");
            } else {
                // 失败：重试（最多3次）
                if ($job->attempts() < 3) {
                    $job->release(3); // 3秒后重试
                } else {
                    $job->delete();
                    Log::channel("queuejob")->error("邮件任务重试超限，收件人: {$reciver}，原因: {$result['message']}");
                }
            }
        } catch (\Exception $e) {
            Log::channel("queuejob")->error("邮件任务异常: {$e->getMessage()}");
            $job->delete();
        }
    }
}

<?php
namespace app\service;

use think\facade\Queue;
use app\job\SendEmailJob;

class UserService
{
    public function register(array $userData): array
    {
        $jobData = [
            'reciver' => $userData['email'], // 收件人邮箱（需确保已解码）
            'subject' => "欢迎注册",
            'content' => "亲爱的用户，感谢注册我们的平台！",
            'isHTML' => false
        ];
        // 推送参数：任务类、任务数据、队列名称（可选）
        Queue::push(SendEmailJob::class, $jobData, 'email');

        return [
            'success' => true,
            'message' => "注册成功，欢迎邮件将尽快发送"
        ];
    }
}