概述
这个扩展包是针对阿里云消息队列AMQP（RabbitMQ）。通过简单的方法调用发送消费消息和接收消费消息。支持所有PHP的项目，本文针对Laravel作详细说明
安装
composer require jyil/aliwaremq
发布配置文件
php artisan vendor:publish --provider="Jyil\AliwareMQ\Laravel\Providers\LaravelServiceProvider" --force
注意：Laravel5.5- 自行添加providers
Jyil\AliwareMQ\Laravel\Providers\LaravelServiceProvider::class
配置
| Key | 描述 |
|---|---|
| host | 接入点 |
| port | 端口 |
| virtualHost | 资源隔离 |
| accessKey | 阿里云的accessKey |
| accessSecret | 阿里云的accessSecret |
| resourceOwnerId | 主账号id |
生产者
app('aliwaremq')->send('queue', 'Hello World');
消费者
app('aliwaremq')->receive('queue');
属性配置
app('aliwaremq')->passive = false;
app('aliwaremq')->durable = true;
app('aliwaremq')->exclusive = false;
app('aliwaremq')->autoDelete = false;
app('aliwaremq')->noLocal = false;
app('aliwaremq')->noAck = false;
app('aliwaremq')->nowait = false;
匿名函数
app('aliwaremq')->receive($queue, '', function ($msgBody) {
echo 'body---' . $msgBody;
});
- 使用本扩展包前请对
RabbitMQ有一定的了解