About amqp-laravel

基于 php-amqplib / php-amqplib 针对 Laravel && Lumen 框架封装 Rabbitmq 的调用方法，方便业务开发.

Setup

本地先安装 composer, 执行以下命令加载库:

composer require dojiland/amqp-laravel

创建配置文件，执行生成 config/amqp.php 配置文件:

php artisan amqp:init

.env 添加 AMQP 配置项:

AMQP_HOST=localhost
AMQP_PORT=5672
AMQP_USER=guest
AMQP_PASSWORD=guest

Laravel

Laravel 版本 >= 5.5, 会自动 package-discover，无需操作.

less than 5.5 add this to the providers array in config/app.php

Dojiland\Amqp\AmqpServiceProvider::class

Lumen

add this in bootstrap/app.php

$app->register(Dojiland\Amqp\AmqpServiceProvider::class);

Usage

PS: 目前只限制使用 Fanout Exchange, 默认配置使用消息持久化和ACK.

Publish

<?php
    ...
    app('amqp')->publish(string $exchange, array $params);
    ...

Subscribe

创建指定订阅者，执行命令

php artisan make:amqp ExampleSubscribe

创建 app\MessageQueue\ExampleSubscribe.php 文件(若MessageQueue文件夹不存在会默认生成).

    /**
     * 订阅的exchange.
     * @var string
     */
    protected $exchange = '';

    /**
     * 订阅的queue.
     *
     * @var string
     */
    protected $queue = '';

    /**
     * 监听消息回调处理
     *
     * @return void
     */
    public function callback(AMQPMessage $msg)
    {
        echo $msg->body;
    }

填写指定的 exchange 和 queue, 并在 callback 里添加消费逻辑.

amqp.php 添加订阅对象配置项:

    /*
    |--------------------------------------------------------------------------
    | 订阅消费类列表
    |--------------------------------------------------------------------------
    |
     */
    'subscribes'        =>  [
        \App\MessageQueue\ExampleSubscribe::class,
    ]

执行命令 php artisan amqp, 启动消费进程.