3

嗨，我创建了一个 laravel 队列作业来发送邮件

public function handle() {
    foreach($this->emails as $value) {
            $to         = $value->email;
            $subject    = $this->data['subject'];       
            $this->data['t_firstname']    = $value->firstname;
            $this->data['t_lastname']     = $value->lastname;
            if (view()->exists('mail.requirement_to_tutor')) {
                    $view = view('mail.requirement_to_tutor',$this->data);
                    $html = $view->render();
            }
            file_put_contents('test.txt', 'test database');
            $body = $html;
            $headers  = "From: " . $this->data['from'] . "\r\nReply-To: " . $this->data['from'] . "";
            $headers .= "MIME-Version: 1.0\r\n";
            $headers .= "Content-type: text/html; charset: utf8\r\n";
            mail($to, $subject, $body, $headers);
    }
}

而且我正在从回购中推送数据

$obj = (new SendStudentRequirement($TutorsbyCity,$data));
$this->dispatch($obj);

但它不作为后台运行，该功能正在等待队列完成，请帮帮我

4

2 回答 2

5

默认情况下使用同步驱动程序。您应该将其更改为中列出的另一个驱动程序config/queue.php

在文件中查找以下行.env并调整为不同的驱动程序：

QUEUE_DRIVER=sync

Laravel - 文档 - 队列

于 2015-12-30T06:32:38.170 回答
0

您使用的是默认配置"sync"，这意味着所有队列作业将同步运行，而不是“即发即弃”的方式。要更改此默认行为，您可以按照以下步骤操作：

1.选择不同的队列连接

打开.env配置文件并使用支持的值之一添加QUEUE_DRIVER参数：“database”、“beanstalkd”、“sqs”或“redis”。在这种情况下，我们将使用数据库连接作为示例模式：QUEUE_DRIVER=database

2.编辑连接驱动

打开/config/queue.php文件并配置您的驱动程序连接，例如：

'database' => [
            'driver' => 'mongodb',
            'table' => 'jobs',
            'queue' => 'default',
            'retry_after' => 90
        ]

然后运行以下命令来创建新jobs表：

php artisan config:cache && php artisan queue:table

因此，您已经将队列作为“一劳永逸”的方式；您可以尝试查看如何jobs使用队列信息创建表。

3. 为长时间运行配置一个进程管理器

要在将来执行待处理队列，我们​​可以使用流程管理器作为主管。您可以运行以下命令为 Ubuntu 和 Debian 安装主管：sudo apt-get install supervisor

然后打开主管文件：sudo nano /etc/supervisor/supervisord.conf并在文件末尾添加如下一行：

[program:laravel-worker-QUEUE_NAME]
process_name=%(program_name)s_%(process_num)02d
command= php /var/www/MY_PROJECT/artisan queue:work --queue=QUEUE_NAME --sleep=15
autostart=true
autorestart=true
user=root
numprocs=1
redirect_stderr=true
stdout_logfile=/var/www/MY_PROJECT/storage/logs/worker.log

替换：QUEUE_NAME和的值MY_PROJECT。请注意，该--sleep参数是验证数据库中新队列的时间（秒）。您可以在官方文档中查看配置文件的更多详细信息。

最后执行这些命令来启用程序：

sudo supervisorctl reread && sudo supervisorctl update

您可以在配置的日志文件中检查队列的状态：/var/www/MY_PROJECT/storage/logs/worker.log

于 2018-08-03T15:56:56.537 回答