RabbitMQ 在 Laravel 中的应用指南

后端

2023-09-16 09:03:28

引言

消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。

常用的中间件及对比介绍详情可见传送门

消息中间件场景

异步处理
- 将耗时较长的任务放入消息队列中，由消息队列进行异步处理，从而提高系统的吞吐量。
应用解耦
- 通过消息队列进行通信，解耦了应用之间的依赖关系，提高了系统的稳定性和可维护性。
流量削峰
- 当系统遇到突发流量时，将部分请求放入消息队列中，由消息队列进行处理，从而避免系统崩溃。

RabbitMQ 简介

RabbitMQ 是一个开源的消息队列中间件，实现 AMQP 协议，支持多种语言和客户端。RabbitMQ 具有以下特点：

高性能：RabbitMQ 能够处理大量的消息，并且具有很低的延迟。
可靠性：RabbitMQ 采用持久化存储，确保消息不会丢失。
可扩展性：RabbitMQ 可以通过增加节点来实现水平扩展。
高可用性：RabbitMQ 支持集群模式，确保消息队列的高可用性。

RabbitMQ 在 Laravel 中的集成

要将 RabbitMQ 集成到 Laravel 中，需要安装以下库：

composer require enqueue/amqp-ext

安装完成后，在 .env 文件中添加以下配置：

QUEUE_CONNECTION=amqp
QUEUE_HOST=localhost
QUEUE_PORT=5672
QUEUE_USERNAME=guest
QUEUE_PASSWORD=guest
QUEUE_VHOST=/

接下来，需要在 config/queue.php 文件中配置队列连接：

'connections' => [
    'amqp' => [
        'driver' => 'amqp',
        'host' => env('QUEUE_HOST'),
        'port' => env('QUEUE_PORT'),
        'username' => env('QUEUE_USERNAME'),
        'password' => env('QUEUE_PASSWORD'),
        'vhost' => env('QUEUE_VHOST'),
    ],
],

最后，需要在 config/app.php 文件中将 Illuminate\Queue\QueueManager 替换为 Enqueue\AmqpExt\QueueManager：

'queue' => [
    'default' => 'amqp',
    'connections' => [
        'amqp' => [
            'driver' => 'amqp',
            'host' => env('QUEUE_HOST'),
            'port' => env('QUEUE_PORT'),
            'username' => env('QUEUE_USERNAME'),
            'password' => env('QUEUE_PASSWORD'),
            'vhost' => env('QUEUE_VHOST'),
        ],
    ],
],

现在，就可以使用 php artisan queue:work 命令启动消息队列监听器，并使用 php artisan queue:push 命令将任务推送到队列中。

使用示例

以下是一个使用 RabbitMQ 在 Laravel 中发送邮件的示例：

use Illuminate\Support\Facades\Mail;
use Enqueue\AmqpExt\AmqpConnectionFactory;
use Enqueue\AmqpExt\Queue\AmqpQueue;

// 创建连接工厂
$connectionFactory = new AmqpConnectionFactory([
    'host' => env('QUEUE_HOST'),
    'port' => env('QUEUE_PORT'),
    'username' => env('QUEUE_USERNAME'),
    'password' => env('QUEUE_PASSWORD'),
    'vhost' => env('QUEUE_VHOST'),
]);

// 创建连接
$connection = $connectionFactory->createContext();

// 创建队列
$queue = new AmqpQueue('emails');

// 发送邮件
Mail::send('emails.welcome', ['name' => 'John Doe'], function ($message) use ($connection, $queue) {
    // 将邮件推送到队列
    $connection->createProducer()->send($queue, $message->getBody());
});

// 关闭连接
$connection->close();