>[info] 消費者代碼示例 **消費者：consumer.php** ~~~ <?php //申明連接參數 $config = [ 'host'=>'127.0.0.1', 'vhost'=>'/', 'port'=>5672, 'login'=>'test', 'password'=>'123456' ]; //連接broker,創建一個rabbitmq連接 $cnn = new AMQPConnection($config); //拋出異常 if(!$cnn->connect()){ echo "連接失敗"; exit(); } //在連接內創建一個通道 $ch = new AMQPChannel($cnn); //創建一個交換機 $ex = new AMQPExchange($ch); //申明路由鍵 $routingKey = 'key_1'; //申明交換機名稱 $exchangeName = 'exchange_1'; //設置交換機名稱 $ex->setName($exchangeName); //設置交換機的類型 $ex->setType(AMQP_EX_TYPE_DIRECT); //設置交換機的持久 $ex->setFlags(AMQP_DURABLE); //申明交換機 $ex->declareExchange(); //創建一個消息隊列 $q = new AMQPQueue($ch); //設置隊列名稱 $q->setName('queue_1'); //設置隊列的持久 $q->setFlags(AMQP_DURABLE); //申明消息隊列 $q->declareQueue(); $q->bind($ex->getName(), $routingKey); //接收消息并進行處理回調方法 function receive($envelope, $queue){ sleep(1); echo $envelope->getBody()."\n"; } $q->consume("receive"); ~~~ 1. 當前通道 交換機 隊列全部為空  2. 運行消費者代碼  3. 查看 rabbitmq 控制臺，看到添加交換機 隊列成功 連接：  通道：  交換機：  隊列：  >[info] 生產者代碼示例 **生產者：publisher.php** ~~~ <?php //申明連接參數 $config = [ 'host'=>'127.0.0.1', 'vhost'=>'/', 'port'=>5672, 'login'=>'test', 'password'=>'123456' ]; $cnn = new AMQPConnection($config); //拋出異常 if(!$cnn->connect()){ echo "連接失敗"; exit(); } $cn = new AMQPChannel($cnn); $ex = new AMQPExchange($cn); $routingKey = 'key_1'; $exchangeName = 'exchange_1'; $ex->setName($exchangeName); //設置交換機的類型 $ex->setType(AMQP_EX_TYPE_DIRECT); //設置交換機的持久 $ex->setFlags(AMQP_DURABLE); //申明交換機 $ex->declareExchange(); for($i=1;$i<=10;$i++){ //消息內容 $msg = [ 'data'=>'消息_'.$i, ]; $ex->publish(json_encode($msg), $routingKey , AMQP_NOPARAM, array('delivery_mode' => 2)); } ~~~ 1. 運行 生產者 for 循環推送消息  2. 查看消費者是否輸出消息  3. 查看 mq 控制臺隊列情況