Camel CXF：Soap客户端超时

Question

我正在使用Camel CXF端点连接到我的soap服务器。我想为客户端的请求添加超时。我正在使用continuationTimeout选项。但它不起作用。请求超时而不等待我配置的时间。

以下是我的端点配置。

<camel-cxf:cxfEndpoint id="tmAPIWSEndpoint" address="http://IN2NPDCEDB01:8088/webservices/services/TransportationManager"
            wsdlURL="/wsdl/TransportationManager.wsdl"
            endpointName="cis:TransportationManagerPort"
            serviceName="cis:TransportationManagerService"
            xmlns:cis="http://www.i2.com/cis"
            continuationTimeout="60000">
        <camel-cxf:properties>
            <entry key="dataFormat" value="MESSAGE"/>
            <entry key="username" value="XXX"/>
            <entry key="password" value="XXX"/>
        </camel-cxf:properties>
    </camel-cxf:cxfEndpoint>

Answer 1

你的问题不是很清楚，因为没有驼峰路由，所以我不知道你是在Camel中创建一个SOAP服务，还是从Camel调用SOAP服务作为客户端。基于您发送的一点点信息，您似乎正在创建一个客户端。

根据骆驼CXF文档

• continuationTimeout：此选项用于设置CXF服务器使用Jetty或Servlet传输时默认情况下可在CxfConsumer中使用的CXF延续超时。 （在Camel 2.14.0之前，CxfConsumer只是将延续超时设置为0，这意味着延续挂起操作永远不会超时。）

请注意，这与CXF服务器设置而非客户端设置有关。您正在使用此属性，但我不认为这是您正在寻找的。

如果您参考Apache CXF Client Settings Documentation页面，您会在那里找到以下注释：

• ConnectionTimeout：指定客户端在超时之前尝试建立连接的时间量（以毫秒为单位）。默认值为30000（30秒）。 0指定客户端将继续尝试无限期地打开连接。
• ReceiveTimeout：指定客户端在超时之前等待响应的时间量（以毫秒为单位）。默认值为60000. 0指定客户端将无限期地等待。

如果您访问CXF文档页面，那里有很多示例。

Answer 2

以下是以编程方式执行的操作：

HelloWorld hello = (HelloWorld) context.getBean("helloService");
org.apache.cxf.endpoint.Client client = ClientProxy.getClient(hello);
HTTPConduit httpConduit = (HTTPConduit) client.getConduit();
HTTPClientPolicy httpClientPolicy = new HTTPClientPolicy();
httpClientPolicy.setConnectionTimeout(5000);
httpClientPolicy.setAllowChunking(false);
httpClientPolicy.setReceiveTimeout(5000);
httpConduit.setClient(httpClientPolicy);
System.out.println(hello.getHelloWorldAsString("Everyone"));

（我正在使用春天）

<bean id="helloService"
    class="soap.timeout.demo.client.jaxws.HelloWorld"
    factory-bean="helloServiceFactory" factory-method="create"/>
<bean id="helloServiceFactory"
    class="org.apache.cxf.jaxws.JaxWsProxyFactoryBean">
    <property name="serviceClass" value="soap.timeout.demo.client.jaxws.HelloWorld"/>
    <property name="address" value="http://localhost:9999/ws/hello"/>
</bean>