java - spring batch 根据批处理 id 记录到不同的日志文件？

Question

我需要将消息记录到不同的日志文件中，这些日志文件应在运行时创建，具体取决于我在启 Action 业时传递给的作业参数。例如 batch_id=2014-07-01 等

我遇到了 https://github.com/dsyer/log4j-utils在测试用例的帮助下，https://github.com/dsyer/log4j-utils/blob/master/src/test/resources/file-dispatcher.xml试图在我的 spring batch admin 项目中配置。下面是配置

<appender name="LOGGER" class="org.springframework.util.log4j.DispatcherAppender">
    <param name="propertyName" value="file" />
    <layout class="org.apache.log4j.PatternLayout">
        <param name="ConversionPattern" value="/var/log/st/batch.log.%x" />
    </layout>
    <appender-ref ref="FILE" />
</appender>

<appender name="FILE" class="org.apache.log4j.FileAppender">
    <param name="file" value="/var/log/st/default.log" />
    <layout class="org.apache.log4j.PatternLayout">
        <param name="ConversionPattern" value="%5p: %m%n" />
    </layout>
</appender>

<root>
    <priority value="info" />
    <appender-ref ref="LOGGER" />
</root

我在类里面使用

import org.apache.commons.lang3.StringUtils;
import org.apache.log4j.Level;
import org.apache.log4j.Logger;
import org.apache.log4j.NDC;

public class MyClass implements MyInterface {

    Logger logger = Logger.getLogger(MyClass.class);

    public void run(final String command, final long timeout) throws Exception {

        NDC.push("2014-07-01");

        logger.info("Running " + command);


    }
}

我正在使用此类在 spring batch 作业中通过 spring batch itemWriter 运行命令。

它不工作，没有创建日志文件，如果我们手动创建并授予完全权限，仍然没有任何内容记录到日志文件。

Answer 1

我目前正在实现您所说的内容，但采用的是不同的方法。我已经定义了一个 JobLoggerGenerator 类，它为每个被调用的类创建一个附加程序:

public static Appender getJobAppender(Class<?> class_) {

    PatternLayout layout = new PatternLayout(
        logProperties.getProperty("log4j.appender.LogFile.layout.ConversionPattern"));

    FileAppender appender = null;
    try {
        // vérifier l'existance du paramétre
        if (UtilBatch.chaineVide(cheminExecutionJob)) {
            throw new IOException("Le chemin de depôt des fichiers est vide");
        }

        // vérifier et créer le dossier des traces
        String cheminDepotFichTraces = UtilBatch.verifierEtCreerChemin(cheminExecutionJob, "log");

        // ajouter le fichier des traces pour ce job
        appender = new FileAppender(layout,
            UtilBatch.creerLien(cheminDepotFichTraces, jobExecutionId + "_log.log"), true);
        appender.setEncoding(logProperties.getProperty("log4j.appender.LogFile.Encoding"));

    } catch (Exception e) {
        Logger mainLog = Logger.getLogger(class_);
        mainLog.error(jobExecutionId, e);
    }

    return appender;
}

然后，例如，在我的服务类中，我将声明一个 Logger 对象，我将对其进行修改:

log.addAppender(JobLoggerGenerator.getJobAppender(TestsServiceImpl.class));

不是微妙的方法是在正确的时间初始化 JobExecutionId。在 Spring-batchs 的情况下，@BeforeStep 在 @Service 类初始化之后被调用，因此带有 @PostConstruct 的 init 方法在这里不起作用。

我要做的是进一步修改 @BeforeStep 方法以 1) 初始化 JobExecutionId，以及 2) 调用我需要在其中记录内容的每个服务或 dao 类，添加一个附加程序到记录器对象。 (基本上我需要为每个服务执行上面的行)..

这对你有帮助吗？