`
113.com
  • 浏览: 81142 次
  • 来自: 广州
社区版块
存档分类
最新评论

cxf源码

 
阅读更多
 package org.apache.cxf.phase.PhaseInterceptorChain
  public synchronized boolean doIntercept(Message message) {
  //循环遍历执行拦截器handleMessage(message);
  while (state == State.EXECUTING && iterator.hasNext()) {
                try {
                    Interceptor<Message> currentInterceptor = (Interceptor<Message>)iterator.next();
                    if (isFineLogging) {
                        LOG.fine("Invoking handleMessage on interceptor " + currentInterceptor);
                    }
                    //System.out.println("-----------" + currentInterceptor);
					
                    currentInterceptor.handleMessage(message);
                    if (state == State.SUSPENDED) {
                         // throw the exception to make sure thread exit without interrupt
                        throw new SuspendedInvocationException();
                    }
                    
                } catch (SuspendedInvocationException ex) {
                    // we need to resume from the same interceptor the exception got originated from
                    if (iterator.hasPrevious()) {
                        iterator.previous();
                    }
                    pause();
                    throw ex;
                } catch (RuntimeException ex) {
				.................
                } 
            }
      return state == State.COMPLETE;
} finally {
     CURRENT_MESSAGE.set(oldMessage);
}
}





package org.apache.cxf.jaxrs.interceptor.JAXRSInInterceptor;
public void handleMessage(Message message) {
        //message=org.apache.cxf.message.XMLMessage@9c494f43
        try {
            processRequest(message);
        } catch (RuntimeException ex) {
           ..
        }
    }
    
	
package org.apache.cxf.jaxrs.interceptor.JAXRSInInterceptor;
private void processRequest(Message message) {
      ....................
	   OperationResourceInfo ori = null;   
	  ...........
	     MultivaluedMap<String, String> values = new MetadataMap<String, String>();
	  ....................
	   //Process parameters
        try {
		   //解析请求方法的参数列表。
           List<Object> params = JAXRSUtils.processParameters(ori, values, message);
            message.setContent(List.class, params);
        } catch (Exception ex) {
          ..............
        }


    //Message contains following information: PATH, HTTP_REQUEST_METHOD, CONTENT_TYPE, InputStream.
	package org.apache.cxf.jaxrs.utils.JAXRSUtils;
    public static List<Object> processParameters(OperationResourceInfo ori, 
                                                 MultivaluedMap<String, String> values, 
                                                 Message message)
        throws IOException, WebApplicationException {
        
        //得到 请求处理的方法public com.ym.box.data.ReturnData //com.ym.box.LogBoxResource.mobileLog(com.ym.box.data.LogBoxRequest)
        Method method = ori.getMethodToInvoke();
		//得到请求方法参数类型[class com.ym.box.data.LogBoxRequest]
        Class<?>[] parameterTypes = method.getParameterTypes();
        Parameter[] paramsInfo = ori.getParameters().toArray(new Parameter[]{});  
        Method annotatedMethod = ori.getAnnotatedMethod();
        Type[] genericParameterTypes = annotatedMethod == null ? method.getGenericParameterTypes() 
                                      : annotatedMethod.getGenericParameterTypes();
        Annotation[][] anns = annotatedMethod == null ? null : annotatedMethod.getParameterAnnotations();
        List<Object> params = new ArrayList<Object>(parameterTypes.length);
         //循环解析请求方法参数,并得到装配完成的参数对象。
        for (int i = 0; i < parameterTypes.length; i++) {
            Class<?> param = parameterTypes[i]; 
            Type genericParam = genericParameterTypes[i];
            if (genericParam instanceof TypeVariable) {
                genericParam = InjectionUtils.getSuperType(ori.getClassResourceInfo().getServiceClass(), 
                                                           (TypeVariable<?>)genericParam);
            }
            if (param == Object.class) {
                param = (Class<?>)genericParam; 
            } else if (genericParam == Object.class) {
                genericParam = param;
            }
            
            
            Object paramValue = processParameter(param, 
                                                 genericParam,
                                                 anns == null ? new Annotation[0] : anns[i],
                                                 paramsInfo[i], 
                                                 values, 
                                                 message,
                                                 ori);
            params.add(paramValue);
        }

        return params;
    }


     package org.apache.cxf.jaxrs.utils.JAXRSUtils;
     private static Object processParameter(Class<?> parameterClass, 
                                           Type parameterType,
                                           Annotation[] parameterAnns,
                                           Parameter parameter, 
                                           MultivaluedMap<String, String> values,
                                           Message message,
                                           OperationResourceInfo ori) 
        throws IOException, WebApplicationException {
        InputStream is = message.getContent(InputStream.class);

        if (parameter.getType() == ParameterType.REQUEST_BODY) {
            
            String contentType = (String)message.get(Message.CONTENT_TYPE);

            if (contentType == null) {
                org.apache.cxf.common.i18n.Message errorMsg = 
                    new org.apache.cxf.common.i18n.Message("NO_CONTENT_TYPE_SPECIFIED", 
                                                           BUNDLE, 
                                                           ori.getHttpMethod());
                LOG.fine(errorMsg.toString());
                contentType = MediaType.WILDCARD;
            }

            return readFromMessageBody(parameterClass,
                                       parameterType,
                                       parameterAnns,
                                       is, 
                                       MediaType.valueOf(contentType),
                                       ori.getConsumeTypes(),
                                       message);
        } else if (parameter.getType() == ParameterType.CONTEXT) {
            return createContextValue(message, parameterType, parameterClass);
        } else {
            
            return createHttpParameterValue(parameter,
                                            parameterClass,
                                            parameterType,
                                            parameterAnns,
                                            message,
                                            values,
                                            ori);
        }
    }












package org.apache.cxf.jaxrs.utils.JAXRSUtils;
private static <T> T readFromMessageBody(Class<T> targetTypeClass,
                                                  Type parameterType,
                                                  Annotation[] parameterAnnotations,
                                                  InputStream is, 
                                                  MediaType contentType, 
                                                  List<MediaType> consumeTypes,
                                                  Message m) throws IOException, WebApplicationException {
        
		//根据请求的contentType 如application/json,application/xml
        List<MediaType> types = JAXRSUtils.intersectMimeTypes(consumeTypes, contentType);
        
        MessageBodyReader<T> provider = null;
        for (MediaType type : types) { 
		     //选择相应的内容解释器,
			 //CXF通过JSonProvider对JSon提供支持,默认的Provider采用jettsion进行编码或解码。
			 //可以配置在xml文件里 <jaxrs:providers><ref bean="jsonProvider" /></jaxrs:providers>
	    
            provider = ProviderFactory.getInstance(m)
                .createMessageBodyReader(targetTypeClass,
                                         parameterType,
                                         parameterAnnotations,
                                         type,
                                         m);
            if (provider != null) {
                try {
                    HttpHeaders headers = new HttpHeadersImpl(m);
                    return provider.readFrom(
                              targetTypeClass, parameterType, parameterAnnotations, contentType,
                              headers.getRequestHeaders(), is);
                } catch (Exception e) {
                    throw e;
                }
            } else {
                  .............
                throw new WebApplicationException(Response.Status.UNSUPPORTED_MEDIA_TYPE);
            }
        }

        return null;
    }
	
	
	//以下是请求的contentType =application/json,我们选择JSONProvider对JSon提供支持的解析方法readFrom
	package org.apache.cxf.jaxrs.provider.json.JSONProvider
	  public T readFrom(Class<T> type, Type genericType, Annotation[] anns, MediaType mt, 
        MultivaluedMap<String, String> headers, InputStream is) throws IOException {
        //type是用户要解析成的类型,如type=class com.ym.box.data.LogBoxRequest
		//genericType是用户要解析成的类型的泛型,没有则为本身。如 class com.ym.box.data.LogBoxRequest
		//mt为contentType =application/json的封装
		//header 为请求头 如{Accept=[application/json], accept-encoding=[UTF-8], cache-control=[no-cache], //connection=[keep-alive], content-encoding=[utf-8], Content-Length=[655], content-type=[application/json], //host=[localhost:8080], pragma=[no-cache], user-agent=[Apache CXF 2.6.1]}
		/**is为输入流,当使用POST请求时,is封装的是请求数据部分,如{"boxId":1000,"boxMobileLogs":[{"appId":111,"createTime":"2014-01-15 15:22:20","installTime":"2014-01-15 15:22:20","packageName":"com.snda.youni"},{"appId":112,"createTime":"2014-01-15 17:22:20","installTime":"2014-01-15 16:22:20","packageName":"com.snda.youni"},{"appId":113,"createTime":"2014-01-15 18:22:20","installTime":"2014-01-15 16:22:20","packageName":"com.snda.youni"}],"ccId":22222,"channelId":10000,"city":"市","fatherChannelId":10000000,"imei":"imei","imsi":"imsi地址","mac":"mac地址","phoneModel":"model","phoneNum":"13760730495","phoneVendor":"MOTO","productCode":"BK","province":"省","statType":4,"totalCnt":3,"versionName":"v12123"}**/
		
        try {
            InputStream realStream = getInputStream(type, genericType, is);
            if (Document.class.isAssignableFrom(type)) {
                W3CDOMStreamWriter writer = new W3CDOMStreamWriter();
                copyReaderToWriter(createReader(type, realStream, false), writer);
                return type.cast(writer.getDocument());
            }
			
            boolean isCollection = InjectionUtils.isSupportedCollectionOrArray(type);
            Class<?> theGenericType = isCollection ? InjectionUtils.getActualType(genericType) : type;
            Class<?> theType = getActualType(theGenericType, genericType, anns);
            ////原来通过使用JSONProvider提供json支持的话,它走的流程是json-->xml-->object,如果你使用过的JSONProvider的话,
			//也许你会对type=class com.ym.box.data.LogBoxRequest有过为了在XML和对象间进行映射的配置,如使用@XmlRootElement,
			//网上有讨论如果使用JacksonJaxbJsonProvider对json的支持的话,效率会比JSONProvider高,后期会分析他们的原因。
            Unmarshaller unmarshaller = createUnmarshaller(theType, genericType, isCollection);
            XMLStreamReader xsr = createReader(type, realStream, isCollection);
            
            Object response = null;
            if (JAXBElement.class.isAssignableFrom(type) 
                || unmarshalAsJaxbElement
                || jaxbElementClassMap != null && jaxbElementClassMap.containsKey(theType.getName())) {
                response = unmarshaller.unmarshal(xsr, theType);
            } else {
			    //这个时候,对象com.ym.box.data.LogBoxRequest@bf470d已经解析,装配完成。
                response = unmarshaller.unmarshal(xsr);
            }
            if (response instanceof JAXBElement && !JAXBElement.class.isAssignableFrom(type)) {
                response = ((JAXBElement<?>)response).getValue();    
            }
            if (isCollection) {
                response = ((CollectionWrapper)response).getCollectionOrArray(theType, type, 
                               org.apache.cxf.jaxrs.utils.JAXBUtils.getAdapter(theGenericType, anns)); 
            } else {
                response = checkAdapter(response, type, anns, false);
            }
			//进行类型转换object->T,然后返回
            return type.cast(response);
            
        } catch (Exception e) {
            ....
        } 
        // unreachable
        return null;
    }
	
	
	
	
	
	
	//========================================================================================
	//如果使用com.fasterxml.jackson.jaxrs.json.JacksonJaxbJsonProvider对json的支持的话,对json的解析交给了JacksonJsonProvider
	    /**
     * Method that JAX-RS container calls to deserialize given value.
     */
    public Object readFrom(Class<Object> type, Type genericType, Annotation[] annotations, MediaType mediaType, MultivaluedMap<String,String> httpHeaders, InputStream entityStream) 
        throws IOException
    {

        AnnotationBundleKey key = new AnnotationBundleKey(annotations);
        EndpointConfig endpoint;
        synchronized (_readers) {
            endpoint = _readers.get(key);
        }
        // not yet resolved (or not cached any more)? Resolve!
        if (endpoint == null) {
            ObjectMapper mapper = locateMapper(type, mediaType);
            endpoint = EndpointConfig.forReading(mapper, annotations);
            // and cache for future reuse
            synchronized (_readers) {
                _readers.put(key.immutableKey(), endpoint);
            }
        }
        ObjectReader reader = endpoint.getReader();
        
        JsonParser jp = reader.getJsonFactory().createJsonParser(entityStream);
        if (jp.nextToken() == null) {
           return null;
        }
		//解析json,转换形式为json->object
        return reader.withType(genericType).readValue(jp);
    }

	
	
	
	
	
	
	
	
	

 

分享到:
评论

相关推荐

    CXF源码:CXF_Spring源码

    【CXF源码分析】 Apache CXF 是一个开源的Java框架,主要用于构建和服务导向架构(SOA)的应用程序。它提供了多种方式来实现Web服务,包括基于Java API for Web Services (JAX-WS) 和 Java API for RESTful Web ...

    cxf 源码包

    总之,Apache CXF源码包为开发者提供了一扇窗,可以深入研究Web服务的实现细节,理解其工作原理,并根据需要进行定制。如果你对Web服务、SOA或分布式系统有浓厚兴趣,那么这个源码包无疑是一个宝贵的教育资源。

    cxf 源码 java websevice

    ”这个主题中,我们将深入探讨Apache CXF 2.2.5版本的源码,这对于Java Web服务开发人员来说是一个宝贵的资源。 Apache CXF的核心功能包括: 1. **SOAP与RESTful服务**:CXF支持两种主流的Web服务风格,即SOAP...

    CXF源码及其lib包

    Apache CXF是一个开源的服务框架,它允许开发人员创建和消费Web服务。CXF结合了XFire和 Celtix两个项目的最佳特性,提供了丰富的API和工具,支持多种协议和标准,如SOAP、RESTful、XML和Java EE。这个压缩包包含的是...

    验证客户端源码cxf

    **标题:“验证客户端源码CXF”** **正文:** CXF(Camel XFire)是一个开源服务框架,它允许开发人员创建和部署基于Java API for Web Services (JAX-WS) 和Java API for RESTful Web Services (JAX-RS) 的Web服务...

    cxf源代码,样例,cxfdemo

    【标题】"cxf源代码,样例,cxfdemo" 涉及的主要知识点是Apache CXF框架的使用,特别是其在服务端开发中的应用。Apache CXF是一个开源的Java框架,它允许开发者创建和消费各种Web服务,包括SOAP和RESTful服务。CXF...

    CXF 案例源码

    【CXF案例源码】详解 CXF,全称Celtix XFire,是一个开源的Java框架,主要用于构建和开发Web服务。它提供了强大的SOAP和RESTful服务支持,是Java世界中广泛使用的Web服务框架之一。CXF允许开发者用他们熟悉的编程...

    cxf源码包-2.0.9版本

    CXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXF

    WebService发布框架CXF的源码

    **WebService发布框架CXF源码解析** Apache CXF是一个开源的Web服务框架,它使得开发者能够轻松地创建和部署高质量的、与标准兼容的Web服务。CXF支持多种Web服务规范,包括SOAP、WSDL、WS-Security等,以及RESTful...

    java的webService源码(使用cxf)

    【Java WebService 源码使用 CXF 框架详解】 Java WebService 是一种基于标准的、平台无关的通信方式,它允许不同系统间的应用程序通过网络交换数据。CXF 是一个开源的 Java 库,它提供了创建和消费 WebService 的...

    cxf与spring整合源码,包括客户端和服务端

    针对目前网上的很多cxf相关的服务开发源码不能使用,自己做的cxf与spring的整合,里面包含了服务端和客户端代码,还有说明文档,这个demo使用的是cxf的服务端,axis2的客户端,希望能够帮到cxf初学者们。

    apache-cxf-2.1.jar包及src源码

    开发者可以查看源码,了解CXF如何处理Web服务请求,如何解析和生成SOAP消息,以及如何实现各种Web服务标准。此外,源码对于自定义或扩展CXF的行为也是至关重要的。 CXF的2.1版本在当时是一个稳定的版本,提供了许多...

    cxf2.5源码

    CXF 是一个开源的 Services 框架,CXF 帮助您利用 Frontend 编程 API 来构建和开发 Services ,像 JAX-WS 。这些 Services 可以支持多种协议,比如:SOAP、XML/HTTP、RESTful HTTP 或者 CORBA ,并且可以在多种传输...

    CXF实例源代码(客户端)

    Apache CXF是一个开源的Java框架,它主要用于构建和开发服务导向架构(SOA)和Web服务。这个"CXF实例源代码(客户端)"压缩包提供了客户端调用Web服务的示例代码,对于初学者来说,是理解如何使用CXF进行Web服务交互...

    java cxf 源码

    Java CXF 是一个开源的服务框架,它允许开发者创建和消费Web服务。CXF使得构建和部署Web服务变得简单,同时也支持...通过对源码的深度学习,我们可以更好地掌握CXF框架,从而在实际项目中更高效地使用和扩展其功能。

    CXF实现WebService详解实例

    Apache CXF是一个开源的Java框架,专门用于构建和消费Web服务。本篇文章将详细探讨如何使用CXF实现WebService,并通过实例进行深入解析。 **一、CXF简介** Apache CXF是一个强大的开源工具,它提供了多种方式来创建...

    实现CXF框架源代码

    在本文中,我们将深入探讨如何使用Apache CXF框架与Java代码来实现Web服务。CXF是一个流行的开源项目,它提供了一种简单的方式来创建和消费Web服务。通过CXF,开发者可以利用SOAP或RESTful风格来构建服务,同时支持...

    CXF实例源代码(服务器端)

    【CXF实例源代码(服务器端)】是一个用于学习和实践Apache CXF框架的入门教程,专注于构建Web服务。Apache CXF是一个开源的Java框架,主要用于创建和消费Web服务,它支持多种协议和标准,如SOAP、RESTful、WS-*等。...

    使用CXF实现WebService(源代码+jar包+文档说明讲解)

    使用CXF实现WebService 资料中附有源代码+jar包+文档说明讲解 &lt;!--导入CXF的xml --&gt; &lt;import resource="classpath:META-INF/cxf/cxf.xml" /&gt; &lt;import resource="classpath:META-INF/cxf/cxf-extension-soap.xml" ...

    CXF soap例子源码

    在这个"CXF soap例子源码"中,我们可以深入理解如何使用CXF框架来实现基于SOAP的Web服务。 首先,SOAP是一种基于XML的协议,允许应用程序通过HTTP或其他传输协议进行通信。在CXF中,你可以使用Java API for RESTful...

Global site tag (gtag.js) - Google Analytics