zhizhaoping/laravel-rabbitmq-mq

一个基于rabbitmq的fanout exchange实现的laravel的消息队列(pub/sub)

dev-master 2020-10-23 08:27 UTC

Requires

• php: >=5.6.0
• php-amqplib/php-amqplib: >=2.9

MIT

• zhizhaoping

README

一个基于rabbitmq的fanout exchange实现的laravel的消息队列(pub/sub)

发布配置

php artisan vendor:publish --provider="Rabbitmq\RabbitMqProvider"

消费实现

参考实践 Exchange Per Event

配置：config/rabbitmq.php

// eventName => subscribe
'subscribes' => [
    'user.created' => \Rabbitmq\Subscribe\UserCreated::class,
]

eventName本质就是一个fanout的exchange

监听事件

php artisan rabbitmq:consume 

发布消息

$created_user = [
    'id' => 100,
    'name' => 'zhangsan'
];

\Rabbitmq\Facades\Publisher::pushlish('user.created', $created_user)