rabbitmq 和 logstash 配置不工作

Question

我正在尝试链接 logstash 以从将在 elasticsearch 中编制索引的队列中读取消息。我最初让它与一个托运人一起工作，将消息发送到 logstash 端口，但现在即使这样也不起作用。尝试运行 logstash conf 文件时的错误:

RabbitMq connection error: . Will reconnect in 10 seconds... {:level=>error}
//not sure if the next piece is related:

WARN: org.elasticsearch.discovery.zen.ping.unicast: [Hellstrom, Damion] failed to send ping 
     to [[#zen_unicast_2#][inet[localhost/127.0.0.1:9301]]]
    org.elasticsearch.transport.ReceiveTimeoutTransportException: []
  [inet[localhost/127.0.0.1:9301]][discovery/zen/unicast] request_id [0] timed out after [3752ms]
    at org.elasticsearch.transport.TransportService$TimeoutHandler.run(TransportService.java:356)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:744)
    log4j, [2014-03-17T14:48:20.197]  WARN: org.elasticsearch.discovery.zen.ping.
    unicast:   [Hellstrom, Damion] failed to send ping to 
    [[#zen_unicast_4#]  [inet[localhost/127.0.0.1:9303]]]
    org.elasticsearch.transport.ReceiveTimeoutTransportException: 
    []                [inet[localhost/127.0.0.1:9303]][discovery/zen/unicast] 
   request_id [3] 
    timed out after [3752ms]
    at org.elasticsearch.transport.TransportService$TimeoutHandler.run(TransportService.java:356)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
    at java.lang.Thread.run(Thread.java:744)
     log4j, [2014-03-17T14:48:20.198]  WARN: org.elasticsearch.discovery.zen.ping.unicast: 
    [Hellstrom, Damion] failed to send ping to 
     [[#zen_unicast_3#]    [inet[localhost/127.0.0.1:9302]]]

请提供帮助，我将不胜感激。我整个周末都在努力让它工作。甚至最初尝试过 Redis，但它有自己的一组错误。

哦，是的，这是我的 conf 文件:

input {
 rabbitmq {
    queue => "input.queue"
    host => "192.xxx.x.xxx"
    exchange => "exchange.output"
    vhost => "myhost"
  }
 }
output {
elasticsearch {
    embedded => true
     index => "board-feed"
}

Answer 1

问题与 RabbitMQ 服务器的身份验证有关。对于 RabbitMQ 传输，用户/密码的默认值是 guest/guest，默认情况下 Rabbit 仅在本地连接(到 127.0.0.1)时有效，而你连接到 192.xxx.x.xxx。 ( https://www.rabbitmq.com/access-control.html )

我的猜测是，当它以前工作时，您是在与 RabbitMQ 相同的机器上运行 Logstash 服务器。

要解决此问题，请在 RabbitMQ 中设置一个帐户并填写 RabbitMQ 输出的用户/密码字段以匹配。