logSystem-advance/console/controllers/MqController.php

<?php
/**
 * @link http://www.yiiframework.com/
 * @copyright Copyright (c) 2008 Yii Software LLC
 * @license http://www.yiiframework.com/license/
 */

namespace console\controllers;

use yii\console\Controller;



use components\PhpClient;
use PhpAmqpLib\Message\AMQPMessage;
use PhpAmqpLib\Connection\AMQPStreamConnection;

/**
 * This command echoes the first argument that you have entered.
 *
 * This command is provided as an example for you to learn how to create console commands.
 *
 * @author Qiang Xue <qiang.xue@gmail.com>
 * @since 2.0
 */
class MqController extends Controller
{
    /**
     * This command echoes what you have entered as the message.
     * @param string $message the message to be echoed.
     */
    public function actionIndex($message = 'rabbit mq begin')
    {
        echo $message . "\n";



        $client = new PhpClient();
        $responses = $client->call('mq begin'); //在这里传入发送给服务端脚本的内容

    }



    /**
     * This command echoes what you have entered as the message.
     * @param string $message the message to be echoed.
     */
    public function actionReceive($message = 'rabbit mq Receive')
    {
        $client = new PhpClient();
        $responses = $client->call('direct type test','logs'); //在这里传入发送给服务端脚本的内容
        var_dump("Receive Message OK");

    }
    /**
     * This command echoes what you have entered as the message.
     * @param string $message the message to be echoed.
     */
    public function actionSend($message = 'rabbit mq send')
    {
        echo $message . "\n";
        $client = new PhpClient();
        $responses = $client->call('direct type test','logs'); //在这里传入发送给服务端脚本的内容
        var_dump("Send Message OK");
    }













}