如何在spring集成框架中屏蔽敏感信息

Question

我需要在登录时屏蔽敏感信息。我们使用集成框架提供的wire-tap进行日志记录，我们已经设计了许多接口，这些接口使用wire-tap进行日志记录。我们目前正在使用spring boot 2.1和spring集成。

Answer 1

我不知道这是否是一种花哨的方法，但我最终实现了某种“错误消息过滤器”，以屏蔽存在敏感标题的情况下的标题（这可以扩展到多个标题名称，但这给出了一个想法）：

@Component
public class ErrorMessageFilter {

    private static final String SENSITIVE_HEADER_NAME = "sensitive_header";

    public Throwable filterErrorMessage(Throwable payload) {
        if (payload instanceof MessagingException) {
            Message<?> failedMessage = ((MessagingException) payload).getFailedMessage();
            if (failedMessage != null && failedMessage.getHeaders().containsKey(SENSITIVE_HEADER_NAME)) {
                MessageHeaderAccessor headerAccessor = new MessageHeaderAccessor(failedMessage);
                headerAccessor.setHeader(SENSITIVE_HEADER_NAME, "XXX");
                return new MessagingException(withPayload(failedMessage.getPayload()).setHeaders(headerAccessor)
                        .build());
            }
        }
        return payload;
    }

}

然后，在@Configuration类中，添加了一种将我的过滤器与Spring Integration的LoggingHandler连接起来的方法：

    @Autowired
    public void setLoggingHandlerLogExpression(LoggingHandler loggingHandler, ErrorMessageFilter messageFilter) {
        loggingHandler.setLogExpression(new FunctionExpression<Message<?>>((m) -> {
            if (m instanceof ErrorMessage) {
                return messageFilter.filterErrorMessage(((ErrorMessage) m).getPayload());
            }
            return m.getPayload();
        }));
    }

这也让我能够灵活地在处理错误消息的其他组件中重用我的过滤器（例如：向Zabbix发送错误通知等）。

附言：抱歉所有的实例和ifs，但在某些层脏代码必须开始。

Answer 2

我希望您的所有集成流都能通过所提到的全球单一有线点击记录。

无论如何，这只是另一个集成流的开始：它不仅仅是一个通道和它上的记录器。您真的可以构建任何复杂的有线接入流。

我的观点是，您可以在记录通道适配器之前添加转换器，并以任何需要的方式屏蔽有效负载和/或标题。记录器将接收已屏蔽的数据。

另一种方法是在log-表达式中使用一些掩码功能。您可以在这里调用一些bean进行掩码或静态实用程序：https://docs.spring.io/spring-integration/reference/html/#logging-channel-adapter