java - 如何在本地计算机上启动logback + logstash？

Question

我必须使用 tcp 连接测试 logback + logstash 群上的一些功能。我已经下载了logstash应用程序。配置如下:

input {
tcp {
    port => "4560"
    codec => json_lines
}

} output {
  stdout { codec => rubydebug } 
}

以

开头

.\bin\logstash.bat -f .\config\logstash-tcp.conf

它以消息开头:

[2020-02-18T10:33:23,910][INFO ][logstash.agent           ] Successfully started Logstash API endpoint {:port=>9600}

现在，我的 ide 中有一个 Java 应用程序，该应用程序应该通过 tcp 连接将 logback 信息记录到本地 lockstash 中。我的 logback.xml 文件配置如下:

    <appender name="LOGSTASH_TCP" class="net.logstash.logback.appender.LogstashTcpSocketAppender">
    <destination>127.0.0.1:4560</destination>
    <writeBufferSize>65536</writeBufferSize>
    <ringBufferSize>65536</ringBufferSize>
    <reconnectionDelay>5 second</reconnectionDelay>
    <droppedWarnFrequency>100</droppedWarnFrequency>
    <encoder class="net.logstash.logback.encoder.LogstashEncoder"/>
</appender>

<root level="debug">
    <appender-ref ref="STDOUT" />
    <appender-ref ref="LOGSTASH_TCP"/>
</root>

现在，当我尝试记录一些东西时，在logstash控制台中我看到了这条消息:

[2020-02-18T10:40:23,373][ERROR][logstash.inputs.tcp      ][main] Error in Netty pipeline: java.io.IOException: An existing connection was forcibly closed by the remote host

如果有人可以帮助解决这个问题，我将非常感激。

Answer 1

好的，这不是问题。我的应用程序确实可以正常工作并关闭连接)