huahuibao/common/config/rabbitmq.php

<?php
/**
 * rabbitmq的配置
 */

$rabbitmq = [
    /*'on before_consume' => function ($event) {
        if (isset(\Yii::$app->db)) {
            $db = \Yii::$app->db;
            if ($db->getIsActive()) {
                $db->close();
            }
            $db->open();
        }
    },
    'logger' => [
        'enable' => true,
        'category' => 'amqp',
        'print_console' => true,
    ],*/
    'class' => 'mikemadisonweb\rabbitmq\Configuration',
    'connections' => [
        [
            'host' => '127.0.0.1',
            'port' => '5672',
            'user' => 'guest',
            'password' => 'guest',
            'vhost' => '/', //虚拟主机
        ]
    ],

    /**
     * 交换器
     * 交换类型(type)：direct、topic、headers、fanout
     * 列出交换器: rabbitmqctl list_exchanges
     */
    'exchanges' => [
        [
            'name' => 'ex_1',
            'type' => 'direct' // direct
        ],
        [
            'name' => 'topic_ex_1',
            'type' => 'topic', // topic
            'passive' => false,
            'durable' => true,
            'auto_delete' => false,
            'internal' => false,
            'nowait' => false,
            'arguments' => null,
            'ticket' => null,
            'declare' => true,
        ],
    ],

    /**
     * 队列
     */
    'queues' => [
        [
            'name' => 'queue_1',
            'passive' => false,
        ],
        [
            'name' => 'queue_2',
            'passive' => false,
            'durable' => true,
            'exclusive' => false,
            'auto_delete' => false,
            'nowait' => false,
            'arguments' => null,
            'ticket' => null,
            'declare' => true,
        ],
        [
            'name' => 'queue_3',
            'passive' => false,
            'durable' => true,
            'exclusive' => false,
            'auto_delete' => false,
            'nowait' => false,
            'arguments' => null,
            'ticket' => null,
            'declare' => true,
        ],
    ],

    /**
     * 交换和队列之间的关系称为绑定
     * 列出绑定: rabbitmqctl list_bindings
     */
    'bindings' => [
        [
            'queue' => 'queue_1',
            'exchange' => 'ex_1',
            'routing_keys' => ['route_1'],
        ],
        [
            'queue' => 'queue_2',
            'exchange' => 'topic_ex_1',
            'routing_keys' => ['route_1', 'route_prefix.*', '*.route_suffix', '*.*.last', '*'],
        ],
        [
            'queue' => 'queue_3',
            'exchange' => 'topic_ex_1',
            'routing_keys' => ['route_3', 'route3_prefix.*', '*.route_suffix', '*.*.last'],
        ],
    ],

    /**
     * 生产者
     */
    'producers' => [
        [
            'name' => 'producer_1',
        ],
        [
            'name' => 'producer_2',
            'connection' => 'default',
            'safe' => true,
            'content_type' => 'text/plain',
            'delivery_mode' => 2,
            'serializer' => 'serialize',
        ]
    ],

    /**
     * 消费者
     */
    'consumers' => [
        [
            'name' => 'consumer_1',
            'callbacks' => [
                'queue_1' => '\common\components\rabbitmq\consumer\ImportDataConsumer', //设定队列的数据给谁转回调而以，只是个配置
            ],
        ],
        [
            'name' => 'consumer_2',
            'connection' => 'default',
            'callbacks' => [
                'queue_2' => '\common\components\rabbitmq\consumer\PrintMsgConsumer',
            ],
            'qos' => [
                'prefetch_size' => 0,
                'prefetch_count' => 0,
                'global' => false,
            ],
            'idle_timeout' => 0,
            'idle_timeout_exit_code' => null,
            'proceed_on_exception' => false,
            'deserializer' => 'unserialize',
        ],
    ],
];

return $rabbitmq;