huahuibao/console/controllers/RabbitmqTestController.php

<?php


namespace console\controllers;

use yii\console\Controller;

class RabbitmqTestController extends Controller
{
    /**
     * @param $producerName 生产者名称 （producer.name） -- 从 config/rabbitmq.php 找
     * @param $exchangeName 交换器名称 （exchanges.name）
     * @param $routingKey 绑定路由键（bindings.routing_keys）
     */
    public function actionPublish($producerName = '', $exchangeName = '', $routingKey = '')
    {
        if(empty($producerName)){
            $producerName = 'producer_1';
        }
        if(empty($exchangeName)){
            $exchangeName = 'ex1';
        }
        if(empty($routingKey)){
            $routingKey = 'route1';
        }

        $producer = \Yii::$app->rabbitmq->getProducer($producerName);
        $data = ['id' => 123, 'status' => 200, ['producer'=>$producerName, 'exchange'=>$exchangeName, 'routingKey'=>$routingKey]];
        $msg = serialize($data);
        $producer->publish($msg, $exchangeName, $routingKey);
    }


}