Pika阻止连接.py随机超时连接到RabbitMQ
回答此问题可获得 20 贡献值，回答如果被采纳可获得 50 分。
<p>我有一个rabbit mq正在机器上运行</p>
<ul>
<li>客户机和rabbitMQ都运行在同一个网络上</li>
<li>rabbitMQ有很多客户机</li>
<li>我可以从rabbitMQ来回ping客户机</li>
<li>机器之间测量的最长延迟为12.1毫秒</li>
<li>网络详细信息：标准交换机网络（在单个物理机上运行的虚拟机网络-使用vmware VC）</li>
</ul>
<p>初始化RPC连接时im收到随机超时</p>
<blockquote>
<p>/usr/lib/python2.6/site-packages/pika-0.9.5-py2.6.egg/pika/adapters/blocking_connection.py</p>
</blockquote>
<p>问题是超时时间不一致，而且有时会发生。在</p>
<p>当手动测试此问题并运行阻塞时_连接.py在同一台机器上发生1000次故障，不会产生超时。在</p>
<p>这是失败时的错误：</p>
<pre><code>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
</code></pre>
<p>请协助</p>
请先 登录 后评论
针对此问题: 更多的回答
- 89 关注
- 1 收藏，216 浏览
- 网友 提问于 2天前
相关Python问题
- 当用户用PYTHON设置一个或一个不带值的URL时，他们怎么能输入一个/a的代码呢？ 7 回答
- 当用户登录到站点时，如何显示不同的导航栏 3 回答
- 当用户登录时，在Flask中向用户显示处理结果 10 回答
- 当用户的Flask会话结束时，我如何从Redis后端中移除所有Celery结果？ 6 回答
- 当用户的Okta配置文件字段当前为blan时，更新该字段 9 回答
- 当用户的付款逾期2天时，从Django模型检索数据 3 回答
- 当用户的消息以问号结尾时，如何让机器人说些什么？ 1 回答
- 当用户的系统上可能也安装了Python 2.7时，如何在用户的系统上运行Python 3脚本？ 2 回答
- 当用户确定打印数量时，使用Matplotlib打印动画 2 回答
- 当用户离开时是否可以删除整个网页？ 1 回答
- 当用户给出一个单词时如何打印？ 3 回答
- 当用户继续更改TKin中的值（使用trace方法）时，使用Entry并更新输入的条目 9 回答
- 当用户编辑表单字段时，从Django时间字段中删除秒数 4 回答
- 当用户被更改时，消息不会来自web套接字 10 回答
- 当用户访问表单时，如何使表单为只读，而不具有更改权限 5 回答
- 当用户试图更改对象的值时，使用描述符类引发RuntimeError 2 回答
- 当用户调整GUI的大小时，是否有方法更改GUI内容的大小？ 10 回答
- 当用户调整风的大小时，pythontkinter小部件的大小会不均匀 9 回答
- 当用户购买某个类别时，是否查找其他类别的销售？ 10 回答
- 当用户转到上一页时，Django和芹菜插入操作 1 回答
