phuongna/rabbitmq

按照指南 https://rabbitmq.cn/ 创建一个易于使用的库。适用于Laravel!

1.1.9 2022-05-24 04:18 UTC

This package is auto-updated.

Last update: 2024-09-24 09:41:26 UTC


README

安装

通过composer安装

composer require phuongna/rabbitmq

发布包资源

php artisan vendor:publish --provider="phuongna\rabbitmq\ServiceProvider"

安全

如果您发现任何与安全相关的问题,请通过电子邮件而不是使用问题跟踪器。

如何使用

####作为服务的服务器

$this->rabbit = app('rabbitmq.queue')->connection('rabbitmq');
RabbitMQQueue::declareRPCServer($this->rabbit, xxx, function ($request) {
    $this->rabbit->replyTo($request, dosomething($request));
});

####作为服务的客户端

$this->rabbit = app('rabbitmq.queue')->connection('rabbitmq');
$stringInput = json_encode(array);
RabbitMQQueue::declareRPCClient($this->rabbit, xxx, $stringInput);