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(); } ~~~