RabbitMQ错误：fwrite（）：发送12字节失败，对等方重置了errno=104连接

Question

我在Laravel 4.2应用程序中使用RabbitMQ库videlvalvaro/php amqplib，开始出现以下错误：

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

有人能提出任何可能导致这种情况的建议吗？

Answer 1

我也有同样的问题。这个案例可以解决这个问题。您应该在ClassNameConsumer类中的方法“execute”中调用此方法。

对于php语言。

/**
 * Resolved problem - Connection reset by peer
 * @param AMQPMessage $msg
 */
public function keepAlive(AMQPMessage $msg)
{
    if (!isset($this->message->delivery_info['channel'])) {
        return;
    }

    /** @var AMQPChannel $channel */
    $channel = $msg->delivery_info['channel'];

    $pkt = new AMQPWriter();
    $pkt->write_octet(8);
    $pkt->write_short(0);
    $pkt->write_long(0);
    $pkt->write_octet(0xCE);

    $channel->getConnection()->write($pkt->getvalue());
}

Answer 2

我也有同样的问题。将预取计数设置为1对我来说很有效，因为我不关心性能与稳定性之间的小折衷。

$channel->basic_qos(0, 1, false);

语法：

basic_qos($prefetch_size, $prefetch_count, $a_global);

Answer 3

“由对等方重置连接”是TCP/IP协议，相当于将手机重新挂上钩子。这比不回答、挂着一个电话更礼貌。但这并不是真正有礼貌的TCP/IP交谈者所期望的结果。（来自其他SO的回答）

所以你对此无能为力，这是服务器的问题。

但是您可以使用try... cat块来处理该异常：

try {
    $msg = new AMQPMessage('Hello World!');
    $channel->basic_publish($msg, '', 'hello');

} catch (Exception $e) {
    // handle exception
}