使用場景。有個高并發的某某活動，因為并發量很高，Mysql的寫入的性能不能滿足吞吐（其他類似于mongo的庫除外），此時，可用借助RabbitMQ的工作隊列來處理，將直接寫入mysql的數據，以消息的形式先發送到RabbitMq的工作隊列中，消費端從隊列中消費數據入庫，這樣：1）客戶端不需要考慮mysql的瓶頸，隊列做為一個緩沖區。2）可用加入多個消費者，加速消費工作隊列，避免造成工作隊列消息積壓。 我們再hello world的發送、接收的代碼中，我做了幾點調整。 指定exchange，并顯式申明它的類型。 將exchange持久化，這樣那怕Rabbit重啟，exchange也不會消失。 將queue持久化，這樣那怕Rabbit重啟，queue也不會消失（包括queue中的消息） 在exchange publish消息時，指定 route key，同時在queue中綁定rout key，這樣exchange在轉發消息時，能夠將消息轉發到與route key匹配的的隊列中。 ~~~ send.php <?php $config = [ 'host' => '127.0.0.1', 'vhost' => '/', 'port' => 5672, 'login' => 'guest', 'password' => 'guest' ]; $conn = new \AMQPConnection($config); $conn->connect(); $channel = new \AMQPChannel($conn); $channel->qos(0,0); $exchange = new \AMQPExchange($channel); $exchange->setName('exchange.activity'); $exchange->setType(AMQP_EX_TYPE_DIRECT); $exchange->setFlags(AMQP_DURABLE); $exchange->declareExchange(); $queue = new \AMQPQueue($channel); $queue->setName('queue.activity'); $queue->declareQueue(); $queue->bind('exchange.activity','route.activity'); for($i=0;$i<6;$i++){ $result = $exchange->publish("message[$i]",'route.activity'); var_dump($result); } receive.php <?php $config = [ 'host' => '127.0.0.1', 'vhost' => '/', 'port' => 5672, 'login' => 'guest', 'password' => 'guest' ]; $conn = new \AMQPConnection($config); $conn->connect(); $channel = new \AMQPChannel($conn); $channel->qos(0,0); $queue = new \AMQPQueue($channel); $queue->setName("queue.activity"); $queue->setFlags(AMQP_PASSIVE); $queue->declareQueue(); $queue->bind('exchange.activity','route.activity'); $queue->consume('processMessage',AMQP_AUTOACK); function processMessage($envelope, $queue) { global $i; echo "Message $i: " . $envelope->getBody() . "\n"; $i++; } ~~~