php-amqplib库操作RabbitMQ

mq的安装和php的扩扎在另外文章说明

RabbitMQ基本原理

首先，建议去大概了解下RabbitMQ(以下简称mq)的基本工作原理，可以参考这篇文章
最主要的几个对象如下

这几个对象在上面的文章说描述的已经非常清楚，这里不要叙述了。

安装操作库

在你的项目目录下的composer.json文件中增加下面内容

{
  "require": {
      "php-amqplib/php-amqplib": "2.7.*" //增加这行
  }
}

然后接着执行composer update php-amqplib/php-amqplib。更加方便的做法是如果你的项目已经有了composer.json那么执行执行
composer require php-amqplib/php-amqplib便可以直接进行安装了

示例演示

首先需要定义交换机、队列以及路由关键字(routing key) 下面是示例代码

<?php

require 'vendor/autoload.php';

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

$conf = [
        'host' => '127.0.0.1',
        'port' => 5672,
        'user' => 'kd_dev',
        'pwd' => 'kd_dev',
        'vhost' => '/',
];
$exchangeName = 'kd_sms_send_ex'; //交换机名
$queueName = 'kd_sms_send_q'; //队列名称
$routingKey = 'sms_send'; //路由关键字(也可以省略)

$conn = new AMQPStreamConnection( //建立生产者与mq之间的连接
    $conf['host'], $conf['port'], $conf['user'], $conf['pwd'], $conf['vhost']
);
$channel = $conn->channel(); //在已连接基础上建立生产者与mq之间的通道


$channel->exchange_declare($exchangeName, 'direct', false, true, false); //声明初始化交换机
$channel->queue_declare($queueName, false, true, false, false); //声明初始化一条队列
$channel->queue_bind($queueName, $exchangeName, $routingKey); //将队列与某个交换机进行绑定，并使用路由关键字

$msgBody = json_encode(["name" => "iGoo", "age" => 22]);
$msg = new AMQPMessage($msgBody, ['content_type' => 'text/plain', 'delivery_mode' => 2]); //生成消息
$r = $channel->basic_publish($msg, $exchangeName, $routingKey); //推送消息到某个交换机
$channel->close();
$conn->close();

有几个地方需要注意：

1. $routingKey其实是可以省略的，但是一般都带上方便交换机对消息进行不同队列的推送
2. 如果绑定的时候使用了$routingKey,那么在bashic_publish的时候也要指定$routingKey，不然交换机无法路由到指定队列，默认就推送到不使用关键字的队列了(这在我实验的时候遇到的一个坑)
3. 上面的exchange_declare和queue_declare以及queue_bind其实也不是必须的，如果在代码运行之前这行交换机和队列名称以及通过管理后台的方式手动添加在mq上，那么可以执行使用，而不需要上面的这3句代码。

执行上面的代码后你也可以在mq管理后台看到对应的显示，如下图
添加后的交换机显示

添加后的队列显示

队列与交换机的绑定关系，以及绑定的路由关键字

路由匹配

上面的代码中，当我们声明初始化交换机的时候第二个参数使用direct参数，其实还有另外3种参数可选。分别为

下一篇在简单的演示一下客户端如何消费队列

---更新---
更新一下在创建交换机和队列的时候各个常用参数说明

name: $queue    // should be unique in fanout exchange. [队列名称]
    passive: false  // don't check if a queue with the same name exists [是否检测同名队列]
    durable: false // the queue will not survive server restarts [是否开启队列持久化]
    exclusive: false // the queue might be accessed by other channels [队列是否可以被其他队列访问]
    auto_delete: true //the queue will be deleted once the channel is closed. [通道关闭后是否删除队列]

name: $exchange [交换机名称]
    type: direct [路由类型]
    passive: false []
    durable: true [交换机是否开启持久化]
    auto_delete: false //the exchange won't be deleted once the channel is closed.