import org.apache.cxf.staxutils.DepthXMLStreamReader; //导入依赖的package包/类
/**
 * @param is
 * @throws javax.xml.stream.XMLStreamException
 */
public ElementReader(InputStream is) throws XMLStreamException {
    // XMLInputFactory factory = XMLInputFactory.newInstance();
    // XMLStreamReader xmlReader = factory.createXMLStreamReader(is);
    XMLStreamReader xmlReader = StaxUtils.createXMLStreamReader(is, null);

    xmlReader.nextTag();

    this.root = new DepthXMLStreamReader(xmlReader);
    this.localName = root.getLocalName();
    this.name = root.getName();
    this.namespace = root.getNamespaceURI();

    extractXsiType();

    depth = root.getDepth();
}
 

import org.apache.cxf.staxutils.DepthXMLStreamReader; //导入依赖的package包/类
public void handleMessage(Message message) throws Fault {
    DepthXMLStreamReader xmlReader = getXMLStreamReader(message);
    try {
        // put the payload source as a document
        Document doc = StaxUtils.read(xmlReader);
        message.setContent(Source.class, new DOMSource(doc));
    } catch (XMLStreamException e) {
        throw new Fault(new org.apache.cxf.common.i18n.Message("XMLSTREAM_EXCEPTION", JUL_LOG), e);
    }
}
 

import org.apache.cxf.staxutils.DepthXMLStreamReader; //导入依赖的package包/类
@Override
public Object read(MessagePartInfo msgPartInfo, XMLStreamReader reader) {
    QName msgPartQname = msgPartInfo.getElementQName();

    if (RfdJaxbDataBinding.this.schemaMetadatas.containsKey(msgPartQname.getNamespaceURI())) {
        SdcctXmlStreamReader delegatingReader =
            ((SdcctXmlStreamReader) ((reader instanceof DepthXMLStreamReader) ? ((DepthXMLStreamReader) reader).getReader() : reader));
        ValidatingStreamReader delegateReader = ((ValidatingStreamReader) delegatingReader.getParent());
        XdmDocument msgPartDoc;

        try {
            delegatingReader.setParent(new MessagePartXmlStreamReader(delegateReader, delegatingReader.getLocator(), delegatingReader.getValidator()));

            msgPartDoc = RfdJaxbDataBinding.this.validatorService.validate(delegatingReader);
        } catch (ValidationException e) {
            throw new RfdWsException(
                String.format("Web service request message part (qname=%s, typeClass=%s) is invalid.", msgPartQname, msgPartInfo.getTypeClass()), e);
        } finally {
            delegatingReader.setParent(delegateReader);
        }

        reader = new UnmarshallingXmlStreamReader(msgPartDoc.getUnderlyingNode(), RfdJaxbDataBinding.this.config.makePipelineConfiguration());

        LOGGER.trace(String.format("Web service request message part (qname=%s, typeClass=%s) is valid.", msgPartQname, msgPartInfo.getTypeClass()));
    }

    return super.read(msgPartInfo, reader);
}
 

import org.apache.cxf.staxutils.DepthXMLStreamReader; //导入依赖的package包/类
private void getPara(DepthXMLStreamReader xmlReader,
                     DataReader<XMLStreamReader> dr,
                     MessageContentsList parameters,
                     Iterator<MessagePartInfo> itr,
                     Message message) {
    
    boolean hasNext = true;
    while (itr.hasNext()) {
        MessagePartInfo part = itr.next();
        if (hasNext) {
            hasNext = StaxUtils.toNextElement(xmlReader);
        }
        Object obj = null;
        if (hasNext) {
            QName rname = xmlReader.getName();
            while (part != null 
                && !rname.equals(part.getConcreteName())) {
                if (part.getXmlSchema() instanceof XmlSchemaElement) {
                    //TODO - should check minOccurs=0 and throw validation exception
                    //thing if the part needs to be here
                    parameters.put(part, null);
                } 

                if (itr.hasNext()) {
                    part = itr.next();
                } else {
                    part = null;
                }                
            }
            if (part == null) {
                return;
            }
            if (rname.equals(part.getConcreteName())) {
                obj = dr.read(part, xmlReader);
            }
        }
        parameters.put(part, obj);
    }
}
 

import org.apache.cxf.staxutils.DepthXMLStreamReader; //导入依赖的package包/类
public final void handleMessage(SoapMessage message) {
    String schemaNamespace = "";
    InterceptorChain chain = message.getInterceptorChain();

    // Scan the incoming message for its schema namespace
    try {
        // Create a buffered stream so that we get back the original stream after scanning
        InputStream is = message.getContent(InputStream.class);
        BufferedInputStream bis = new BufferedInputStream(is);
        bis.mark(bis.available());
        message.setContent(InputStream.class, bis);

        String encoding = (String) message.get(Message.ENCODING);
        XMLStreamReader reader = xmlInputFactory.createXMLStreamReader(bis, encoding);
        DepthXMLStreamReader xmlReader = new DepthXMLStreamReader(reader);

        if (xmlReader.nextTag() == XMLStreamConstants.START_ELEMENT) {
            String ns = xmlReader.getNamespaceURI();
            SoapVersion soapVersion = SoapVersionFactory.getInstance().getSoapVersion(ns);
            // Advance just past header
            StaxUtils.toNextTag(xmlReader, soapVersion.getBody());
            // Past body
            xmlReader.nextTag();
        }
        schemaNamespace = xmlReader.getName().getNamespaceURI();
        bis.reset();

    } catch (IOException | XMLStreamException ex) {
        log.error("Exception happened", ex);
    }

    // Init the lookup, when the first message ever arrives
    if (actualServers.isEmpty()) {
        initServerLookupMap(message);
    }

    // We redirect the message to the actual OCPP service
    Server targetServer = actualServers.get(schemaNamespace);

    // Redirect the request
    if (targetServer != null) {
        MessageObserver mo = targetServer.getDestination().getMessageObserver();
        mo.onMessage(message);
    }

    // Now the response has been put in the message, abort the chain
    chain.abort();
}