Logstash無法連接到rabbitmq

我正在嘗試設置logstash配置以將行從文件推送到rabbitmq。我在本地機器上安裝了logstash 2.1.1和rabbit 3.6.0來測試它。輸出配置爲：Logstash無法連接到rabbitmq

output { 
    rabbitmq { 
      exchange => "test_exchange" 
      key => "test" 
      exchange_type => "direct" 
      host => "127.0.0.1" 
      port => "15672" 
      user => "logstash" 
      password => "logstashpassword" 
     } 
}

但是當我現在開始logstash它失敗，出現以下錯誤啓動（當logstash在調試模式下啓動的輸出僅顯示）：

Worker threads expected: 4, worker threads started: 4 {:level=>:info, :file=>"logstash/pipeline.rb", :line=>"186", :method=>"start_filters"} 
Connecting to RabbitMQ. Settings: {:vhost=>"/", :host=>"127.0.0.1", :port=>15672, :user=>"logstash", :automatic_recovery=>true, :pass=>"logstashpassword", :timeout=>0, :heartbeat=>0} {:level=>:debug, :file=>"logstash/plugin_mixins/rabbitmq_connection.rb", :line=>"135", :method=>"connect"} 
The error reported is: 

com.rabbitmq.utility.BlockingCell.get(com/rabbitmq/utility/BlockingCell.java:77) 
com.rabbitmq.utility.BlockingCell.uninterruptibleGet(com/rabbitmq/utility/BlockingCell.java:111) 
com.rabbitmq.utility.BlockingValueOrException.uninterruptibleGetValue(com/rabbitmq/utility/BlockingValueOrException.java:37) 
com.rabbitmq.client.impl.AMQChannel$BlockingRpcContinuation.getReply(com/rabbitmq/client/impl/AMQChannel.java:367) 
com.rabbitmq.client.impl.AMQConnection.start(com/rabbitmq/client/impl/AMQConnection.java:293) 
com.rabbitmq.client.ConnectionFactory.newConnection(com/rabbitmq/client/ConnectionFactory.java:621) 
com.rabbitmq.client.ConnectionFactory.newConnection(com/rabbitmq/client/ConnectionFactory.java:648) 
java.lang.reflect.Method.invoke(java/lang/reflect/Method.java:606) 
RUBY.new_connection_impl(/opt/logstash/vendor/bundle/jruby/1.9/gems/march_hare-2.11.0-java/lib/march_hare/session.rb:505) 
org.jruby.RubyProc.call(org/jruby/RubyProc.java:281) 
RUBY.converting_rjc_exceptions_to_ruby(/opt/logstash/vendor/bundle/jruby/1.9/gems/march_hare-2.11.0-java/lib/march_hare/session.rb:467) 
RUBY.new_connection_impl(/opt/logstash/vendor/bundle/jruby/1.9/gems/march_hare-2.11.0-java/lib/march_hare/session.rb:500) 
RUBY.initialize(/opt/logstash/vendor/bundle/jruby/1.9/gems/march_hare-2.11.0-java/lib/march_hare/session.rb:136) 
RUBY.connect(/opt/logstash/vendor/bundle/jruby/1.9/gems/march_hare-2.11.0-java/lib/march_hare/session.rb:109) 
RUBY.connect(/opt/logstash/vendor/bundle/jruby/1.9/gems/march_hare-2.11.0-java/lib/march_hare.rb:20) 
RUBY.connect(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-mixin-rabbitmq_connection-2.2.0-java/lib/logstash/plugin_mixins/rabbitmq_connection.rb:137) 
RUBY.connect!(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-mixin-rabbitmq_connection-2.2.0-java/lib/logstash/plugin_mixins/rabbitmq_connection.rb:94) 
RUBY.register(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-output-rabbitmq-3.0.6-java/lib/logstash/outputs/rabbitmq.rb:40) 
org.jruby.RubyArray.each(org/jruby/RubyArray.java:1613) 
RUBY.start_outputs(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-core-2.1.1-java/lib/logstash/pipeline.rb:192) 
RUBY.run(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-core-2.1.1-java/lib/logstash/pipeline.rb:102) 
RUBY.execute(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-core-2.1.1-java/lib/logstash/agent.rb:165) 
RUBY.run(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-core-2.1.1-java/lib/logstash/runner.rb:90) 
org.jruby.RubyProc.call(org/jruby/RubyProc.java:281) 
RUBY.run(/opt/logstash/vendor/bundle/jruby/1.9/gems/logstash-core-2.1.1-java/lib/logstash/runner.rb:95) 
org.jruby.RubyProc.call(org/jruby/RubyProc.java:281) 
RUBY.initialize(/opt/logstash/vendor/bundle/jruby/1.9/gems/stud-0.0.22/lib/stud/task.rb:24) 
java.lang.Thread.run(java/lang/Thread.java:745)

然後logstash「崩潰」即停止。有誰知道這是否與logstash的配置有關，或者它是rabbitMQ設置中的問題嗎？

在此先感謝。 Daniel

來源

2016-01-21 d.a.d.a

發現我的錯誤rabbitMQ的端口必須是5672而不是15672。

來源

2016-01-21 10:08:17

Logstash無法連接到rabbitmq

回答

相關問題