RabbitMQ php-amqplib使用--基本使用

1.一些基本概念：

vhost：虚拟主机，开设多个vhost，用作不同用户的权限分离。
channel：通道，建立一个访问通道。
Exchange：交换机，它指定消息按什么规则，路由到哪个队列。
Queue：队列，每个消息都会被投入到一个或多个队列。
Routing Key：路由，exchange根据这个关键字进行消息投递。
producer：消息生产者，就是投递消息的程序。
consumer：消息消费者，就是接受消息的程序。

2.建立生产者与mq之间的连接

$conn = new AMQPStreamConnection( $host,$port,$user,$password,$vhost);$host:  RabbitMQ服务器主机IP地址
$port:  RabbitMQ服务器端口
$user:  连接RabbitMQ服务器的用户名
$password:  连接RabbitMQ服务器的用户密码
$vhost:   连接RabbitMQ服务器的vhost（服务器可以有多个vhost，虚拟主机，类似nginx的vhost）

3.建立通道

$channel = $conn->channel($channel_id); //在已连接基础上建立生产者与mq之间的通道$channel_id 信道id，不传则获取$channel[“”]信道，再无则循环$this->channle数组，下标从1到最大信道数找第一个不是AMQPChannel对象的下标，实例化并返回AMQPChannel对象，无则抛出异常No free channel ids

4.声明初始化交换机

$channel->exchange_declare($exhcange_name,$type,$passive,$durable,$auto_delete);参数：
$exhcange_name 交换器名字
$type 交换器类型
$passive  false
  是否检测同名队列
durable false  交换机是否开启持久化
auto_detlete false  通道关闭后是否删除队列(1)交换器类型:direct(默认)，fanout, topic, 和headers
Direct:直接交换器，工作方式类似于单播，Exchange会将消息发送完全匹配ROUTING_KEY的Queue
fanout:广播是式交换器，不管消息的ROUTING_KEY设置为什么，Exchange都会将消息转发给所有绑定的Queue。
topic:主题交换器，工作方式类似于组播，Exchange会将消息转发和ROUTING_KEY匹配模式相同的所有队列，比如，ROUTING_KEY为user.stock的Message会转发给绑定匹配模式为 * .stock,user.stock， * . * 和#.user.stock.#的队列。（ * 表是匹配一个任意词组，#表示匹配0个或多个词组）
headers:消息体的header匹配（ignore）

5.声明初始化一条队列

$channel->queue_declare($name, $passive,$durable,$exclusive,$auto_delete);
    name: 队列名称
    passive: false   是否检测同名队列
    durable: false 是否开启队列持久化
    exclusive: false  队列是否可以被其他队列访问
    auto_delete: true 通道关闭后是否删除队列

6.创建要发送的信息 ，可以创建多个消息

$msg = new AMQPMessage($data,$properties)$data  string类型 要发送的消息
$properties array类型 设置的属性，比如设置该消息持久化[‘delivery_mode’=>2]

7.发送消息

$channel->basic_publish($msg,$exchange,$routing_key);$msg object AMQPMessage对象
$exchange string 交换机名字  
$routing_key string 路由键 如果交换机类型

8、关闭信道和链接

$channel->close();$connection->close();

9.路由绑定

$channel->queue_bind($queueName, $exchangeName, $routingKey);$queueName 队列名称
$exchangeName  交换机名称
$routingKey 路由键

10.消费消息

$channel->basic_consume($queue,$consumer_tag,$no_local, $no_ack, $exclusive,$nowait, $callback);$queue队列名称
$callback回调函数
（1）回调函数
 $callback = function($msg){
  echo " [x] Received ", $msg->body, "\n";
  sleep(substr_count($msg->body, '.'));
  echo " [x] Done", "\n";};

11.监听消息，一有消息，立马就处理

while(count($channel->callbacks)) {
    $channel->wait();}

https://www.kancloud.cn/lengyueguang/linux/2055371