farshidrezaei/larabbitmq

Laravel RabbitMq 集成。

维护者

详细信息

github.com/farshidrezaei/larabbitmq

源代码

问题

安装: 19

依赖项: 0

建议者: 0

安全性: 0

星标: 2

关注者: 2

分支: 1

开放问题: 0

1.0.6 2022-05-07 06:56 UTC

Requires

MIT d341026887b8249500f24c07cd06b91b6af8cf3f

This package is auto-updated.

Last update: 2024-09-07 11:58:51 UTC

README

安装

composer

composer require farshidrezaei/larabbitmq

Larabbitmq 环境

将以下配置设置到 .env 文件中，并使用您安装的 rabbitmq 凭据

LARABBITMQ_RABBIT_HOST=
LARABBITMQ_RABBIT_PORT=
LARABBITMQ_RABBIT_USERNAME=
LARABBITMQ_RABBIT_PASSWORD=

配置

调用以下命令发布配置文件

php artisan vendor:publish --provider="FarshidRezaei\Larabbitmq\Providers\LarabbitmqServiceProvider" --tag="config"

用法

发布

您可以使用 Larabbitmq Facade 容易地发布到指定的队列。

use FarshidRezaei\Larabbitmq\Facades\Larabbitmq;

Larabbitmq::publish( 'default_queue','default_exchange','simple_text_message' );

消费

对于消费队列，您应该在 config/larabbitmq.php 中创建消费处理器类，并将其指定给队列。

调用以下命令创建新的消费处理器类

php artisan larabbitmq:make-consume-handler ExampleConsumeHandler

然后，ExampleConsumeHandler.php 类将在 app/LarabbitmqConsumeHandlers 中创建。您必须将其添加到 config/larabbitmq.php 中，如下所示

// config/larabbitmq.php
  
  // ...
  
  'consume-handlers' => [
    'default_queue'=>App\LarabbitmqConsumeHandlers\ExampleConsumeHandler::class
  ]
    
  // ...

现在，您可以调用以下命令来消费指定的队列

php artisan larabbitmq:consume --queue=default_queue

许可证

MIT 许可证 (MIT)。有关更多信息，请参阅 许可证文件。