我试图了解如何将Apache Camel与提供WSDL的任何Web服务集成以生成其类,然后再调用其方法以返回一些请求.
我已经研究了一下camel-spring-ws和camel-cxf软件包.如我所见,Spring Web Services组件不支持使用WSDL,但CXF支持,但是它仅支持与CXF中托管的JAX-WS服务的连接.
如果我收到客户的WSDL,可以使用CXF吗？还是我需要创建一个自定义组件来使用他的方法？
据我所知,最简单的实现方法是创建一个Process或Bean来调用远程Web服务.
我试图实现一个生产者来调用远程Web服务.我的beans.xml：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:camel="http://camel.apache.org/schema/spring"
xmlns:cxf="http://camel.apache.org/schema/cxf"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd
http://camel.apache.org/schema/cxf http://camel.apache.org/schema/cxf/camel-cxf.xsd">
<import resource="classpath:META-INF/cxf/cxf.xml"/>
<cxf:cxfEndpoint
id="osvEndpoint"
address="http://10.193.1.90:8767/"
serviceClass="siemens_hiq8000.SiemensHiq8000PortType"/>
<bean id="osvWebServiceProcessor" class="br.com.willianantunes.processor.OsvWebServiceProcessor" />
</beans>
我的路线：
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:camel="http://camel.apache.org/schema/spring"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd">
<routeContext id="osvWebServiceInvoke" xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="quartz2://test?cron=0/10+*+*+*+*+?"/>
<process ref="osvWebServiceProcessor" />
<to uri="cxf:bean:osvEndpoint"/>
<to uri="log:live?level=INFO" />
</route>
</routeContext>
</beans>
而我的处理器：
public class OsvWebServiceProcessor implements Processor
{
@Override
public void process(Exchange exchange) throws Exception
{
Message inMessage = exchange.getIn();
// The method to be called
inMessage.setHeader(CxfConstants.OPERATION_NAME, "getVersion");
// Parameters to be passed into the web service
List<Object> params = new ArrayList<Object>();
ResultCodeStructHolder resultCodeStructHolder = new ResultCodeStructHolder();
VersionDataHolder versionDataHolder = new VersionDataHolder();
params.add(resultCodeStructHolder);
params.add(versionDataHolder);
inMessage.setBody(params);
}
}
方法getVersion需要一些参数,如下所示：
public void getVersion(siemens_hiq8000.holders.ResultCodeStructHolder result,
siemens_hiq8000.holders.VersionDataHolder versionData) throws java.rmi.RemoteException;
我怎样才能通过他们？这些持有人必须充满网络服务的响应.当我运行项目时,出现以下错误：
[main] INFO org.apache.cxf.service.factory.ReflectionServiceFactoryBean - Creating Service {http://siemens_hiq8000/}SiemensHiq8000PortType from class siemens_hiq8000.SiemensHiq8000PortType
Exception in thread "main" java.lang.NoSuchMethodError: org.apache.cxf.wsdl11.WSDLEndpointFactory.createEndpointInfo(Lorg/apache/cxf/service/model/ServiceInfo;Lorg/apache/cxf/service/model/BindingInfo;Ljava/util/List;)Lorg/apache/cxf/service/model/EndpointInfo;
at org.apache.cxf.frontend.AbstractWSDLBasedEndpointFactory.createEndpointInfo(AbstractWSDLBasedEndpointFactory.java:287)
at org.apache.cxf.frontend.AbstractWSDLBasedEndpointFactory.createEndpoint(AbstractWSDLBasedEndpointFactory.java:144)
at org.apache.cxf.frontend.ClientFactoryBean.create(ClientFactoryBean.java:91)
at org.apache.camel.component.cxf.CxfSpringEndpoint.createClient(CxfSpringEndpoint.java:116)
at org.apache.camel.component.cxf.CxfProducer.doStart(CxfProducer.java:76)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.impl.DefaultCamelContext.startService(DefaultCamelContext.java:2869)
at org.apache.camel.impl.DefaultCamelContext.doAddService(DefaultCamelContext.java:1097)
at org.apache.camel.impl.DefaultCamelContext.addService(DefaultCamelContext.java:1058)
at org.apache.camel.impl.ProducerCache.doGetProducer(ProducerCache.java:405)
at org.apache.camel.impl.ProducerCache.acquireProducer(ProducerCache.java:123)
at org.apache.camel.processor.SendProcessor.doStart(SendProcessor.java:219)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:79)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
at org.apache.camel.processor.RedeliveryErrorHandler.doStart(RedeliveryErrorHandler.java:1272)
at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:44)
at org.apache.camel.support.ChildServiceSupport.start(ChildServiceSupport.java:31)
at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
at org.apache.camel.processor.interceptor.DefaultChannel.doStart(DefaultChannel.java:153)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:61)
at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
at org.apache.camel.processor.MulticastProcessor.doStart(MulticastProcessor.java:1060)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:59)
at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:103)
at org.apache.camel.util.ServiceHelper.startServices(ServiceHelper.java:89)
at org.apache.camel.processor.DelegateAsyncProcessor.doStart(DelegateAsyncProcessor.java:79)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.util.ServiceHelper.startService(ServiceHelper.java:74)
at org.apache.camel.impl.RouteService.startChildService(RouteService.java:340)
at org.apache.camel.impl.RouteService.warmUp(RouteService.java:182)
at org.apache.camel.impl.DefaultCamelContext.doWarmUpRoutes(DefaultCamelContext.java:3090)
at org.apache.camel.impl.DefaultCamelContext.safelyStartRouteServices(DefaultCamelContext.java:3020)
at org.apache.camel.impl.DefaultCamelContext.doStartOrResumeRoutes(DefaultCamelContext.java:2797)
at org.apache.camel.impl.DefaultCamelContext.doStartCamel(DefaultCamelContext.java:2653)
at org.apache.camel.impl.DefaultCamelContext.access$000(DefaultCamelContext.java:167)
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2467)
at org.apache.camel.impl.DefaultCamelContext$2.call(DefaultCamelContext.java:2463)
at org.apache.camel.impl.DefaultCamelContext.doWithDefinedClassLoader(DefaultCamelContext.java:2486)
at org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:2463)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:2432)
at org.apache.camel.spring.SpringCamelContext.maybeStart(SpringCamelContext.java:255)
at org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:121)
at org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:332)
at org.springframework.context.event.SimpleApplicationEventMulticaster.invokeListener(SimpleApplicationEventMulticaster.java:151)
at org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:128)
at org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:331)
at org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:773)
at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:483)
at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:139)
at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:93)
at org.apache.camel.spring.Main.createDefaultApplicationContext(Main.java:216)
at org.apache.camel.spring.Main.doStart(Main.java:156)
at org.apache.camel.support.ServiceSupport.start(ServiceSupport.java:61)
at org.apache.camel.main.MainSupport.run(MainSupport.java:150)
at br.com.willianantunes.test.Program.main(Program.java:12)
解
对于那些想要camel-cxf像生产者一样工作的人,请按照下面的步骤作为示例：
>首先,我在此developer page中下载可用于OpenScape Voice here的最后一个WSDL文件.
>必须使用客户端代码,才能在选项serviceClass中通知SEI(服务端点接口).您可以生成以下命令：
wsdl2java -client -d“ TargetFolderHere” -autoNameResolution“ OpenScape-Voice_V8.00.28.01.wsdl”
>将生成的客户端类插入项目中. WSDL文件也是如此.
>在beans.xml中通知cxfEndpoint配置.
<import resource="classpath:META-INF/cxf/cxf.xml" />
<cxf:cxfEndpoint xmlns:urn="urn:openscape-voice"
id="osvEndpoint"
address="http://10.193.1.90:8767/"
serviceClass="voice.openscape.OpenscapeVoicePortType"
wsdlURL="OpenScape-Voice_V8.00.28.01.wsdl"
serviceName="urn:openscape_voice">
</cxf:cxfEndpoint>
<bean id="osvWebServiceProcessor" class="br.com.willianantunes.processor.OsvWebServiceProcessor" />
>在调用Web服务之前,请配置处理器以通知参数和要执行的方法.
Message inMessage = exchange.getIn();
// The method to be called
inMessage.setHeader(CxfConstants.OPERATION_NAME, "GetVersion");
// Parameters to be passed into the web service
List<Object> params = new ArrayList<Object>();
Holder<ResultCodeStruct> result = new Holder<>();
Holder<VersionData> versionData = new Holder<>();
params.add(result);
params.add(versionData);
inMessage.setBody(params);
>现在,您可以配置路由并插入camelContext作为完成任务的参考.
<routeContext id="osvWebServiceInvoke" xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="quartz2://test?cron=0/10+*+*+*+*+?"/>
<process ref="osvWebServiceProcessor"/>
<to uri="cxf:bean:osvEndpoint"/>
<to uri="log:live?level=INFO"/>
</route>
</routeContext>
日志显示以下内容：
- Quartz scheduler 'DefaultQuartzScheduler-main-application' initialized from an externally provided properties instance.
- Quartz scheduler version: 2.2.1
- Job Camel_main-application.test (triggerType=CronTriggerImpl, jobClass=CamelJob) is scheduled. Next fire date is Tue Mar 31 09:12:00 BRT 2015
- AllowUseOriginalMessage is enabled. If access to the original message is not needed, then its recommended to turn this option off as it may improve performance.
- StreamCaching is not in use. If using streams then its recommended to enable stream caching. See more details at http://camel.apache.org/stream-caching.html
- Creating Service {urn:openscape-voice}openscape_voice from WSDL: OpenScape-Voice_V8.00.28.01.wsdl
- Could not find endpoint/port for {urn:openscape-voice}openscape_voicePortTypePort in wsdl. Using {urn:openscape-voice}openscape_voice.
- Route: route1 started and consuming from: Endpoint[quartz2://test?cron=0%2F10+*+*+*+*+%3F]
- Starting scheduler.
- Scheduler DefaultQuartzScheduler-main-application_$_NON_CLUSTERED started.
- Total 1 routes, of which 1 is started.
- Apache Camel 2.15.0 (CamelContext: main-application) started in 10.759 seconds
- Exchange[ExchangePattern: InOnly, BodyType: org.apache.cxf.message.MessageContentsList, Body: [null, javax.xml.ws.Holder@508696f5, javax.xml.ws.Holder@333cf1ba]]
我对CXF依赖项有一些问题,所以这是我的pom.xml：
<dependency>
<groupId>org.apache.camel</groupId>
<artifactId>camel-cxf</artifactId>
<version>${camel-version}</version>
</dependency>
<!-- Apache CXF -->
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-frontend-jaxws</artifactId>
<version>${cxf.version}</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-frontend-jaxrs</artifactId>
<version>${cxf.version}</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-transports-http</artifactId>
<version>${cxf.version}</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-transports-http-jetty</artifactId>
<version>${cxf.version}</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-bindings-soap</artifactId>
<version>${cxf.version}</version>
</dependency>
<dependency>
<groupId>javax.ws.rs</groupId>
<artifactId>jsr311-api</artifactId>
<version>1.1.1</version>
</dependency>
<!-- End of Apache CXF -->
您可以设计一个新的处理器或bean,以从Web服务获取带有响应的主体消息(不是纯SOAP消息,而是以前使用的POJO).
@Namphibian提供的答案还可以,也可以满足我的目的.
解决方法:
您指的是合同优先或自上而下的Web服务开发.用这种方法,您可以从WSDL定义中生成存根代码,并在开发中使用这些类等.我已经做了很多工作,并且使用了.NET,Java,PHP甚至是Delphi中创建的服务中的WSDL(尽管Delphi违反了WSI规范甚至都没有做到).
CXF几乎可以从您指向该库的任何WSDL生成类.首先,您需要向Maven POM文件添加一个条目,该条目告诉Maven为您从WSDL生成类.
将以下内容添加到您的POM文件中：
<plugin>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-codegen-plugin</artifactId>
<version>get the latest version or the version you want</version>
<executions>
<execution>
<id>generate-sources</id>
<phase>generate-sources</phase>
<configuration>
<sourceRoot>
${basedir}/target/generated/src/main/java
</sourceRoot>
<wsdlOptions>
<wsdlOption>
<wsdl>
URI/FILE PATH OF WSDL HERE
</wsdl>
<extraargs>
<extraarg>-impl</extraarg> <-- use this if you want to implement the service i.e. create it
<extraarg>-client</extraarg> <-- us this if you want to generate a client for the service.
</extraargs>
</wsdlOption>
</wsdlOptions>
</configuration>
<goals>
<goal>wsdl2java</goal>
</goals>
</execution>
</executions>
</plugin>
现在,您可以运行目标mvn generate-source来生成使用此文件所需的存根类.
我通常会进入处理器/ bean中进行实际的实现,因为我生产和/或使用的大多数Web服务都具有相当复杂的数据结构.但是,这实际上取决于服务.
因此,简而言之,您可以使用CXF为几乎(Web服务的Delphi家伙)生成存根类,然后在处理器中使用这些生成的类来实现客户端和/或服务器.
更新：
根据上面的示例,您处于正确的轨道.首先,我只想讨论关于骆驼中CXF的一些重要概念. CXF Bean与其他Bean稍有不同,例如,当您看到以下代码时：
<from uri="file://....."/>
<to uri="mock"/>
文件组件是生产者,它毕竟会产生文件,而模拟组件是使用者,因为它接收文件组件产生的数据并将其消耗以完成其任务.
Web服务稍微扭曲了这个概念.当您有以下路线时：
cxf bean称为生产器,因为它调用Web服务.当您将cxf bean用作使用者或在< from>中使用时,它会变得很有趣.您路线的一部分.
这是一个Web服务使用者的示例：
<from uri="cxf:bean:someService" />
CXF bean正在使用Web服务调用,然后将消息发送到其他各个部分.这使您可以暴露一些非常复杂的内容,例如从FTP服务器下载文件,通过JDBC调用将内容丰富到其中,然后将所丰富的数据作为Web服务针对SAP系统进行处理.您的路线在< from>中公开了cxf bean.作为服务,路由的其余部分可以完成所有集成,但它作为Web服务公开.非常强大的概念.
在您的情况下,您的Web服务Bean是生产者或客户.我通常不将cxf Bean用于客户端,因为我消耗的服务可能相当复杂,并且我需要Java的全部功能来处理这些情况.因此,我将向您展示如何执行此操作.
因此,在我的世界中,我会选择以下骆驼路线：
<routeContext id="osvWebServiceInvoke" xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="quartz2://test?cron=0/10+*+*+*+*+?"/>
<process ref="osvWebServiceProcessor" />
<to uri="log:live?level=INFO" />
</route>
</routeContext>
我的处理器bean将更改为：
public class OsvWebServiceProcessor implements Processor
{
@Override
public void process(Exchange exchange) throws Exception
{
Message inMessage = exchange.getIn();
/*
SInce i dont have access to the WSDL and XSD I cant say how the following code will look but essentially you would need to call the web-service here in Java code and get the result back.
*/
outSOAPMsg= siemens_hiq8000.SiemensHiq8000PortType.OperationName(inSOAPMsg)
//set the reply into the inbody and send onto other components for processing.
inMessage.setBody(outSOAPMsg);
}
}
查看您的代码,我意识到您的存根类似乎没有正确生成.我强烈建议您将帖子中描述的项目添加到您的POM文件中.如果您可以发布一些WSDL和XSD文件,我可以为您提供更多描述性的答案.