在 http 网关 spring 集成上记录 SOAP 消息

Question

我正在使用 spring 集成 (4.0.6) 使用 int-http:outbound-gateway 和 int-ws:outbound-gateway 从 rest 服务进行 SOAP 调用。有没有办法只在异常情况下记录 SOAP 请求消息。

<int:gateway id="myGateway" service-interface="myservice">
    <int:method name="getData" request-channel="reqChannel" reply-channel="repChannel">
</int-gateway>

我的出站网关配置如下

<int-http:outbound-gateway id="og1" request-channel="reqChannel" url="xxx" http-method="POST" reply-channel="repChannel" reply-timeout="10000" message-converters="converter" request-factory="reqFactory">

<bean id="reqFactory"
     class="org.springframework.http.client.SimpleClientHttpRequestFactory">
    <property name="cTimeout" value="20000"/>
    <property name="rTimeout"    value="20000"/>
</bean>

Answer 1

好的，试试这个方法。 创建您自己的错误处理程序，它实现了 spring 错误处理程序接口。在您的上下文文件中

<bean id="soapErrorHandlingSyncTaskExecutor"
    class="org.springframework.integration.util.ErrorHandlingTaskExecutor">
        <constructor-arg>
            <bean class="org.springframework.core.task.SyncTaskExecutor" />
        </constructor-arg>
        <constructor-arg>
            <bean class="ErrorHandle" 
p:errorSender-ref="errorSender"/>
        </constructor-arg>
    </bean>
<bean id="errorSender" class="org.springframework.integration.core.MessagingTemplate"
        p:defaultChannel-ref="errors" />

当您的 WS 适配器抛出任何异常时，org.springframework.integration.util.ErrorHandlingTaskExecutor 现在会捕获此异常，这取决于您如何在错误处理程序中处理异常。

在 MessagingException 的原因中找到了 SOAP 错误代码和错误字符串（如果是 SoapFaultClientException）。

我在这里将错误消息发送到一个频道供我监控。

希望这会有所帮助。

Answer 2

最好分享一些配置以及您想要获取日志/异常的点。

<int-http:outbound-gateway> 和 <int-ws:outbound-gateway> 都具有 <request-handler-advice-chain> 功能，您可以在其中使用 ExpressionEvaluatingRequestHandlerAdvice 并发送带有请求（有罪？）消息的 ErrorMessage 以进行任何诊断。

您应该在适当的ClientHttpRequestFactory 上配置readTimeout，例如HttpComponentsClientHttpRequestFactory#setReadTimeout(int timeout).

关于转换器以及希望在出现错误时记录其结果...

如何用所需的逻辑实现ClientHttpRequestInterceptor：

try {
   return execution.execute(request, body);
catch (Exception e) {
   this.errorChannel.send(...);
}

我很确定 byte[] body 是您的 SOAP 请求。

有关更多信息，请参阅ClientHttpRequestInterceptorJavaDocs。

ClientHttpRequestInterceptor 是RestTemplate 的一部分，可以注入到http:outbound-gateway。

对于ws:outbound-gateway，您应该使用ClientInterceptor 和handleFault 实现并提取MessageContext.getRequest() 用于您的目的。