tgrego / broker
为hypedeals提供消息代理的软件包
1.0.1
2018-12-01 05:58 UTC
Requires
- illuminate/config: 5.5.*
- illuminate/support: 5.5.*
- php-amqplib/php-amqplib: ^2.8@dev
Requires (Dev)
- mockery/mockery: ^1.2
- orchestra/testbench: ~3.0
- phpunit/phpunit: 6.0
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);
});