Spring Integration 日志记录错误 channel (slf4j + logback)

Question

我正在使用 Spring 集成与此配置:

@Bean MessageChannel errorChannel(){
    return new PublishSubscribeChannel();
}

@MessagingGateway(name = "gatewayInbound", 
defaultRequestChannel="farsRequestChannel", errorChannel="errorChannel"){
}

通过此配置，我可以避免显示消息，但我想创建一个基本日志，例如 LOGGER.error()。

此外，我正在与 SLFJ 和 logbak 合作。因此，完美的方案是将此错误消息与我的 logback XML 中的类似配置集成。出于这个原因:

• 我可以使用 logback 来记录 Spring 集成 errorChannel LOGS 吗？
• 我可以显示发送到 errorChannel 的错误吗？

• 我可以在 logback 中使用类似的表达式来个性化此错误吗？如果我使用 LoggingHandler，我会看到完整的堆栈跟踪，并且我想自定义此消息。

  [%-5level] - %d{dd/MM/YYYY HH:mm:ss} - [%file:%line] - %msg%n

Answer 1

@Bean
@ServiceActivator(inputChannel="myErrorChannel")
public MessageHandler myLogger() {
    return new MessageHandler() {

        @Override
        public void handleMessage(Message<?> message) throws MessagingException {
            ErrorMessage em = (ErrorMessage) message;
            String errorMessage = em.getPayload().getMessage();

            // log it

            throw (MessagingException) em.getPayload();
        }
    };
}

如果您不希望传播异常，则可以直接使用它，但需要在网关上设置 defaultReplyTimeout=0 (并且 null 将被退回)。

或

@Bean
@ServiceActivator(inputChannel="myErrorChannel")
public MessageHandler loggingHandler() {
    LoggingHandler loggingHandler = new LoggingHandler("ERROR");
    loggingHandler.setExpression("payload.message");
    return loggingHandler;
}

(在这种情况下错误将被消耗)。