を設定する際の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
に開き、作成したキューを見ることができます。
例外なくポートを設定するにはどうすればよいですか?
setPort()を使用していないときブラウザのlocalhost:15672で開き、私のrabbitmqキューを参照してください – user2957954
try 5672 not 15672 – cantSleepNow
私はRabbitMQをあまり使用していません。 15672ブローカポートではなく、何らかの管理ポートである必要がありますか?以前のポスターが指摘したように、最近5672はAMQPメッセージングのデフォルトです。 ActiveMQ/ArtemisでAMQPを実行すると、WebブラウザをAMQPポートに接続できません。 –