qswsdlhandler.java

Java有关XML编程需要用到axis 的源代码 把里面bin下的包导入相应的Java工程 进行使用

/*
 * Copyright 2001-2004 The Apache Software Foundation.
 * 
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 * 
 *      http://www.apache.org/licenses/LICENSE-2.0
 * 
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.apache.axis.transport.http;

import org.apache.axis.AxisFault;
import org.apache.axis.Constants;
import org.apache.axis.MessageContext;
import org.apache.axis.ConfigurationException;
import org.apache.axis.description.ServiceDesc;
import org.apache.axis.server.AxisServer;
import org.apache.axis.utils.Messages;
import org.apache.axis.utils.XMLUtils;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import org.w3c.dom.Element;

import javax.servlet.http.HttpServletResponse;
import java.io.PrintWriter;
import java.net.HttpURLConnection;
import java.util.Iterator;
import java.util.Set;
import java.util.HashSet;

/**
 * The QSWSDLHandler class is a handler which provides an AXIS service's WSDL
 * document when the query string "wsdl" (ignoring case) is encountered in an
 * AXIS servlet invocation.
 *
 * @author Curtiss Howard (code mostly from AxisServlet class)
 * @author Doug Davis ([e-mail])
 * @author Steve Loughran
 * @author Ian P. Springer, Sal Campana
 */
public class QSWSDLHandler extends AbstractQueryStringHandler {
    /**
     * Performs the action associated with this particular query string handler.
     *
     * @param msgContext a MessageContext object containing message context
     *                   information for this query string handler.
     * @throws AxisFault if an error occurs
     */
    public void invoke(MessageContext msgContext) throws AxisFault {
        // Obtain objects relevant to the task at hand from the provided
        // MessageContext's bag.
        configureFromContext(msgContext);
        AxisServer engine = (AxisServer) msgContext.getProperty
                (HTTPConstants.PLUGIN_ENGINE);
        PrintWriter writer = (PrintWriter) msgContext.getProperty
                (HTTPConstants.PLUGIN_WRITER);
        HttpServletResponse response = (HttpServletResponse)
                msgContext.getProperty(HTTPConstants.MC_HTTP_SERVLETRESPONSE);
        try {
            engine.generateWSDL(msgContext);
            Document wsdlDoc = (Document) msgContext.getProperty("WSDL");
            if (wsdlDoc != null) {
                try {
                    updateSoapAddressLocationURLs(wsdlDoc, msgContext);
                } catch (RuntimeException re) {
                    log.warn(
                            "Failed to update soap:address location URL(s) in WSDL.",
                            re);
                }
                response.setContentType(
                        "text/xml; charset=" +
                        XMLUtils.getEncoding().toLowerCase());
                reportWSDL(wsdlDoc, writer);
            } else {
                if (log.isDebugEnabled()) {
                    log.debug("processWsdlRequest: failed to create WSDL");
                }
                reportNoWSDL(response, writer, "noWSDL02", null);
            }
        } catch (AxisFault axisFault) {
            //the no-service fault is mapped to a no-wsdl error
            if (axisFault.getFaultCode().equals
                    (Constants.QNAME_NO_SERVICE_FAULT_CODE)) {
                //which we log
                processAxisFault(axisFault);

                //then report under a 404 error
                response.setStatus(HttpURLConnection.HTTP_NOT_FOUND);
                reportNoWSDL(response, writer, "noWSDL01", axisFault);
            } else {
                //all other faults get thrown
                throw axisFault;
            }
        }
    }

    /**
     * Report WSDL.
     *
     * @param doc
     * @param writer
     */
    public void reportWSDL(Document doc, PrintWriter writer) {
        XMLUtils.PrettyDocumentToWriter(doc, writer);
    }

    /**
     * Report that we have no WSDL.
     *
     * @param res
     * @param writer
     * @param moreDetailCode optional name of a message to provide more detail
     * @param axisFault      optional fault string, for extra info at debug time only
     */
    public void reportNoWSDL(HttpServletResponse res, PrintWriter writer,
                             String moreDetailCode, AxisFault axisFault) {
        res.setStatus(HttpURLConnection.HTTP_NOT_FOUND);
        res.setContentType("text/html");
        writer.println("<h2>" + Messages.getMessage("error00") + "</h2>");
        writer.println("<p>" + Messages.getMessage("noWSDL00") + "</p>");
        if (moreDetailCode != null) {
            writer.println("<p>" + Messages.getMessage(moreDetailCode)
                    + "</p>");
        }
        if (axisFault != null && isDevelopment()) {
            //only dev systems give fault dumps
            writeFault(writer, axisFault);
        }
    }

    /**
     * Updates the soap:address locations for all ports in the WSDL using the URL from the request as
     * the base portion for the updated locations, ensuring the WSDL returned to the client contains
     * the correct location URL.
     *
     * @param wsdlDoc    the WSDL as a DOM document
     * @param msgContext the current Axis JAX-RPC message context
     * @throws AxisFault if we fail to obtain the list of deployed service names from the server config
     */
    protected void updateSoapAddressLocationURLs(Document wsdlDoc,
                                                 MessageContext msgContext)
            throws AxisFault {
        Set deployedServiceNames;
        try {
            deployedServiceNames = getDeployedServiceNames(msgContext);
        }
        catch (ConfigurationException ce) {
            throw new AxisFault("Failed to determine deployed service names.", ce);
        }
        NodeList wsdlPorts = wsdlDoc.getDocumentElement().getElementsByTagNameNS(Constants.NS_URI_WSDL11, "port");
        if (wsdlPorts != null) {
            String endpointURL = getEndpointURL(msgContext);
            String baseEndpointURL = endpointURL.substring(0, endpointURL.lastIndexOf("/") + 1);
            for (int i = 0; i < wsdlPorts.getLength(); i++) {
                Element portElem = (Element) wsdlPorts.item(i);
                Node portNameAttrib = portElem.getAttributes().getNamedItem("name");
                if (portNameAttrib == null) {
                    continue;
                }
                String portName = portNameAttrib.getNodeValue();
                NodeList soapAddresses = portElem.getElementsByTagNameNS(Constants.URI_WSDL11_SOAP, "address");
                if (soapAddresses == null || soapAddresses.getLength() == 0) {
                    soapAddresses = portElem.getElementsByTagNameNS(Constants.URI_WSDL12_SOAP, "address");
                }
                if (soapAddresses != null) {
                    for (int j = 0; j < soapAddresses.getLength(); j++) {
                        Element addressElem = (Element) soapAddresses.item(j);
                        Node addressLocationAttrib = addressElem.getAttributes().getNamedItem("location");
                        if ( addressLocationAttrib == null )
                        {
                            continue;
                        }
                        String addressLocation = addressLocationAttrib.getNodeValue();
                        String addressServiceName = addressLocation.substring(addressLocation.lastIndexOf("/") + 1);
                        String newServiceName = getNewServiceName(deployedServiceNames, addressServiceName, portName);
                        if (newServiceName != null) {
                            String newAddressLocation = baseEndpointURL + newServiceName;
                            addressLocationAttrib.setNodeValue(newAddressLocation);
                            log.debug("Setting soap:address location values in WSDL for port " +
                                    portName +
                                    " to: " +
                                    newAddressLocation);
                        }
                        else
                        {
                            log.debug("For WSDL port: " + portName + ", unable to match port name or the last component of " +
                                    "the SOAP address url with a " +
                                    "service name deployed in server-config.wsdd.  Leaving SOAP address: " +
                                    addressLocation + " unmodified.");
                        }
                    }
                }
            }
        }
    }

    private String getNewServiceName(Set deployedServiceNames, String currentServiceEndpointName, String portName) {
        String endpointName = null;
        if (deployedServiceNames.contains(currentServiceEndpointName)) {
            endpointName = currentServiceEndpointName;
        }
        else if (deployedServiceNames.contains(portName)) {
            endpointName = portName;
        }
        return endpointName;
    }

    private Set getDeployedServiceNames(MessageContext msgContext) throws ConfigurationException {
        Set serviceNames = new HashSet();
        Iterator deployedServicesIter = msgContext.getAxisEngine().getConfig().getDeployedServices();
        while (deployedServicesIter.hasNext()) {
            ServiceDesc serviceDesc = (ServiceDesc) deployedServicesIter.next();
            serviceNames.add(serviceDesc.getName());
        }
        return serviceNames;
    }

    /**
     * Returns the endpoint URL that should be used in the returned WSDL.
     *
     * @param msgContext the current Axis JAX-RPC message context
     * @return the endpoint URL that should be used in the returned WSDL
     * @throws AxisFault if we fail to obtain the {@link org.apache.axis.description.ServiceDesc} for this service
     */
    protected String getEndpointURL(MessageContext msgContext)
            throws AxisFault {
        // First see if a location URL is explicitly set in the MC.
        String locationUrl = msgContext.getStrProp(
                MessageContext.WSDLGEN_SERV_LOC_URL);
        if (locationUrl == null) {
            // If nothing, try what's explicitly set in the ServiceDesc.
            locationUrl =
                    msgContext.getService().getInitializedServiceDesc(
                            msgContext)
                    .getEndpointURL();
        }
        if (locationUrl == null) {
            // If nothing, use the actual transport URL.
            locationUrl = msgContext.getStrProp(MessageContext.TRANS_URL);
        }
        return locationUrl;
    }
}