Spring Integration：如何截获所有Spring Integration组件并获取属性值到日志

Question

我需要在运行时拦截所有Spring Integration组件，并且应该能够获取属性值，以便记录有意义的消息。例如：

<int-http:outbound-gateway url="someURL" http-method="GET"
                           request-channel="channel1"
                           expected-response-type="com.example.Test"
                           message-converters="customMessageConverters">
    <int-http:uri-variable name="testId" expression="headers.testId"/>
</int-http:outbound-gateway>

在上面的示例中，我需要截获int-http：output-gateway并捕获url、request-channel和expected-response-type的值。我们需要为所有http出站网关这样做。

<int:message-history />
<int:logging-channel-adapter id="logging"
    log-full-message="true" logger-name="message.history" level="DEBUG"/>
    <int:wire-tap pattern="*" order="3" channel="logging" /> 

或

<int:message-history /> 
    <int:logging-channel-adapter id="logger"
    log-full-message="true" logger-name="message.history" level="DEBUG"/>
<int:channel id="wiretapChannel">
    <int:interceptors>
        <int:wire-tap channel="logger"/>
    </int:interceptors>
</int:channel>  

此外，我还试图将LogMessage注入到wire-tap中，以便从MessageHistory数据中执行一些额外的任务。但是控件不进入handleMessage方法。请帮忙。

<bean id="logMessage" class="com.logging.LogMessage"/> 
<int:service-activator input-channel="wiretapChannel" ref="logMessage" method="handleMessage"></int:service-activator>

public class LogMessage {
public void handleMessage(org.springframework.messaging.Message<?> message) throws MessagingException {
MessageHistory history = MessageHistory.read(message);
for (int i = 0; i < history.size(); i++) {
    Properties properties = history.get(i);
    getLogger().info("history: " + properties.get("name"));
}    
}
}

Answer 1

嗯，这不是标准的任务，尤其是对于您想要打印的阅读属性。此外，它们中的许多都是基于SpEL表达式的，实际值取决于请求消息。

虽然有一个组件是非常接近你想要得到的。它被称为消息历史。

您所需要的只是 -所有Spring集成组件都将被跟踪，并将它们存储到messagehistory.header_name中，以显示集成流上消息的整个路径。

<wire-tap channel="logger"/>

<logging-channel-adapter id="logger" log-full-message="true" logger-name="message.history"/>

以截获应用程序中的所有通道并记录消息及其消息历史记录。

您可以为全局 创建自己的POJO订阅服务器( )，并执行一些智能逻辑从消息中提取MessageHistory:MessageHistory.read(Message<？>)。这样的MessageHistory是一个列表 ，实际上您可以在MessageHistory.Entry类中强制转换该属性，并遍历其属性：

    public String getName() {
        return this.getProperty(NAME_PROPERTY);
    }

    public String getType() {
        return this.getProperty(TYPE_PROPERTY);
    }

    public String getTimestamp() {
        return this.getProperty(TIMESTAMP_PROPERTY);
    }

使用名称，您可以转到BeanFactory以获取真正的组件实例，并且已经在那里尝试提取您所需的属性，但同样：并非所有属性都可用，因为...

您还可以参考集成图，了解IntegrationNode实现的可能公共属性。