2017-08-30 5 views
0

を設定する際のRabbitMQは接続を拒否:私はJavaでそれを実装し、エンドポイントのコンストラクタを持ちたいデフォルトポート

public EndPoint(final String endPointName, final String host, final int port){ 
    this.name=endPointName; 
    ConnectionFactory factory = new ConnectionFactory(); 

    factory.setHost(host); 
    factory.setPort(port); 
    connection = factory.newConnection(); 

    channel = connection.createChannel(); 
    channel.queueDeclare(name, false, false, false, null); 

} 

そして私は、私が考慮された引数"localhost"15672を設定した場合でもEOFException:connection refusedを受け取ります私が理解する限り、デフォルトにする。問題はメソッドsetPort()です:すべてが完璧に機能していない場合。

なぜ15672ポートが正しいと思いますか? setPort()がなければ私のブラウザのRabbitmqヘルパーをlocalhost:15672に開き、作成したキューを見ることができます。

例外なくポートを設定するにはどうすればよいですか?

答えて

1

RabbitMQの運用プロトコルのデフォルトポートは5672です。ポート15672は、管理プラグイン(GUI)のデフォルトポートです。

0

RabbitMQのリリースによって、デフォルトポートが異なります。コードがsetPort()コールなしで動作する場合は、RabbitMQクライアントランタイムライブラリが使用するデフォルトのものが何であれ、正しいと思われ、15672の選択が間違っていると思います。

「接続が拒否されました」とは、ほとんどの場合、実際には指定されたポートで何も受信していないことを意味します。

+0

setPort()を使用していないときブラウザのlocalhost:15672で開き、私のrabbitmqキューを参照してください – user2957954

+1

try 5672 not 15672 – cantSleepNow

+0

私はRabbitMQをあまり使用していません。 15672ブローカポートではなく、何らかの管理ポートである必要がありますか?以前のポスターが指摘したように、最近5672はAMQPメッセージングのデフォルトです。 ActiveMQ/ArtemisでAMQPを実行すると、WebブラウザをAMQPポートに接続できません。 –

関連する問題