SpringBoot中如何使fluent-logger-java与Logback Appender正常工作？

你遇到的问题很典型：自定义Logback Appender集成fluent-logger-java时抛出NPE，使用第三方的logback-more-appenders又无法发送日志。我帮你一步步排查和解决：

一、自定义Appender触发NPE的核心原因 #

先看你的代码，问题出在这几个地方：

1. 缺少属性Setter方法：Logback通过反射注入Appender的配置属性，你的label等字段是私有且没有public Setter，虽然你给了默认值，但Logback初始化时可能因为反射访问问题埋下隐患；
2. 未处理初始化异常：start()方法里直接调用FluentLogger.log()，如果Fluentd连接失败或初始化异常，fluentLogger可能为null，直接调用log方法就会抛出NPE；
3. 未做空值校验：append()方法里没有检查fluentLogger是否可用，一旦初始化失败就会触发NPE。

二、修复自定义Appender的NPE问题 #

修改你的FluentLogbackAppender代码，完善初始化逻辑和异常处理：

package com.example.demo;

import java.util.HashMap;
import java.util.Map;
import org.fluentd.logger.FluentLogger;
import ch.qos.logback.classic.spi.ILoggingEvent;
import ch.qos.logback.core.UnsynchronizedAppenderBase;

public class FluentLogbackAppender extends UnsynchronizedAppenderBase<ILoggingEvent> {
    private FluentLogger fluentLogger;
    private String label = "test";
    private String host = "localhost";
    private int port = 24224;

    // 为Logback添加属性Setter方法，支持配置注入
    public void setLabel(String label) {
        this.label = label;
    }

    public void setHost(String host) {
        this.host = host;
    }

    public void setPort(int port) {
        this.port = port;
    }

    @Override
    public void start() {
        try {
            super.start();
            this.fluentLogger = FluentLogger.getLogger(label, host, port);
            
            // 发送启动日志时捕获异常，避免初始化崩溃
            Map<String, Object> startupData = new HashMap<>();
            startupData.put("msg", "Fluentd appender started");
            fluentLogger.log(label, startupData);
            addInfo("成功连接Fluentd服务：" + host + ":" + port);
        } catch (Exception e) {
            addError("初始化Fluentd Appender失败", e);
            // 初始化失败时标记Appender为停止状态
            stop();
        }
    }

    @Override
    protected void append(ILoggingEvent rawData) {
        // 先检查Appender是否正常启动，避免NPE
        if (fluentLogger == null || !isStarted()) {
            addWarn("Fluentd Appender未初始化，跳过日志：" + rawData.getMessage());
            return;
        }
        try {
            Map<String, Object> logData = new HashMap<>();
            logData.put("msg", rawData.getMessage());
            logData.put("level", rawData.getLevel().toString());
            logData.put("timestamp", rawData.getTimeStamp());
            fluentLogger.log(label, logData);
        } catch (Exception e) {
            addError("发送日志到Fluentd失败", e);
        }
    }

    @Override
    public void stop() {
        super.stop();
        if (fluentLogger != null) {
            fluentLogger.close();
            addInfo("Fluentd Appender已停止");
        }
    }
}

然后更新logback.xml，添加可配置的属性（可选，但更灵活），同时保留控制台输出方便调试：

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE logback>
<configuration>
    <include resource="org/springframework/boot/logging/logback/base.xml"/>
    <appender name="fluent" class="com.example.demo.FluentLogbackAppender">
        <label>test</label>
        <host>localhost</host>
        <port>24224</port>
    </appender>
    <root level="info" additivity="false">
        <appender-ref ref="CONSOLE" />
        <appender-ref ref="fluent" />
    </root>
</configuration>

三、解决logback-more-appenders无法发送数据的问题 #

如果想用第三方Appender，确保配置正确：

1. 确认依赖版本兼容（Spring Boot 2.x用1.4.x，Spring Boot 3.x用2.x）：

<dependency>
    <groupId>com.sndyuk</groupId>
    <artifactId>logback-more-appenders</artifactId>
    <version>1.4.3</version>
</dependency>
<dependency>
    <groupId>org.fluentd</groupId>
    <artifactId>fluent-logger</artifactId>
    <version>0.3.3</version>
</dependency>

2. 配置logback.xml中的Fluentd Appender：

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE logback>
<configuration>
    <include resource="org/springframework/boot/logging/logback/base.xml"/>
    
    <appender name="FLUENT" class="com.sndyuk.logback.appender.FluentdAppender">
        <tag>test</tag>
        <host>localhost</host>
        <port>24224</port>
        <encoder>
            <pattern>%msg</pattern>
        </encoder>
        <!-- 开启异步发送，避免阻塞业务线程 -->
        <async>true</async>
    </appender>
    
    <root level="info" additivity="false">
        <appender-ref ref="CONSOLE" />
        <appender-ref ref="FLUENT" />
    </root>
</configuration>

四、额外排查技巧 #

如果还是无法发送日志，试试这些步骤：

1. 检查Fluentd配置：确保Fluentd监听0.0.0.0:24224，并且匹配你使用的标签，比如：

   <source>
     @type forward
     port 24224
     bind 0.0.0.0
   </source>
   <match test.**>
     @type stdout
   </match>
   

2. 测试端口连通性：用telnet localhost 24224或nc -zv localhost 24224确认端口可达；
3. 开启Logback调试：在configuration标签添加debug="true"，查看Appender初始化日志；
4. 查看Fluentd日志：检查Fluentd的运行日志，确认是否有连接或日志接收记录。

内容的提问来源于stack exchange，提问作者MrPavanayi