rabbitmq接收不到消息防火墙_用PHP+RabbitMQ实现消息的发送和接收

消费者：接收消息

逻辑：
创建连接-->创建channel-->创建交换机-->创建队列-->绑定交换机/队列/路由键-->接收消息

<?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//创建连接和channel
$conn = new AMQPConnection($conn_args);
if (!$conn->connect()) {die("Cannot connect to the broker!n");
}
$channel = new AMQPChannel($conn);//创建交换机
$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";//创建队列
$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()); //手动发送ACK应答
}
生产者：发送消息逻辑：
创建连接-->创建channel-->创建交换机对象-->发送消息 Continue reading →Posted in 系统架构 | 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在进阶的时候总会遇到一些问题和瓶颈，业务代码写多了没有方向感，不知道该从那里入手去提升，对此我整理了一些资料，包括但不限于：分布式架构、高可扩展、高性能、高并发、服务器性能调优、TP6，laravel，YII2，Redis，Swoole、Swoft、Kafka、Mysql优化、shell脚本、Docker、微服务、Nginx等多个知识点高级进阶干货需要的可以免费分享给大家，需要戳这里PHP进阶架构师>>>视频、面试文档免费获取

或者关注我每天分享技术文章

PHP架构师之路www.zhihu.com