在 Laravel 8 框架下使用 RabbitMQ，你需要进行以下几个步骤，包括安装依赖、配置 Laravel 和创建队列任务等。下面是详细的步骤说明：

1. 安装依赖

确保你已经安装了 RabbitMQ 的 PHP 扩展和对应的库。你可以使用 PhpAmqpLib 来与 RabbitMQ 进行交互。通过 Composer 安装 php-amqplib/php-amqplib：

composer require php-amqplib/php-amqplib

2. 配置 RabbitMQ 连接

在 config 目录中，你可以创建一个 queue.php 配置文件（如果尚未存在），并添加 RabbitMQ 的连接配置。

// config/queue.php

'connections' => [

    'rabbitmq' => [
        'driver' => 'rabbitmq',
        'host' => env('RABBITMQ_HOST', 'localhost'),
        'port' => env('RABBITMQ_PORT', 5672),
        'user' => env('RABBITMQ_USER', 'guest'),
        'password' => env('RABBITMQ_PASSWORD', 'guest'),
        'queue' => env('RABBITMQ_QUEUE', 'default'),
        'options' => [
            'queue' => [
                'passive' => false,
                'durable' => true,
                'exclusive' => false,
                'auto_delete' => false,
                'nowait' => false,
                'routing_key' => '',
            ],
        ],
    ],

],

3. 添加环境变量

在 .env 文件中，添加 RabbitMQ 的相关连接信息：

RABBITMQ_HOST=localhost
RABBITMQ_PORT=5672
RABBITMQ_USER=guest
RABBITMQ_PASSWORD=guest
RABBITMQ_QUEUE=default

4. 创建队列任务

创建一个队列作业类，使用 artisan make:job 命令：

php artisan make:job MyRabbitMQJob

然后在生成的作业类中实现 ShouldQueue 接口，并编写你的业务逻辑：

// app/Jobs/MyRabbitMQJob.php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

class MyRabbitMQJob implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $data;

    public function __construct($data)
    {
        $this->data = $data;
    }

    public function handle()
    {
        $connection = new AMQPStreamConnection(
            config('queue.connections.rabbitmq.host'),
            config('queue.connections.rabbitmq.port'),
            config('queue.connections.rabbitmq.user'),
            config('queue.connections.rabbitmq.password')
        );

        $channel = $connection->channel();
        $channel->queue_declare(config('queue.connections.rabbitmq.queue'), false, true, false, false, false);

        $msg = new AMQPMessage(json_encode($this->data));
        $channel->basic_publish($msg, '', config('queue.connections.rabbitmq.queue'));

        $channel->close();
        $connection->close();
    }
}

5. 调度作业

在控制器或其他地方调度作业：

use App\Jobs\MyRabbitMQJob;

MyRabbitMQJob::dispatch($yourData);

6. 处理队列

为了处理 RabbitMQ 队列，你需要启动队列监听器。使用以下命令：

php artisan queue:work rabbitmq

7. 安装 Laravel Horizon（可选）

如果你希望更方便地管理队列，并实时监控队列任务，可以考虑安装 Laravel Horizon。

composer require laravel/horizon

按照 Laravel Horizon 的文档进行配置，以便在 web 界面上管理和监控队列。

结论

以上步骤为在 Laravel 8 框架中使用 RabbitMQ 提供了基本的指南。确保 RabbitMQ 服务已经启动并正确配置，按照上述步骤进行操作后，应该能够成功将任务推送到 RabbitMQ 并处理。

标签： 来源：

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。