RabbitMq连接由对等方重置


RabbitMq connection reset by peer

我在RabbitMQ中遇到了更严重的错误。我发送了一些产品的信息扔了RabbitMq和Php,但出了问题。我可以在大约一分钟后发送消息,因为我出现了异常"errno=104对等方重置连接"。见下文:

2016-05-09 08:13:14 Daemon start
2016-05-09 08:13:17 Send to shop-id-1-price
2016-05-09 08:13:21 Send to shop-id-1-price
2016-05-09 08:13:24 Send to shop-id-1-price
2016-05-09 08:13:28 Send to shop-id-1-price
2016-05-09 08:13:32 Send to shop-id-1-price
2016-05-09 08:13:36 Send to shop-id-1-price
2016-05-09 08:13:39 Send to shop-id-1-price
2016-05-09 08:13:43 Send to shop-id-1-price
2016-05-09 08:13:47 Send to shop-id-1-price

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

rabbitmq:consumer [-m|--messages [MESSAGES]] [-r|--route [ROUTE]] [-l|--memory-limi
t [MEMORY-LIMIT]] [-d|--debug] [--] <name>
PHP Fatal error:  Uncaught ErrorException: fwrite(): send of 19 bytes failed with e
rrno=32 Broken pipe in /chroot/data/stage/home/html/vendor/videlalva
ro/php-amqplib/PhpAmqpLib/Wire/IO/StreamIO.php:271

rabbitmq-3.6.1版本,php-7.0.5版本,php-amqp库版本-"videlalvaro/php-amqplib":"~2.7

来自rabbitmq:的日志

=INFO REPORT==== 9-May-2016::03:36:53 ===
accepting AMQP connection <0.25777.24> (104.207.249.104:38001 -> 104.207.249.104:5672)
=ERROR REPORT==== 9-May-2016::03:37:23 ===
closing AMQP connection <0.25777.24> (104.207.249.104:38001 -> 104.207.249.104:5672):
{writer,send_failed,{error,timeout}}

@Gabriele的链接帮助了我,以下是问题的详细信息:https://stackoverflow.com/a/36114095/1476819

这两个变化解决了我的问题:

  • 在调用basic_consume之前添加此。它将CCD_ 2设置为1;无穷大"
$channel->basic_qos(null, 1, null);
$channel->basic_consume(...);
  • 我不确定这是否也有必要,但我已经从no_ack变成了ack。此处向下滚动至消息确认标题:https://www.rabbitmq.com/tutorials/tutorial-two-php.html

我同时做了这些更改,现在它与docker一起工作。