colearn/rabbitmq

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

维护者

详细信息

github.com/hieudd92/colearn-rabbitmq

源代码

问题

安装: 52

依赖项: 1

建议者: 0

安全: 0

星星: 0

观察者: 1

分支: 0

开放问题: 0

1.0.3 2021-10-25 09:52 UTC

Requires

Requires (Dev)

MIT 87d3bc16ddbcf54248f0eabad1635c01c28d144f

  • Đàm Đức Hiệu <hieudd.woop@elcom.com.vn>

rabbitmq

This package is auto-updated.

Last update: 2024-09-25 16:55:40 UTC

README

安装

通过composer安装

composer require colearn/rabbitmq

发布包资源

php artisan vendor:publish --provider="CoLearn\RabbitMQ\RabbitMQServiceProvider"

安全

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

如何使用

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

$this->rabbit = app('rabbitmq.queue')->connection('rabbitmq');
RabbitMQ::declareRPCServer($this->rabbit, 'name_of_queue', function ($request) {
    # code...
});

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

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

####作为服务的服务器工作队列服务

$this->rabbit = app('rabbitmq.queue')->connection('rabbitmq');
RabbitMQ::declareWorkerQueueServer($this->rabbit, 'name_of_queue', function ($request) {
    RabbitMQ::declareAck($request);
});