1

私はrabbitmqクラスターを使用しています。私のコンシューマーは、haproxy を介してこのクラスターに接続されています。

消費者は、haproxy を介して接続された次の例外を発生させました。ノードに直接接続されているコンシューマーが例外を発生させない場合。

2013-01-08 16:25:09,745 警告 | SimpleAsyncTaskExecutor-1 | osamqp.rabbit.listener.SimpleMessageListenerContainer | コンシューマが例外を発生させました。接続ファクトリがサポートしている場合、処理を再開できます。例外の概要: com.rabbitmq.client.ShutdownSignalException: 接続エラー。理由: java.io.EOFException

私の ha-proxy 構成を参照してください。

グローバル
    ログ 127.0.0.1 local0
    ログ 127.0.0.1 local1 通知
    #logloghost ローカル 0 情報をログに記録する
    マックスコン 4096
    #chroot /usr/share/haproxy
    ユーザー ハプロキシ
    グループハプロキシ
    デーモン
    ＃デバッグ
    ＃静かな

デフォルト
    ロググローバル
    オプション dontlognull
    再試行 3
    オプション再発送
    マックスコン5000
    タイムアウト 10000
    clitimeout 60000
    srvtimeout 60000


リッスン rabbitmq_producer_cluster 0.0.0.0:5672
    モード TCP                                                
    バランスラウンドロビン                 

    サーバー rabbit_1 rabbit1:5672 チェック インター 5000 上昇 2 下降 3    
    サーバー rabbit_2 rabbit2:5672 チェック インター 5000 上昇 2 下降 3
    #server rabbit_3 rabbit3:5672 チェック インター 5000 上昇 2 下降 3

リッスン rabbitmq_consumer_cluster 0.0.0.0:5673
    モード TCP
    バランスラウンドロビン
    オプションtcpka   

    サーバー rabbit_1 rabbit1:5672 チェック インター 5000 上昇 2 下降 3
    サーバー rabbit_2 rabbit2:5672 バックアップ チェック インター 5000 上昇 2 下降 3
    #server rabbit_3 rabbit3:5672 チェック インター 5000 上昇 2 下降 3

private_monitoring を聞く:8100
    モード http
    オプション httplog
    統計を有効にする
    統計 uri /stats
    統計更新 5 秒
4

1 に答える 1

0

ネイティブ接続ファクトリーのタイムアウトは? 60 秒未満になるようにしてください。

于 2013-01-09T09:01:07.857 に答える