私はRabbitMQキューから受信したすべてのURLをクロールするための小さなプログラムを作成しています。私は約6000件のURLでテストし、半分が処理された後、クライアントは例外なく停止し、rabbitmqサーバーへの接続はすべて失われます。私はまた、ログをチェックし、RabbitMqクライアントクローズTCP接続が突然
=WARNING REPORT==== 7-Apr-2016::10:40:50 ===
closing AMQP connection <0.32373.9> (192.168.55.1:55716 -> 192.168.55.100:5672):
connection_closed_abruptly
のようないくつかのものを持ってきた私は、この接続ファクトリの設定を使用しています:
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("192.168.55.100");
factory.setUsername(params.username);
factory.setPassword(params.password);
factory.setVirtualHost(params.virtualHost);
factory.setAutomaticRecoveryEnabled(true);
factory.setRequestedHeartbeat(2);
あなたはこれについていくつかのアイデアを持っていますか?よろしく!
最後に、これが私の問題を解決します。ありがとう – innovatism