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源码分析】 Apache CXF 是一个开源的Java框架,主要用于构建和服务导向架构(SOA)的应用程序。它提供了多种方式来实现Web服务,包括基于Java API for Web Services (JAX-WS) 和 Java API for RESTful Web ...
总之,Apache CXF源码包为开发者提供了一扇窗,可以深入研究Web服务的实现细节,理解其工作原理,并根据需要进行定制。如果你对Web服务、SOA或分布式系统有浓厚兴趣,那么这个源码包无疑是一个宝贵的教育资源。
”这个主题中,我们将深入探讨Apache CXF 2.2.5版本的源码,这对于Java Web服务开发人员来说是一个宝贵的资源。 Apache CXF的核心功能包括: 1. **SOAP与RESTful服务**:CXF支持两种主流的Web服务风格,即SOAP...
Apache CXF是一个开源的服务框架,它允许开发人员创建和消费Web服务。CXF结合了XFire和 Celtix两个项目的最佳特性,提供了丰富的API和工具,支持多种协议和标准,如SOAP、RESTful、XML和Java EE。这个压缩包包含的是...
**标题:“验证客户端源码CXF”** **正文:** CXF(Camel XFire)是一个开源服务框架,它允许开发人员创建和部署基于Java API for Web Services (JAX-WS) 和Java API for RESTful Web Services (JAX-RS) 的Web服务...
【标题】"cxf源代码,样例,cxfdemo" 涉及的主要知识点是Apache CXF框架的使用,特别是其在服务端开发中的应用。Apache CXF是一个开源的Java框架,它允许开发者创建和消费各种Web服务,包括SOAP和RESTful服务。CXF...
【CXF案例源码】详解 CXF,全称Celtix XFire,是一个开源的Java框架,主要用于构建和开发Web服务。它提供了强大的SOAP和RESTful服务支持,是Java世界中广泛使用的Web服务框架之一。CXF允许开发者用他们熟悉的编程...
CXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXFCXF
**WebService发布框架CXF源码解析** Apache CXF是一个开源的Web服务框架,它使得开发者能够轻松地创建和部署高质量的、与标准兼容的Web服务。CXF支持多种Web服务规范,包括SOAP、WSDL、WS-Security等,以及RESTful...
【Java WebService 源码使用 CXF 框架详解】 Java WebService 是一种基于标准的、平台无关的通信方式,它允许不同系统间的应用程序通过网络交换数据。CXF 是一个开源的 Java 库,它提供了创建和消费 WebService 的...
针对目前网上的很多cxf相关的服务开发源码不能使用,自己做的cxf与spring的整合,里面包含了服务端和客户端代码,还有说明文档,这个demo使用的是cxf的服务端,axis2的客户端,希望能够帮到cxf初学者们。
开发者可以查看源码,了解CXF如何处理Web服务请求,如何解析和生成SOAP消息,以及如何实现各种Web服务标准。此外,源码对于自定义或扩展CXF的行为也是至关重要的。 CXF的2.1版本在当时是一个稳定的版本,提供了许多...
CXF 是一个开源的 Services 框架,CXF 帮助您利用 Frontend 编程 API 来构建和开发 Services ,像 JAX-WS 。这些 Services 可以支持多种协议,比如:SOAP、XML/HTTP、RESTful HTTP 或者 CORBA ,并且可以在多种传输...
Apache CXF是一个开源的Java框架,它主要用于构建和开发服务导向架构(SOA)和Web服务。这个"CXF实例源代码(客户端)"压缩包提供了客户端调用Web服务的示例代码,对于初学者来说,是理解如何使用CXF进行Web服务交互...
Java CXF 是一个开源的服务框架,它允许开发者创建和消费Web服务。CXF使得构建和部署Web服务变得简单,同时也支持...通过对源码的深度学习,我们可以更好地掌握CXF框架,从而在实际项目中更高效地使用和扩展其功能。
Apache CXF是一个开源的Java框架,专门用于构建和消费Web服务。本篇文章将详细探讨如何使用CXF实现WebService,并通过实例进行深入解析。 **一、CXF简介** Apache CXF是一个强大的开源工具,它提供了多种方式来创建...
在本文中,我们将深入探讨如何使用Apache CXF框架与Java代码来实现Web服务。CXF是一个流行的开源项目,它提供了一种简单的方式来创建和消费Web服务。通过CXF,开发者可以利用SOAP或RESTful风格来构建服务,同时支持...
【CXF实例源代码(服务器端)】是一个用于学习和实践Apache CXF框架的入门教程,专注于构建Web服务。Apache CXF是一个开源的Java框架,主要用于创建和消费Web服务,它支持多种协议和标准,如SOAP、RESTful、WS-*等。...
使用CXF实现WebService 资料中附有源代码+jar包+文档说明讲解 <!--导入CXF的xml --> <import resource="classpath:META-INF/cxf/cxf.xml" /> <import resource="classpath:META-INF/cxf/cxf-extension-soap.xml" ...
在这个"CXF soap例子源码"中,我们可以深入理解如何使用CXF框架来实现基于SOAP的Web服务。 首先,SOAP是一种基于XML的协议,允许应用程序通过HTTP或其他传输协议进行通信。在CXF中,你可以使用Java API for RESTful...