测试环境：ThinkPHP5.0

测试方法：

1、将下载的PHPamqplib文件放在extend目录下；

2、在控制器引入相应类

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

3、在控制器或者配置文件中定义相关参数

public static $amqp = array(
        'name' => 'admin',
        'password' => 'admin',//填写加密用的EncodingAESKey,
        'exchange' => 'publish-topic',
        'command'=>'admin',//主题口令
        'mode' => 'topic'//方式
    );

4、定义qmqp方法

    /**
     * [amqp 消息队列]
     * @param  [arr] $data [发送数据]
     *
     */
    public function amqp($data="aaa",$topic="hello")
    {
        $connection = new AMQPStreamConnection('39.107.122.245', 5672, Index::$amqp['name'], Index::$amqp['password'],'admin');
        $channel = $connection->channel();
        $channel->exchange_declare(Index::$amqp['exchange'], Index::$amqp['mode'], true, false, false);
        $msg = new AMQPMessage($data);
        $channel->basic_publish($msg, Index::$amqp['exchange'],$topic);
        $channel->close();
        $connection->close();
    }

这里只简单演示消息发送；消息的消费可参考rabbit官网