4

快速提问：

为了防止“Broken Pipe Error”，我是否需要祈祷两个独立的应用程序在通信 RabbitMQ 时不要同时使用相同的通道？（或者线程与拥有两个或多个独立应用程序不同？）

历史：

我已经编写了一些应用程序，其中一个（io-server）从我的其他应用程序的角度来看就像一个服务器，从 RabbitMQ 服务器的角度来看它就像一个客户端。

现在，一切都按预期运行了大约 10 分钟。然后，我的 io-server 崩溃了。这是回溯的最后一部分：

    File "/usr/local/lib/python2.7/dist-packages/amqp-1.4.2-py2.7.egg/amqp/transport.py", line 163, in write_frame
    frame_type, channel, size, payload, 0xce,
  File "/usr/lib/python2.7/socket.py", line 224, in meth
    return getattr(self._sock,name)(*args)
error: [Errno 32] Broken pipe

这是 RabbitMQ 日志的相关部分：

=ERROR REPORT==== 31-Mar-2014::12:29:53 ===
AMQP connection <0.22183.0> (running), channel 1 - error:
{amqp_error,unexpected_frame,
            "expected content header for class 60, got non content header frame instead",
            'basic.publish'}

=INFO REPORT==== 31-Mar-2014::12:30:23 ===
closing AMQP connection <0.22183.0> (127.0.0.1:43367 -> 127.0.0.1:5672)

据我所知，最有希望的答案在这里：

...
So yes, RabbitMQ closes the connection due to a connection-level error
with frame interleaving. 
...
 * Avoid publishing on *the same* channel from multiple threads
 * Synchronize publishing in your own code

我可以让我的应用程序同步发布。但是如何保证我的所有应用程序同步运行？我真的必须吗？

4

2 回答 2

0

我是否需要为没有两个独立的应用程序使用相同的频道而祈祷

不，这里的“频道”是指您共享的链接是一个共享Channel对象。如果不同的应用程序（进程）不共享内​​存，它们将总是有不同的通道。

线程与拥有两个或更多独立应用程序有什么不同？

是的。您使用的 amqp 库不是线程安全的。如果您Channel()在“IO 服务器”中的不同线程之间共享一个对象，这将是一个问题。但是，如果您的服务器是单线程的并且您运行许多并行实例，这将不是问题。

我建议您保持简单，不要在服务器应用程序中使用线程。假设您的 IO 服务器接受来自其他应用程序的 HTTP 连接；依靠 nginx+uwsgi 接受并行请求。

于 2019-06-12T13:44:59.647 回答
0

我经历过这个确切的问题，并且（正如@istepaniuk）指出这与线程有关。您不能在多个线程中重复使用相同的连接，您必须为每个线程打开 1 个连接。

于 2019-06-12T13:50:01.473 回答