Вызов службы SOAP асинхронно с использованием Spring

Question

Я должен вызывать веб-сервис SOAP асинхронно. В настоящее время я называю это синхронно, используя Spring webservicetemplate.

Текущий конфиг похож на:

    <bean id="interceptedHttpClientBuilder" class="org.springframework.beans.factory.config.MethodInvokingFactoryBean">
        <property name="targetObject" ref="httpClientBuilder" />
        <property name="targetMethod" value="addInterceptorFirst"> </property>
        <property name="arguments">
            <list>
                <bean class="org.springframework.ws.transport.http.HttpComponentsMessageSender.RemoveSoapHeadersInterceptor"/>
            </list>
        </property>
    </bean>

    <bean id="requestConfigBuilder" class="org.apache.http.client.config.RequestConfig" factory-method="custom">
        <property name="socketTimeout" value="120000" />
    </bean>

    <bean id="requestConfig" factory-bean="requestConfigBuilder" factory-method="build" />
    <bean id="httpClient" factory-bean="httpClientBuilder" factory-method="build" />

    <bean id="httpClientBuilder" class="org.apache.http.impl.client.HttpClientBuilder" factory-method="create">
        <property name="defaultRequestConfig" ref="requestConfig" />
    </bean>

    <bean id="messageSender" class="org.springframework.ws.transport.http.HttpComponentsMessageSender">
        <constructor-arg ref="httpClient"></constructor-arg>
    </bean>

    <bean id="jaxb2Marshaller" class="org.springframework.oxm.jaxb.Jaxb2Marshaller">
        <property name="packagesToScan">
            <list><value>...</value></list>
        </property>
    </bean>

    <bean id="wsClientSecurityInterceptor"  
        class="org.springframework.ws.soap.security.wss4j.Wss4jSecurityInterceptor">  
        <property name="securementActions" value="UsernameToken" />  
        <property name="securementUsername"><value>${username}</value></property>  
        <property name="securementPassword"><value>${password}</value></property>
        <property name="securementPasswordType" value="PasswordText" />
    </bean>

    <bean id="webServiceTemplate" class="org.springframework.ws.client.core.WebServiceTemplate">
        <property name="marshaller" ref="jaxb2Marshaller"></property>
        <property name="unmarshaller" ref="jaxb2Marshaller"></property>
        <property name="defaultUri"><value>${ws.url}</value></property>
        <property name="interceptors">  
            <list>  
                <ref local="wsClientSecurityInterceptor"/>  
            </list>  
        </property>
        <property name="messageSender" ref="messageSender"></property>
    </bean>

Java-вызов выглядит так:

MyResponse response = (MyResponse) webServiceTemplate.marshalSendAndReceive(req, new WebServiceMessageCallback() {
                        public void doWithMessage(WebServiceMessage message) {
                        ((SoapMessage) message).setSoapAction("test");
                        }
                    });

Могу ли я узнать, как изменить его так, чтобы он вызывал службу асинхронно? Или мне нужно использовать что-то еще весной, чтобы добиться этого?

Answer 1

Не уверен, почему вы используете spring-integration тег в вашем вопросе, но если мы здесь, пожалуйста, обязательно посмотрите в @MessagingGateway с Future<> в качестве типа возврата: https://docs.spring.io/spring-integration/docs/5.0.1.RELEASE/reference/html/messaging-endpoints-chapter.html

SOAP WebService может быть вызван через Spring Integration <int-ws:outbound-gateway>: https://docs.spring.io/spring-integration/docs/5.0.1.RELEASE/reference/html/ws.html

Примеры здесь: https://github.com/spring-projects/spring-integration-samples

Чтобы быть более понятным, код может выглядеть так:

<int:gateway id="mathService" 
             service-interface="org.springframework.integration.samples.async.gateway.MathServiceGateway"
             default-request-channel="requestChannel"
             async-executor="executor"/>

Где это MathServiceGateway это так:

public interface MathServiceGateway {

    Future<Integer> multiplyByTwo(int i);
}

Вызов WS также прост:

<int-ws:outbound-gateway request-channel="requestChannel" uri="http://www.w3schools.com/xml/tempconvert.asmx"/>