使用Camel、CXF和ProxyBuilder/ProxyHelper调用SOAP-WS

Question

我正在尝试使用apache camel（版本2.14.1）和cxf（版本3.0.3）进行一个简单的（SOAP）webservice调用。

我要调用的远程方法接受一个float并返回一个float：

public float getVolume(float vol) {
    float f = vol * vol;
    return f;
}

我在一位生产工人的帮助下设法把它叫来了。这很好用<现在我想像调用对象的方法一样调用它。为此，我使用的ProxyBuilder如下：

TestService service = new ProxyBuilder(context).endpoint(endpoint).build(TestService.class);  

作为ProxyBuilder的替代，可以使用ProxyHelper，这没有什么区别
我的路线：

String cxfUri = "cxf:http://localhost/9202/testService?serviceClass=" + TestService.class.getName();
from("direct:start").log("${body}").process(new Processor() {

    @Override
    public void process(Exchange e) throws Exception {
        final BeanInvocation bi = e.getIn().getBody(BeanInvocation.class);
        e.getIn().setBody(bi.getArgs());
    }
}).to(cxfUri);

（从这里得到提示：Camel:Bean代理到CXFendpoint）
如果我这样调用该方法：

System.out.println("Volume: " + service.getVolume(42f));

出现以下异常：

org.apache.camel.InvalidPayloadException: No body available of type: float but has value: [1764.0] of type: org.apache.cxf.message.MessageContentsList on: Message: [1764.0]. Caused by: No type converter available to convert from type: org.apache.cxf.message.MessageContentsList to the required type: float with value [1764.0].

如果我的方法返回一个字符串，则一切正常
我读到BeaninJournal中的值必须是可序列化的
这就是问题所在（返回基元类型）<此外，如果服务提供两种方法（第一种返回字符串，第二种返回浮点），它会尝试将浮点转换为字符串
我尝试了不同的cxf版本（2.7.14）、不同的路由，并在路由定义中使用选项，如定义WSDL位置、将模式设置为有效负载、定义默认操作。

我也在网上搜索了几个小时，但没有找到工作提示。

有人能告诉我我做错了什么吗？

编辑：
通过向路由添加第二个处理器解决了第一个问题：

from("direct:start").process(new Processor() {

    @Override
    public void process(Exchange e) throws Exception {
        BeanInvocation bi = e.getIn().getBody(BeanInvocation.class);
        e.getIn().setBody(bi.getArgs());
    }
}).to(cxfUri).process(new Processor() {

    @Override
    public void process(Exchange e) throws Exception {
        MessageContentsList list = e.getIn().getBody(MessageContentsList.class);
        if (list.size() > 0) {
            e.getIn().setBody(list.get(0));
        }
    }
});  

这并没有解决第二个问题：

此外，如果服务提供两个方法（第一个返回字符串，第二个返回浮点），它会尝试将浮点转换为字符串。

发生以下异常：

线程"main"rocessor.java:120中的异常：org.apache.camel.management.Float无法转换为rocessor.java:72WrapperClassOutInterceptor.handle消息（WrapperClassOutInterceptor.java:117）org.apache.cxf.phase.PhaseInterceptorCorg.apache.camel.processor.拦截（PhaseInterceptorCrocessor.process）rocessor.java:191ClientIorg.apache.camel.processor.调用（ClientIipeline.process）在ipeline.java:118ClientImpl.invoke（ClientImpl.java:418）在org.apache.camel.component.cxf.CxfProducer.process（CxfProducer.java:112）在org.apache.camel.processor.SendProcessor.process（SendPorg.apache.cxf.interceptor.）在java.lang.InstrumentationPjava.lang.（InstrumentationPorg.apache.cxf.jaxws.interceptors.）在hain.doCamelInternalPhain.java:307（CamelInternalPorg.apache.cxf.endpoint.）在mpl.doPmpl.java:516（Porg.apache.cxf.endpoint.）在org. apache. camel. Procor. CamelInternalProcessor（CamelInternalProcessor. java： 80）在org. apache. camel.soapTest. client上的$Proxy6. getVolume（未知来源）。TestServiceClientCXF. main（TestServiceClientCXF. java： 49）由：java. lang引起。ClassCastException：java. lang。浮点数无法转换为java. lang。soapTest. service上的字符串。GetName_WrapperTypeHelper1. createWrapperObject（未知来源）在org. apache. cxf. jaxws.拦截器。WrapperClassOutInterceptor. handleMessage（WrapperClassOutInterceptor. java： 101）...21更多

Answer 1

最后，我找到了答案<错误是使用了组织。阿帕奇。骆驼建设者ProxyBuilder
它与cxf不完全兼容
取而代之的是组织。阿帕奇。cxf。常见的util。ProxyHelper必须与自己的调用处理程序一起使用：

final ProducerTemplate template = context.createProducerTemplate();
final Endpoint endpoint = context.getEndpoint("direct:start");

ClassLoader classLoader = context.getApplicationContextClassLoader();
InvocationHandler invocationHandler = new InvocationHandler() {

    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        return template.requestBodyAndHeader(endpoint, args, "operationName", method.getName(), method.getReturnType());
    }
};

TestService service = (TestService) ProxyHelper.getProxy(classLoader, new Class[] {TestService.class}, invocationHandler);    

此外，路由需要一个处理器（如果不返回简单类型，则无法工作）：

from("direct:start").to(cxfUri).process(new Processor() {

    @Override
    public void process(Exchange exchange) throws Exception {
        MessageContentsList list = exchange.getIn().getBody(MessageContentsList.class);
        if (list.size() > 0) {
            exchange.getIn().setBody(list.get(0));
        }
    }
});