支持Enqueue
Enqueue 是一个 MIT 许可的开源项目,它的持续开发完全得益于社区和我们客户的支持。如果您想加入他们,请考虑:
Laravel 队列
LaravelQueue 包允许以Laravel方式来使用于队列交互兼容的传输。 我想你应该已经安装并配置好了这个包,所以让我们看看你必须做什么才能使队列工作。
配置
您必须向 config/queues.php
文件添加连接器。驱动必须是 interop
。
<?php
// config/queue.php
return [
'default' => 'interop',
'connections' => [
'interop' => [
'driver' => 'interop',
'dsn' => 'amqp+rabbitmq://guest:guest@localhost:5672/%2f',
],
],
];
这是支持的传输的完整列表。
用例
与标准Laravel 队列相同。
发送消息示例:
<?php
$job = (new \App\Jobs\EnqueueTest())->onConnection('interop');
dispatch($job);
消费消息:
$ php artisan queue:work interop
Amqp交互
<?php
// config/queue.php
return [
// 取消注释以将其设置为默认值
// 'default' => env('QUEUE_DRIVER', 'interop'),
'connections' => [
'interop' => [
'driver' => 'interop',
// 连接到localhost
'dsn' => 'amqp:', //
// 可以是“rabbitmq_dlx”、“rabbitmq_delay_plugin”、DelayStrategy接口实例或null。
// 'delay_strategy' => 'rabbitmq_dlx'
],
],
];