tgrego/broker

为hypedeals提供消息代理的软件包

1.0.1 2018-12-01 05:58 UTC

This package is auto-updated.

Last update: 2024-09-29 05:21:28 UTC


README

使用AMQP库的消息代理,适用于HypeDeals。

安装

要执行软件包安装,请在终端中输入以下语法。

php composer require trego/broker

然后将trego/broker/amqp.php中的数组复制到主目录下的config目录中。根据您的配置调整配置文件。

安装后

安装完成后,在bootstrap/app.php文件的注册服务提供程序部分添加以下语法。

$app->register(Trego\Broker\BrokerServiceProvider::class)

然后在bootstrap/app.php文件中配置以下语法。

// $app->withFacades(); 

// $app->withEloquent();

$app->configure('amqp');

如何使用

完成此类安装后,您现在可以发布和消费消息。

要发布消息

use Trego\Broker\Facades\Broker;

Broker::publish('message', 'routing-key')

要消费消息

use Trego\Broker\Facades\Broker;

Broker::consume('queue-name', 'routing-key', function ($message, $consumer) {
    var_dump($message->body);
    $consumer->acknowledge($message);
});