Link Search Menu Expand Document

支持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'
        ],
    ],
];

返回首页