README

此包提供了一种简单的方式来发布和消费来自 RabbitMQ 的消息。

安装

composer require alterindonesia/rabbit-mq

配置

将以下内容添加到您的 .env 文件中

RABBITMQ_HOST=
RABBITMQ_PORT=
RABBITMQ_USER=
RABBITMQ_PASSWORD=
RABBITMQ_VHOST=
RABBITMQ_EXCHANGE=

使用方法

测试发布者

$rabbit = new Alterindonesia\RabbitMQ\Services\RabbitMQPublisherService();
$rabbit->test();

它将发送到交换名称 test，路由键 test 和消息 test

发布消息

$rabbit = new Alterindonesia\RabbitMQ\Services\RabbitMQPublisherService();
$rabbit->publish(
    ['test'=>'test'], 
    'exchange_name',
    'routing_key'
);

消费消息

$listener = new Alterindonesia\RabbitMQ\Services\RabbitMQConsumerService();
$listener->listen('queue_name');

或使用命令

php artisan alter:mq-consume {--routing=} {--exchange=} {--queue=}

许可证

此包是开源软件，根据MIT 许可证授权。

alterindonesia / rabbit-mq

维护者

详细信息

README

安装

配置

使用方法

测试发布者

发布消息

消费消息

许可证