Pika blocking_connection.py 连接到 RabbitMQ 的随机超时答案

【问题标题】：Pika blocking_connection.py random timeout connecting to RabbitMQPika blocking_connection.py 连接到 RabbitMQ 的随机超时
【发布时间】：2023-03-09 04:19:01
【问题描述】：

我有一个兔子 mq 在机器上运行

client 和 rabbitMQ 都在同一个网络上运行
rabbitMQ 有很多客户端
我可以从 rabbitMQ ping 客户端并返回
机器之间测得的最长延迟为 12.1 毫秒
网络详细信息：标准交换机网络（在单个物理机上运行的虚拟机网络 - 使用 vmware VC）

我在初始化 RPC 连接时随机超时

/usr/lib/python2.6/site-packages/pika-0.9.5-py2.6.egg/pika/adapters/blocking_connection.py

问题是超时时间不一致，时常发生。

当手动测试这个问题并在同一台机器上运行blocking_connection.py 1000 次失败时，不会产生超时。

这是我失败时得到的错误：

2013-04-23 08:24:23,396 runtest-trigger.24397 24397 DEBUG      producer_rabbit initiate_rpc_connection Connecting to RabbitMQ RPC queue rpcqueue_java on host: auto-db1
2013-04-23 08:24:25,350 runtest-trigger.24397 24397 ERROR      testrunner go   Run 1354: cought exception: timed out
Traceback (most recent call last):
  File "/testrunner.py", line 193, in go
    self.set_runparams(jobid)
  File "/testrunner.py", line 483, in set_runparams
    self.runparams.producers_testrun = self.initialize_producers_testrun(self.runparams)
  File "/basehandler.py", line 114, in initialize_producers_testrun
    producer.set_testcase_checkout()
  File "/baseproducer.py", line 73, in set_testcase_checkout
    self.checkout_handler = pm_checkout.get_producer(self.testcasecheckout)
  File "/producer_manager.py", line 101, in get_producer
    producer = self.load_producer(plugin_dir, producer_name)
  File "/producer_manager.py", line 20, in load_producer
    producer = getattr(producer_module, 'Producer')(producer_name, self.runparams)
  File "/producer_rabbit.py", line 13, in __init__
    self.initiate_rpc_connection()
  File "/producer_rabbit.py", line 67, in initiate_rpc_connection
    self.connection = pika.BlockingConnection(pika.ConnectionParameters( host=self.conf.rpc_proxy))
  File "/usr/lib/python2.6/site-packages/pika-0.9.5-py2.6.egg/pika/adapters/blocking_connection.py", line 32, in __init__
    BaseConnection.__init__(self, parameters, None, reconnection_strategy)
  File "/usr/lib/python2.6/site-packages/pika-0.9.5-py2.6.egg/pika/adapters/base_connection.py", line 50, in __init__
    reconnection_strategy)
  File "/usr/lib/python2.6/site-packages/pika-0.9.5-py2.6.egg/pika/connection.py", line 170, in __init__
    self._connect()
  File "/usr/lib/python2.6/site-packages/pika-0.9.5-py2.6.egg/pika/connection.py", line 228, in _connect
    self.parameters.port or  spec.PORT)
  File "/usr/lib/python2.6/site-packages/pika-0.9.5-py2.6.egg/pika/adapters/blocking_connection.py", line 44, in _adapter_connect
    self._handle_read()
  File "/usr/lib/python2.6/site-packages/pika-0.9.5-py2.6.egg/pika/adapters/base_connection.py", line 151, in _handle_read
    data = self.socket.recv(self._suggested_buffer_size)
timeout: timed out

请帮忙

【问题讨论】：

你的网络设置是什么，客户端和服务器在哪里，你测量过这两者之间的网络延迟，你知道MQ有很多客户端吗？这一切都可能导致超时错误，如果没有这些（以及更多）细节，解决问题将很困难。
感谢您的建议，我在问题中添加了信息
在同一个网络上~12ms 可能有点高，但是你没有提供足够的细节来说明那是什么类型的网络。但是，由于您显然看到了超时，您是否尝试过像 pika.readthedocs.org/en/latest/connecting.html 那样创建 socket_timeout 值？

标签： python rabbitmq rpc pika python-pika

【解决方案1】：

我遇到了类似的问题。如果一切看起来都很好，那么您很可能有某种未配置的配置，例如装订不好。如果未配置，那么您将得到一个timeout，因为脚本无法到达它认为需要去的地方，因此在这种情况下错误可能会导致错误。

对于我的问题，我的rabbitmq.config 文件和我的绑定都特别有问题，我不得不使用我的python 解决方案，如：RabbitMQ creating queues and bindings from a command line 所示，而不是我展示的命令行示例。正确更新和配置后，一切正常。希望这能让您朝着正确的方向前进。

【讨论】：

【解决方案2】：

Pika 在连接不同主机时会出现超时问题。解决方案是在连接参数中传递socket_timeout 参数。Pika 应该升级到 >=0.9.14

credentials = pika.PlainCredentials(RABBITMQ_USER, RABBITMQ_PASS)
connection = pika.BlockingConnection(pika.ConnectionParameters(
    credentials=credentials,
        host=RABBITMQ_HOST,
         socket_timeout=300))
channel = connection.channel()

【讨论】：