import com.sun.xml.internal.ws.streaming.XMLReaderException; //导入依赖的package包/类
public static XMLStreamReader create(InputSource source, boolean rejectDTDs) {
    try {
        // Char stream available?
        if (source.getCharacterStream() != null) {
            return get().doCreate(source.getSystemId(), source.getCharacterStream(), rejectDTDs);
        }

        // Byte stream available?
        if (source.getByteStream() != null) {
            return get().doCreate(source.getSystemId(), source.getByteStream(), rejectDTDs);
        }

        // Otherwise, open URI
        return get().doCreate(source.getSystemId(), new URL(source.getSystemId()).openStream(),rejectDTDs);
    } catch (IOException e) {
        throw new XMLReaderException("stax.cantCreate",e);
    }
}
 

import com.sun.xml.internal.ws.streaming.XMLReaderException; //导入依赖的package包/类
/**
 * Returns the FI parser allocated for this thread.
 */
public static XMLStreamReader createFIStreamReader(InputStream in) {
    // Check if compatible implementation of FI was found
    if (FastInfosetReflection.fiStAXDocumentParser_new == null) {
        throw new XMLReaderException("fastinfoset.noImplementation");
    }

    try {
        // Do not use StAX pluggable layer for FI
        Object sdp = FastInfosetReflection.fiStAXDocumentParser_new.newInstance();
        FastInfosetReflection.fiStAXDocumentParser_setStringInterning.invoke(sdp, Boolean.TRUE);
        FastInfosetReflection.fiStAXDocumentParser_setInputStream.invoke(sdp, in);
        return (XMLStreamReader) sdp;
    } catch (Exception e) {
        throw new XMLStreamReaderException(e);
    }
}
 

import com.sun.xml.internal.ws.streaming.XMLReaderException; //导入依赖的package包/类
@Override
public XMLStreamReader doCreate(String systemId, InputStream in, boolean rejectDTDs) {
    try {
        return xif.get().createXMLStreamReader(systemId,in);
    } catch (XMLStreamException e) {
        throw new XMLReaderException("stax.cantCreate",e);
    }
}
 

import com.sun.xml.internal.ws.streaming.XMLReaderException; //导入依赖的package包/类
@Override
public synchronized XMLStreamWriter doCreate(OutputStream out, String encoding) {
    try {
        XMLStreamWriter writer = xof.createXMLStreamWriter(out,encoding);
        return new HasEncodingWriter(writer, encoding);
    } catch (XMLStreamException e) {
        throw new XMLReaderException("stax.cantCreate",e);
    }
}
 

import com.sun.xml.internal.ws.streaming.XMLReaderException; //导入依赖的package包/类
private XMLStreamReader doCreate(String systemId, InputStream in, @NotNull String encoding, boolean rejectDTDs) {
    Reader reader;
    try {
        reader = new InputStreamReader(in, encoding);
    } catch(UnsupportedEncodingException ue) {
        throw new XMLReaderException("stax.cantCreate", ue);
    }
    return doCreate(systemId, reader, rejectDTDs);
}