合租网站设计,临沂品牌网站推广,移动商城网站开发选择,南通网站建设项目消费者#xff1a;接收消息逻辑#xff1a;创建连接--创建channel--创建交换机--创建队列--绑定交换机/队列/路由键--接收消息?php
/*************************************
* PHP amqp(RabbitMQ) Demo - consumer
* Author: Linvo
* Date: 2018/7/…消费者接收消息逻辑创建连接--创建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, RabbitMQwindows下安装rabbitmq的php扩展amqp1.将php_amqp.dll放在php的ext目录里然后修改php.ini文件在文件的最后面添加两行[amqp]
extensionphp_amqp.dll2.将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在进阶的时候总会遇到一些问题和瓶颈业务代码写多了没有方向感不知道该从那里入手去提升对此我整理了一些资料包括但不限于分布式架构、高可扩展、高性能、高并发、服务器性能调优、TP6laravelYII2RedisSwoole、Swoft、Kafka、Mysql优化、shell脚本、Docker、微服务、Nginx等多个知识点高级进阶干货需要的可以免费分享给大家需要戳这里PHP进阶架构师视频、面试文档免费获取或 者关注我每天分享技术文章PHP架构师之路www.zhihu.com
