码迷,mamicode.com
首页 > Web开发 > 详细

PHP Rabbitmq 报错Broken pipe

时间:2019-08-03 10:49:21      阅读:180      评论:0      收藏:0      [点我收藏+]

标签:sum   没有   nec   bytes   大量   消息队列   channel   err   class   

fwrite(): send of 13 bytes failed with errno=32 Broken pipe

fwrite(): send of 21 bytes failed with errno=104 Connection reset by peer

 

用 rabbitmq 做消息队列时报上面的错误,当消费队列一启动,Unacked 瞬间达到好几百。经查:RabbitMQ服务器在短时间内发送大量的消息给Consumer,如果你没有来得及Ack的话,那么服务端会积压大量的UnAcked消息,而Consumer如果来不急处理也会处于假死或程序崩溃。

后果就是Consmer崩溃后,UnAcked消息又ReQueue不断消耗MQ的资源

 

解决方案:

技术图片
$connection = new AMQPStreamConnection(HOST, PORT, USER, PASS, VHOST);

$channel = $connection->channel();

$channel->queue_declare(‘qos_queue‘, false, true, false, false);

$channel->basic_qos(null, 10, null); //加上这个就好了 这个10 就是Unacked 里面的值,表示预先取出多少值来消费  prefetch_count
技术图片

 

PHP Rabbitmq 报错Broken pipe

标签:sum   没有   nec   bytes   大量   消息队列   channel   err   class   

原文地址:https://www.cnblogs.com/php-linux/p/11293807.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!