消費者：接收消息

邏輯：
創(chuàng)建連接-->創(chuàng)建channel-->創(chuàng)建交換機-->創(chuàng)建隊列-->綁定交換機/隊列/路由鍵-->接收消息

<?php /************************************* * PHP amqp(RabbitMQ) Demo - consumer * Author: Linvo * Date: 2018/7/30 *************************************/ //配置信息 $conn_args = array('host' => '192.168.1.93','port' => '5672','login' => 'guest','password' => 'guest','vhost'=>'/' ); $e_name = 'e_linvo'; //交換機名 $q_name = 'q_linvo'; //隊列名 $k_route = 'key_1'; //路由key//創(chuàng)建連接和channel $conn = new AMQPConnection($conn_args); if (!$conn->connect()) {die("Cannot connect to the broker!n"); } $channel = new AMQPChannel($conn);//創(chuàng)建交換機 $ex = new AMQPExchange($channel); $ex->setName($e_name); $ex->setType(AMQP_EX_TYPE_DIRECT); //direct類型 $ex->setFlags(AMQP_DURABLE); //持久化 echo "Exchange Status:".$ex->declare()."n";//創(chuàng)建隊列 $q = new AMQPQueue($channel); $q->setName($q_name); $q->setFlags(AMQP_DURABLE); //持久化 echo "Message Total:".$q->declare()."n";//綁定交換機與隊列，并指定路由鍵 echo 'Queue Bind: '.$q->bind($e_name, $k_route)."n";//阻塞模式接收消息 echo "Message:n"; while(True){$q->consume('processMessage');//$q->consume('processMessage', AMQP_AUTOACK); //自動ACK應答 } $conn->disconnect();/** * 消費回調函數 * 處理消息 */ function processMessage($envelope, $queue) {$msg = $envelope->getBody();echo $msg."n"; //處理消息$queue->ack($envelope->getDeliveryTag()); //手動發(fā)送ACK應答 } 生產者：發(fā)送消息邏輯： 創(chuàng)建連接-->創(chuàng)建channel-->創(chuàng)建交換機對象-->發(fā)送消息 Continue reading →Posted in 系統(tǒng)架構 | Tagged amqp, RabbitMQ

windows下安裝rabbitmq的php擴展amqp

1.將php_amqp.dll放在php的ext目錄里，然后修改php.ini文件，在文件的最后面添加兩行

[amqp] extension=php_amqp.dll

2.將rabbitmq.1.dll文件放在php的根目錄里(也就是ext目錄的父級目錄)，然后修改apache的httpd.con文件，文件尾部添加一行

LoadFile "d:/wamp/bin/php/php5.5.12/rabbitmq.1.dll"

這里的路徑根據情況修改，我這里使用的wampserver軟件。

3.重啟apache，并查看phpinfo信息。只要看到amqp 字樣即可。

以上內容希望幫助到大家，很多PHPer在進階的時候總會遇到一些問題和瓶頸，業(yè)務代碼寫多了沒有方向感，不知道該從那里入手去提升，對此我整理了一些資料，包括但不限于：分布式架構、高可擴展、高性能、高并發(fā)、服務器性能調優(yōu)、TP6，laravel，YII2，Redis，Swoole、Swoft、Kafka、Mysql優(yōu)化、shell腳本、Docker、微服務、Nginx等多個知識點高級進階干貨需要的可以免費分享給大家，需要戳這里PHP進階架構師>>>視頻、面試文檔免費獲取

或 者關注我每天分享技術文章

PHP架構師之路?www.zhihu.com

總結

以上是生活随笔為你收集整理的rabbitmq接收不到消息 防火墙_用PHP+RabbitMQ实现消息的发送和接收的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。