laravel能不能同时使用两个队列驱动

Posted 2023-04-26

参考技术A queue配置
首先说明一下我之前的项目中如何使用queue的。
我们现在的项目都是用的symfony，老一点的项目用的symfony1poser/vendor/bin 加入到环境变量中。
source ~/.bash_profile 就可以直接在命令行中使用laravel了。试一下。
laravel -V 能够看到下面的，就代表成功了。
Laravel Installer version 1.2.1 2、创建项目。
laravel new guagua 3、配置redis和queue。
4、创建controller，
php artisan make:controller DefaultController 在controller的action中push100个queue的任务。
for($i = 0; $i < 100; $i ++) Queue::push(new SendEmail("ssss".$i)); 5、创建queue的Command
php artisan make:command SendEmail --queued 修改app/Commands/SendEmail.php，添加一个私有变量。
protected $msg; 同时修改构造函数。
public function __construct($msg) $this->msg = $msg; 再修改的handle方法
public function handle() sleep(4); echo $this->msg."\t".date("Y-m-d H:i:s")."\n"; $this->delete(); 6、修改routes
Route::get('/', [ 'as' => 'index', 'uses' => 'DefaultController@index' ]); 7、监听queue
php artisan queue:listen 为了验证多任务处理，我们同时开三个窗口运行同样的命令。
8、用laravel内建的server启动服务
php artisan serve --port 8080 打开浏览器，访问localhost:8080/页面。当然也可以用nginx，apache之类的。但是需要各种配置，还是内建的使用方便。
在控制台就能看到各个queue执行的情况了，如下图。可以看到100个任务被三个work平分了。

到此，基本达到了我想要的效果。验证了laravel可以简单实现queue，并且可以多任务处理。
make command生成的代码中use App\Commands\Command ，但是运行时提示没有这个文件。 解决办法，修改为 use Illuminate\Console\Command; 不知道为什么会出现这个低级问题，难道是我mac系统问题，还是我的人品问题。
在controller的action中push队列的时候，没有异步执行，还是在action的脚本中执行的。 发现是配置问题，原来不仅仅要修改config中的queue.php，还要修改.evn中相关配置。 虽然问题解决了，但是还是觉得蛋疼，不能理解。还需要在学习学习laravel。
异步队列使用方法

1.配置
关于队列的定义，这里就不作介绍了。我们要使用异步队列就有两个关键：
（1）存储队列的地方
（2）执行任务的服务
打开 config/queue.php ，这是Laravel5关于队列的配置文件。首先我们可以通过 default 参数指定默认队列驱动，默认配置是 sync , 这是同步队列，我们要做异步队列首先就要改变这里。假设我们用 database 作为驱动，队列任务将会存放在数据库中，而我们后面会另外启动一个后台服务来处理队列任务，这就是异步方式了。
'default' => 'database' 修改完配置后，我们需要创建一个表来存放队列任务，Laravel5已经在自带artisan命令中内置了一个指令用来生成数据迁移，只需要两条命令即可，当然你得实现配置好数据库连接。
php artisan queue:table php artisan migrate 这样就自动在数据库中创建了 jobs 表。
2.启动队列监听服务
通过下面这条指令启动队列监听服务，它会自动处理 jobs 表中的队列任务：
php artisan queue:listen 在linux中，如果想让它在后台执行，可以这样：
nohup php artisan queue:listen & 3.添加队列任务
关于队列任务的添加，手册里说的比较详细，这里就简单举个例子吧。
首先，通过artisan创建一个队列命令：
php artisan make:command SendEmail --queued 这样会生成 app/Commands/SendEmail.php 这个类文件，这个类会被标识为队列命令，你可以在 handle 方法中写自己的业务逻辑。
在控制器中，可以简单通过 Bus::dispatch 分发任务:
Bus::dispatch(new \App\Commands\SendEmail()); 你会发现任务不会立即执行，而是被放到 jobs 表中，由队列监听服务处理。
更详细的用法建议参考 command bus 和 queue 相关的手册章节。本回答被提问者采纳

Laravel 队列（数据库驱动程序）+ Cron 作业（任务调度程序）堆叠并且在服务器崩溃后不再发送

【中文标题】Laravel 队列（数据库驱动程序）+ Cron 作业（任务调度程序）堆叠并且在服务器崩溃后不再发送

【英文标题】：Laravel Queues (Database driver) + Cron job (task scheduler) stacked and are not being sent anymore after server crashed

【发布时间】：2017-10-02 11:36:58

【问题描述】：

我已经配置了一个 laravel 队列来发送电子邮件，它曾经可以很好地立即发送电子邮件。

我还使用了laravel任务调度器并配置了queue:listen每分钟执行一次，导致服务器崩溃，因为cron作业一遍又一遍地调用queue:work循环... . 网站崩溃了。而且是客户的现场，所以问题很严重。

托管公司将我的 laravel cron 作业修改为每 5 分钟运行一次。而且由于它崩溃了，所有邮件现在都留在数据库中，并且数据库队列根本不起作用。我猜这个进程根本没有运行。

我有这些问题：

如何执行数据库中的堆叠队列记录？ 如何让数据库队列重新工作？ 如何配置 cron 作业和 laravel 计划以正常工作。

注意：我希望它与数据库驱动程序一起工作，而不是与 redis 或同步或其他东西一起工作，所以请继续关注数据库驱动程序，谢谢。

【参考方案1】：

在 Laravel 8 中（在以前的版本中不确定）

php artisan queue:work --stop-when-empty

这个命令可以毫无问题地“croned”。

【参考方案2】：

laravel 任务调度器并配置 queue:listen 每分钟执行一次

这是错误的。您应该永远不要通过 cron 调度程序调用 queue:listen，否则您会遇到发生在您身上的意外行为。

您应该将 queue:listen 配置为永远作为守护进程运行。一旦队列工作者运行 - 它将永远运行并根据需要处理作业。您可以使用Supervisor 来确保它继续运行。

【讨论】：

谢谢，这可能是我所缺少的。我明天会尝试这样做，稍后再回来。

我有一个类似的问题，queue:listen 意外执行了schedule() 函数。你能帮助我吗。 laravel cannot run scheduled command

【参考方案3】：

我认为问题在于queue:listen 命令实际上每分钟执行一次。这不应该发生。它只应在特定时刻未在侦听时执行。因此，应该检查侦听器是否正在运行。请参阅this gist，应该适合您。

要从数据库中执行所有挂起队列任务，请尝试：

php artisan queue:restart

还有：

php artisan queue:work

希望这会有所帮助。