5

私はマシン上でウサギのmqを実行しています

  • クライアントと 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

手伝ってください

4

2 に答える 2

1

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()
于 2015-01-23T05:07:55.987 に答える
1

同様の問題がありました。すべてが正常に見える場合は、何らかの設定ミスがある可能性があります (不適切なバインドなど)。構成timeoutが間違っていると、スクリプトが移動する必要があると思われる場所に到達できないため、エラーが発生する可能性があります。

私の問題については、特にrabbitmq.configファイルとバインディングの両方に問題があり、次の python ソリューションを使用する必要がありました。更新して適切に構成すると、すべてが正常に機能しました。うまくいけば、これで正しい方向に進むことができます。

于 2014-10-02T19:59:57.827 に答える