Ordinary hut
          
			人間一福地，勝似天仙宮
		          		
	
          

          

          

          

          posts - 61, comments - 50, trackbacks - 0, articles - 1
          


          		
	
          
	
          
		
			
		
		
			
          
				
					
	
          
		
          
			
          
				Camel與cxf
			
          
 			Posted on 2011-09-29 13:50 landor 閱讀(2342) 評論(2)  編輯  收藏  所屬分類: camel 
			
			


		
          
		
          camel是一個路由選擇引擎，具體內(nèi)容可見
          http://camel.apache.org
          還有一本camel in action，對camel核心進行了詳細講解；

          這是一個簡單的例子，接收一個webservice消息，并且通過camel把消息路由給一個bean；
          需要一些jar包：
           
          apache-cxf-2.3.3\lib\cxf-2.3.3.jar
          apache          -cxf-2.3.3\lib\XmlSchema-1.4.7.jar
          apache          -cxf-2.3.3\lib\neethi-2.0.4.jar
          apache          -cxf-2.3.3\lib\wss4j-1.5.11.jar
          apache          -cxf-2.3.3\lib\wsdl4j-1.6.2.jar
          apache          -cxf-2.3.3\lib\geronimo-servlet_3.0_spec-1.0.jar
          apache          -cxf-2.3.3\lib\jsr311-api-1.1.1.jar
          apache          -cxf-2.3.3\lib\jetty-continuation-7.2.2.v20101205.jar
          apache          -cxf-2.3.3\lib\jetty-http-7.2.2.v20101205.jar
          apache          -cxf-2.3.3\lib\jetty-server-7.2.2.v20101205.jar
          apache          -cxf-2.3.3\lib\jetty-util-7.2.2.v20101205.jar
          apache          -cxf-2.3.3\lib\jetty-io-7.2.2.v20101205.jar
          apache          -camel-2.7.1\lib\spring\spring-beans-3.0.5.RELEASE.jar
          apache          -camel-2.7.1\lib\spring\spring-context-3.0.5.RELEASE.jar
          apache          -camel-2.7.1\lib\spring\spring-context-support-3.0.5.RELEASE.jar
          apache          -camel-2.7.1\lib\spring\spring-core-3.0.5.RELEASE.jar
          apache          -camel-2.7.1\lib\spring\spring-expression-3.0.5.RELEASE.jar
          apache          -camel-2.7.1\lib\spring\spring-tx-3.0.5.RELEASE.jar
          apache          -camel-2.7.1\lib\spring\aopalliance-1.0.jar
          apache          -camel-2.7.1\lib\spring\commons-logging-1.1.1.jar
          apache          -camel-2.7.1\lib\spring\spring-aop-3.0.5.RELEASE.jar
          apache          -camel-2.7.1\lib\spring\spring-asm-3.0.5.RELEASE.jar
          apache          -camel-2.7.1\lib\slf4j-api-1.6.1.jar
          apache          -camel-2.7.1\lib\camel-core-2.7.1.jar
          apache          -camel-2.7.1\lib\commons-management-1.0.jar
          apache          -camel-2.7.1\lib\camel-cxf-2.7.1.jar
          apache          -camel-2.7.1\lib\camel-spring-2.7.1.jar
           

          1 新建bean：
              
          package bean;
          public class Usr {
                        public String test(String str){
                  System.out.println(          "Hello Bean    "+str);
                            return "Hello Bean    "+str;
              }
          }
           

          2 再新建一個webservice接口文件：
          package server;
          import javax.jws.WebService;
          @WebService
          public interface IHello {
              String sayHi(String name);
          }

          3 需要建立spring配置文件，放在classpath下
          配置文件有兩個用途：
              用cxf發(fā)布一個webservice；
              配置camel的route
          <beans xmlns="http://www.springframework.org/schema/beans"
              xmlns:xsi          ="http://www.w3.org/2001/XMLSchema-instance" 
              xmlns:cxf          ="http://camel.apache.org/schema/cxf"
              xmlns:camel          ="http://camel.apache.org/schema/spring"
              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" />
                        <import resource="classpath:META-INF/cxf/cxf-extension-soap.xml" />
                        <import resource="classpath:META-INF/cxf/cxf-extension-http-jetty.xml" />
              
                        <!--發(fā)布一個webservice-->
                        <cxf:cxfEndpoint id="orderEndpoint"
                           address          ="http://localhost:9000/helloWorld"
                           serviceClass          ="server.IHello"
                                     />
              
                        <bean id="usr" class="bean.Usr"></bean>
                  
                        <camelContext xmlns="http://camel.apache.org/schema/spring">
                            <route>
                                <from uri="cxf:bean:orderEndpoint"/>
                                <bean ref="usr" method="test"/>
                            </route>
                        </camelContext>
          </beans>

          4 啟動camel：

          package camel;
          import org.apache.camel.spring.Main;
          public class Helloworld {
                        public static void main(String[] args) throws Throwable {
                  Main main           = new Main();
                  main.start();
                  Thread.sleep(          600000);
                  main.stop();
              }
          }

          5 寫個webservice客戶端測試一下：
          package client;
          import java.net.URL;
          import javax.xml.namespace.QName;
          import javax.xml.ws.Service;
          import server.IHello;
          public class Test {
                        public static void main(String[] args) throws Throwable{
                  URL wsdlURL           = new URL("http://localhost:9000/helloWorld?wsdl");//WSDL文件地址
                  QName SERVICE_NAME           = new QName("http://server/", "IHelloService");//參數(shù)一是WSDL中的
targetNamespace，參數(shù)2是WSDL中的
name 節(jié)點
                  Service service = Service.create(wsdlURL, SERVICE_NAME);
                  IHello client           = service.getPort(IHello.class);
                  String result           = client.sayHi("bbb");
                  System.out.println(result);
              }
          }

          得到的結(jié)果應(yīng)該是：
          Hello Bean    bbb

          
	
          


          
	    
    

          Feedback
          
	
			
          
				
          
					
          
						# re: Camel與cxf  回復(fù)  更多評論
						  
					
          
					2012-06-10 20:17 by jdkleo
				
          
				
          我的client代碼：
          public class CamelCxfClient {
              public static void main(String[] args) throws Throwable{
                  URL wsdlURL = new URL("http://localhost:8080/camel_ws/webservice/helloWorld?wsdl");
          //        QName SERVICE_NAME = new QName("http://www.springframework.org/schema/beans", "helloWorld");

                  QName SERVICE_NAME = new QName("http://www.springframework.org/schema/beans", "helloWorld");
                  Service service = Service.create(wsdlURL, SERVICE_NAME);
                  IHelloWorld client = service.getPort(IHelloWorld.class);
                  String result = client.sayHi("bbb");
                  System.out.println(result);
              }
          }
          我跑后變成這樣：
          Exception in thread "main" javax.xml.ws.soap.SOAPFaultException: org.apache.cxf.message.Exchange.getBindingOperationInfo()Lorg/apache/cxf/service/model/BindingOperationInfo;
          	at org.apache.cxf.jaxws.JaxWsClientProxy.invoke(JaxWsClientProxy.java:143)
          	at $Proxy35.sayHi(Unknown Source)
          	at camel.ws.CamelCxfClient.main(CamelCxfClient.java:13)
          Caused by: org.apache.cxf.binding.soap.SoapFault: org.apache.cxf.message.Exchange.getBindingOperationInfo()Lorg/apache/cxf/service/model/BindingOperationInfo;
          	at org.apache.cxf.binding.soap.interceptor.Soap11FaultInInterceptor.unmarshalFault(Soap11FaultInInterceptor.java:75)
          	at org.apache.cxf.binding.soap.interceptor.Soap11FaultInInterceptor.handleMessage(Soap11FaultInInterceptor.java:46)
          	at org.apache.cxf.binding.soap.interceptor.Soap11FaultInInterceptor.handleMessage(Soap11FaultInInterceptor.java:35)
          	at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:236)
          	at org.apache.cxf.interceptor.AbstractFaultChainInitiatorObserver.onMessage(AbstractFaultChainInitiatorObserver.java:96)
          	at org.apache.cxf.binding.soap.interceptor.CheckFaultInterceptor.handleMessage(CheckFaultInterceptor.java:69)
          	at org.apache.cxf.binding.soap.interceptor.CheckFaultInterceptor.handleMessage(CheckFaultInterceptor.java:34)
          	at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:236)
          	at org.apache.cxf.endpoint.ClientImpl.onMessage(ClientImpl.java:658)
          	at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.handleResponseInternal(HTTPConduit.java:2139)
          	at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.handleResponse(HTTPConduit.java:2022)
          	at org.apache.cxf.transport.http.HTTPConduit$WrappedOutputStream.close(HTTPConduit.java:1947)
          	at org.apache.cxf.transport.AbstractConduit.close(AbstractConduit.java:66)
          	at org.apache.cxf.transport.http.HTTPConduit.close(HTTPConduit.java:632)
          	at org.apache.cxf.interceptor.MessageSenderInterceptor$MessageSenderEndingInterceptor.handleMessage(MessageSenderInterceptor.java:62)
          	at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:236)
          	at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:472)
          	at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:302)
          	at org.apache.cxf.endpoint.ClientImpl.invoke(ClientImpl.java:254)
          	at org.apache.cxf.frontend.ClientProxy.invokeSync(ClientProxy.java:73)
          	at org.apache.cxf.jaxws.JaxWsClientProxy.invoke(JaxWsClientProxy.java:123)
          	... 2 more
          
			
          
		
			
          
				
          
					
          
						# re: Camel與cxf  回復(fù)  更多評論
						  
					
          
					2012-06-10 20:30 by jdkleo
				
          
				
          i am so sorry that i find
          in my pom.xml 
          the <cxf.version>2.2.3</cxf.version>
          that must be changed to 
          <cxf.version>2.3.3</cxf.version>
          oh fuck
          
			
          
		




          





          


          

	
          
		
          
				
		
	
		
          
		
		
          只有注冊用戶登錄后才能發(fā)表評論。
          
		
          
			
		
          
			
		
          
		
		
          
		


          

		          		
		
          
		
          			
		
		
		
		
          
		
          
		
		
          
		
          
			網(wǎng)站導(dǎo)航:
		
		
          
		
          
			
		
          	
		
          
			 
		
          
		
          
			
		
          
		
          
			
				
		
          		
	
          	

          



          

				
			
          
		          		
	
          
	
          
		
			

		
	
          

          


    







          
        
	




主站蜘蛛池模板：
万荣县|
成都市|
安阳县|
两当县|
西安市|
张北县|
房山区|
新干县|
务川|
玉田县|
万安县|
天长市|
曲阜市|
山东|
宣武区|
彝良县|
普洱|
屏东县|
独山县|
晋城|
朝阳区|
琼中|
云龙县|
青州市|
德令哈市|
长治市|
三穗县|
鄱阳县|
嘉义县|
上蔡县|
东乡族自治县|
搜索|
宁安市|
大邑县|
贵德县|
澳门|
吕梁市|
施甸县|
三江|
安远县|
新蔡县|