Logstash/Logback 使用 Spring-引导配置进行设置

Question

我正在尝试在我的 Spring 引导项目中以编程方式设置带有 logback 的 logstash，以便使用环境进行设置。

为此，我使用了一个简单的@Configuration bean（简化代码，然后我将设置 host/port 使用环境）：

@Component
@Slf4j
public class LogstashConfiguration {

    private LogstashTcpSocketAppender logstashTcpSocketAppender;

    @PostConstruct
    public void init() {
        Logger rootLogger = (Logger) LoggerFactory.getLogger(Logger.ROOT_LOGGER_NAME);
        LoggerContext loggerContext = rootLogger.getLoggerContext();
        //loggerContext.reset(); // shouldn't need to use that

        logstashTcpSocketAppender = new LogstashTcpSocketAppender();
        logstashTcpSocketAppender.setName("logstash");
        logstashTcpSocketAppender.setContext(loggerContext);
        logstashTcpSocketAppender.setRemoteHost("localhost");
        logstashTcpSocketAppender.setPort(4560);

        PatternLayoutEncoder encoder = new PatternLayoutEncoder();
        encoder.setContext(loggerContext);
        encoder.start();

        logstashTcpSocketAppender.setEncoder(encoder);
        logstashTcpSocketAppender.start();

        rootLogger.addAppender(logstashTcpSocketAppender);
        rootLogger.setLevel(Level.ALL);
        rootLogger.warn("TEST");

}

我可以看到 TcpSocketAppender 正在登录我的 logstash 服务器，但是我从未收到 TEST 日志。但是我可以在我的控制台中看到 "TEST"。

此外，如果按照 https://github.com/logstash/logstash-logback-encoder#tcp 中所述设置记录器，它也可以工作。

你有什么建议让这项工作成功吗？

谢谢，

面料

Answer 1

实际上 appender 已正确绑定到记录器，但连接到 logstash 失败并出现 SocketException（管道损坏）。

为了解决这个问题，我只需要使用 LogstashEncoder 而不是 PatternLayoutEncoder。

Logstash/Logback 使用 Spring-引导配置进行设置

Logstash/Logback setup using Spring-boot configuration

spring

logging

spring-boot

logstash

logback