PHP에서 첨부 파일이 포함된 이메일을 보내기 위해 대기열을 사용하는 방법은 무엇입니까?

class MailSender { public function send($to, $subject, $message, $attachments = []) { // 创建邮件任务 $job = [ 'to' => $to, 'subject' => $subject, 'message' => $message, 'attachments' => $attachments ]; // 将任务放入队列 $this->putJobToQueue($job); } private function putJobToQueue($job) { // 连接Beanstalkd服务器 $pheanstalk = new PheanstalkPheanstalk('127.0.0.1'); // 将任务数据转换为JSON字符串 $jobData = json_encode($job); // 将任务放入队列 $pheanstalk->useTube('mail')->put($jobData); } }

require 'vendor/autoload.php'; use PheanstalkPheanstalk; // 连接Beanstalkd服务器 $pheanstalk = new Pheanstalk('127.0.0.1'); // 设置监听的队列tube $pheanstalk->watch('mail'); while (true) { // 获取队列中的任务 $job = $pheanstalk->reserve(); // 从任务数据中解析出邮件信息 $jobData = json_decode($job->getData(), true); $to = $jobData['to']; $subject = $jobData['subject']; $message = $jobData['message']; $attachments = $jobData['attachments']; // 发送邮件 $mail = new PHPMailerPHPMailerPHPMailer(); $mail->isSMTP(); // 配置SMTP服务器等相关信息 // ... $mail->Subject = $subject; $mail->Body = $message; $mail->addAddress($to); foreach ($attachments as $attachment) { $mail->addAttachment($attachment['path'], $attachment['name']); } if ($mail->send()) { // 邮件发送成功，删除队列中的任务 $pheanstalk->delete($job); } else { // 邮件发送失败，将任务放回队列，稍后重试 $pheanstalk->release($job, 10); } }

$mailSender = new MailSender(); // 发送带附件的邮件 $mailSender->send('to@example.com', '测试邮件', '这是一封带附件的测试邮件', [ [ 'path' => '/path/to/attachment1.pdf', 'name' => 'attachment1.pdf' ], [ 'path' => '/path/to/attachment2.jpg', 'name' => 'attachment2.jpg' ] ]);