", new Object[] {e.getMessage()})); throw new ServletException(e); } out.print("</HTML>"); out.close(); } private void dumpMessage(MessageTrace message, PrintWriter out) throws Exception { /*String xsl = "<?xml version=\"1.0\"?>"+ "<xsl:stylesheet xmlns:xsl=\"http://www.w3.org/1999/XSL/Transform\" version=\"1.0\">"+ "<xsl:template match=\"/\">" + "<xsl:for-each select=\"*\">" + "<<xsl:value-of select=\".\"/>>" + "</xsl:for-each>" + "</xsl:template>" + "</xsl:stylesheet>";*/ // now transform it... ByteArrayInputStream bais = new ByteArrayInputStream(message.getMessage(true).getBytes()); StreamSource ss = new StreamSource(bais); ByteArrayOutputStream baos = new ByteArrayOutputStream(); StreamResult sr = new StreamResult(baos); TransformerFactory factory = TransformerFactory.newInstance(); Transformer transformer = factory.newTransformer(); transformer.setOutputProperty(OutputKeys.METHOD, "xml"); transformer.setOutputProperty(OutputKeys.INDENT, "yes"); transformer.setOutputProperty("{http://xml.apache.org/xslt}indent-amount", "4"); transformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8"); transformer.transform(ss, sr); out.print("<HR>
");
String value = baos.toString();
value = value.replaceAll("<", "<");
value = value.replaceAll(">", ">");
out.write(value);
out.print("</pre>"); } private MessageTrace request = null; private MessageTrace response = null; public void invocationProcessed(MessageTrace request, MessageTrace response) { this.request = request; this.response = response; } private Object convertWebParam(Class targetParamType, String webValue) { Object convertedValue = null; if (webValue==null || webValue.length()==0) { return null; } if (String.class.equals(targetParamType)) { convertedValue = webValue; } else { try { if (int.class.equals(targetParamType) || Integer.class.equals(targetParamType)) { convertedValue = new Integer(webValue); } if (boolean.class.equals(targetParamType) || Boolean.class.equals(targetParamType)) { convertedValue = new Boolean(webValue); } if (char.class.equals(targetParamType) || (Character.class.equals(targetParamType))) { convertedValue = new Character(webValue.charAt(0)); } if (long.class.equals(targetParamType) || (Long.class.equals(targetParamType))) { convertedValue = new Long(webValue); } if (float.class.equals(targetParamType) || (Float.class.equals(targetParamType))) { convertedValue = new Float(webValue); } if (double.class.equals(targetParamType) || (Double.class.equals(targetParamType))) { convertedValue = new Double(webValue); } if (byte.class.equals(targetParamType) || (Byte.class.equals(targetParamType))) { convertedValue = new Byte(webValue); } if (short.class.equals(targetParamType) || (Short.class.equals(targetParamType))) { convertedValue = new Short(webValue); } if (StringBuffer.class.equals(targetParamType)) { convertedValue = new StringBuffer(webValue); } } catch(NumberFormatException nfe) { System.out.println("Cannot convert " + webValue + " in " + targetParamType); } } return convertedValue; } private void classNotAccessibleError(ClassLoader cl, String className, PrintWriter out) { out.print(localStrings.getLocalString( "enterprise.webservice.monitoring.CNFTitle", "<HTML>
"); out.print(localStrings.getLocalString( "enterprise.webservice.monitoring.TesterNSdetail", "Please note that the tester feature is supported for JAXWS based webservices only")); out.print("</BODY>"); out.print("</HTML>"); out.close(); } private void wsImportError(URL wsdlUrl, PrintWriter out) { out.print(localStrings.getLocalString( "enterprise.webservice.monitoring.WsImportError", "<HTML>
"); out.print(localStrings.getLocalString( "enterprise.webservice.monitoring.WsImportError3", "Possible causes can be" + "invoking https when the application is not configured for security", new Object[] {wsdlUrl})); out.print("</BODY>"); out.print("</HTML>"); out.close(); } private void initializePort(HttpServletRequest req,HttpServletResponse res) throws ServletException, IOException { String requestURL = req.getRequestURL().toString(); Endpoint myEndpoint; if(svcEP.implementedByWebComponent()) { myEndpoint = WebServiceEngineImpl.getInstance().getEndpoint(req.getServletPath()); } else { myEndpoint = WebServiceEngineImpl.getInstance().getEndpoint(req.getRequestURI()); } // get our service qname QName serviceName = new QName(myEndpoint.getDescriptor().getWsdlPort().getNamespaceURI(), myEndpoint.getDescriptor().getWebService().getName()); // construct the WSDL http url StringBuffer sb = new StringBuffer(URLDecoder.decode(requestURL)); sb.append("?WSDL"); URL[] urls = new URL[1]; String classesDir; try { URL wsdlUrl = new URL(sb.toString()); // create client artifacts classesDir = wsImport(wsdlUrl); if (classesDir == null) { wsImportError(wsdlUrl,res.getWriter()); return; } urls[0] = (new File(classesDir)).toURL(); } catch(MalformedURLException mue) { throw new ServletException(mue); } // we need a class loader to load the just created client artifacts. Save the current classloader ClassLoader currentLoader = Thread.currentThread().getContextClassLoader(); // we now create a new classloader using the parent class loader // which should be the shared application classloader. I don't want // the application class loader to not get into client/server // classes clashes. // the immediate classloader is the WebApp classloader, its parent is the // application classloader, we want the parent of that one ClassLoader testerCL = new URLClassLoader(urls, currentLoader.getParent()); try { Thread.currentThread().setContextClassLoader(testerCL); String serviceClassName = getServiceClass( JAXBRIContext.mangleNameToClassName(serviceName.getLocalPart()), classesDir); if (serviceClassName==null) { throw new RuntimeException("Service Class not generated as expected"); } Class serviceClass = testerCL.loadClass(serviceClassName); Service service = Service.create(new URL(sb.toString()), serviceName); if (service==null) { throw new RuntimeException("Cannot load Service"); } // find the right port... for this look at the @WebService annotation in SEI and get the portName String portClassName = getPortClass(myEndpoint, serviceClass); if (portClassName==null) { throw new RuntimeException("Cannot find the correct port class."); } Class portClass = testerCL.loadClass(portClassName); Object port = service.getPort(myEndpoint.getDescriptor().getWsdlPort(), portClass); if (port==null) { throw new RuntimeException("Cannot find the correct port class."); } if (port!=null) { ports.put(requestURL, port); gsiClasses.put(requestURL, portClass); } } catch(Exception e) { throw new ServletException(e); } finally { // restore the class loader Thread.currentThread().setContextClassLoader(currentLoader); // delete client artifacts, everything should be loaded or it failed deleteDir(new File(classesDir)); } } private String wsImport(URL wsdlLocation) throws IOException { File classesDir = new File(System.getProperty("java.io.tmpdir")); /** * JAXWS uses the System.getProperty(java.class.path) to pass on to apt during wsgen * In V2 this would have * tools.jar, webservices-rt and webservices-api.jar and webservices-tools.jar so there was no issue * In V3 the apt cannot see JSR 250, JAXB api and JAXWS apis so I have to pass them * explicitly to apt using the classpath option * This will be changed after prelude once I move to asm as it is not thoroughly tested right now */ WebServiceContractImpl wscImpl = WebServiceContractImpl.getInstance(); ModulesRegistry modulesRegistry = wscImpl.getModulesRegistry(); Collection<Module> modules1 = modulesRegistry.getModules(); Iterator it= modules1.iterator(); String classpath1 = classesDir.getAbsolutePath(); while(it.hasNext()){ Module m = (Module) it.next(); String name = m.getName(); if (name.equals("com.sun.xml.ws") || name.equals("com.sun.xml.bind") ){ ModuleDefinition modDef= m.getModuleDefinition(); java.net.URI[] location = modDef.getLocations(); classpath1+=(File.pathSeparator + new File(location[0]).getAbsolutePath()) ; } } System.setProperty("java.class.path",classpath1); // create a dumy file to have a unique temporary name for a directory classesDir = File.createTempFile("jax-ws", "tester", classesDir); classesDir.delete(); classesDir.mkdirs(); String[] wsimportArgs = new String[7]; wsimportArgs[0]="-d"; wsimportArgs[1]=classesDir.getAbsolutePath(); wsimportArgs[2]="-keep"; wsimportArgs[3]=wsdlLocation.toExternalForm(); wsimportArgs[4]="-Xendorsed"; wsimportArgs[5]="-target"; wsimportArgs[6]="2.1"; WSToolsObjectFactory tools = WSToolsObjectFactory.newInstance(); boolean success = tools.wsimport(System.out, wsimportArgs); if (logger!=null) { logger.log(Level.INFO, "Invoking wsimport with " + wsdlLocation); } else { System.out.println("Invoking wsimport with " + wsdlLocation); } if (success) { if (logger!=null) logger.log(Level.INFO, "wsimport successful"); } else { if (logger!=null) logger.log(Level.SEVERE, "wsimport failed"); return null; } return classesDir.getAbsolutePath(); } private String getServiceClass(String serviceClassName, String classesDirPath) { //wsimport generated Service Class always is serviceQName.getLocalPart()+".class" // So just look for this class and return that class File classesDir = new File(classesDirPath); if (!classesDir.exists()) { return null; } File[] classes = getListOfFiles(classesDir).toArray(new File[0]); String resolvedServiceClass = null; String svcClass = null; for (File f : classes) { if (f.getName().endsWith(serviceClassName+"_Service.class")){ resolvedServiceClass = f.getAbsolutePath().substring(classesDirPath.length()+1); } else { if (f.getName().endsWith(serviceClassName+".class")){ svcClass = f.getAbsolutePath().substring(classesDirPath.length()+1); } } } //Incase there is a clash JAXWS resolves the serviceClass //to serviceName_Service.class Use the first if it is present //Fix for issue 3403 if ( resolvedServiceClass != null){ svcClass = resolvedServiceClass; } if (svcClass != null) { svcClass = svcClass.substring(0, svcClass.indexOf(".class")); return svcClass.replaceAll("\\"+File.separator,"."); } else { return null; } } private String getPortClass(Endpoint ep, Class serviceClass) throws Exception { String pkg = serviceClass.getPackage().getName(); for(Method m : serviceClass.getMethods()) { WebEndpoint webEP = (WebEndpoint) m.getAnnotation(WebEndpoint.class); if(webEP == null || webEP.name() == null || webEP.name().length() == 0) { continue; } String getPortMethodName = "get" + JAXBRIContext.mangleNameToClassName(webEP.name()); Method getPortMethod = serviceClass.getMethod(getPortMethodName, (Class[])null); return getPortMethod.getReturnType().getName(); } return null; } private List<File> getListOfFiles(File path) { File[] files = path.listFiles(); List<File> result = new ArrayList
Other Glassfish examples (source code examples)
Here is a short list of links related to this Glassfish WebServiceTesterServlet.java source code file:
The search page
Other Glassfish source code examples at this package level
Click here to learn more about this project
Glassfish example source code file (WebServiceTesterServlet.java)
The Glassfish WebServiceTesterServlet.java source code/*
* DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
*
* Copyright (c) 1997-2010 Oracle and/or its affiliates. All rights reserved.
*
* The contents of this file are subject to the terms of either the GNU
* General Public License Version 2 only ("GPL") or the Common Development
* and Distribution License("CDDL") (collectively, the "License"). You
* may not use this file except in compliance with the License. You can
* obtain a copy of the License at
* https://glassfish.dev.java.net/public/CDDL+GPL_1_1.html
* or packager/legal/LICENSE.txt. See the License for the specific
* language governing permissions and limitations under the License.
*
* When distributing the software, include this License Header Notice in each
* file and include the License file at packager/legal/LICENSE.txt.
*
* GPL Classpath Exception:
* Oracle designates this particular file as subject to the "Classpath"
* exception as provided by Oracle in the GPL Version 2 section of the License
* file that accompanied this code.
*
* Modifications:
* If applicable, add the following below the License Header, with the fields
* enclosed by brackets [] replaced by your own identifying information:
* "Portions Copyright [year] [name of copyright owner]"
*
* Contributor(s):
* If you wish your version of this file to be governed by only the CDDL or
* only the GPL Version 2, indicate your decision by adding "[Contributor]
* elects to include this software in this distribution under the [CDDL or GPL
* Version 2] license." If you don't indicate a single choice of license, a
* recipient has the option to distribute your version of this file under
* either the CDDL, the GPL Version 2 or to extend the choice of license to
* its licensees as provided above. However, if you add GPL Version 2 code
* and therefore, elected the GPL Version 2 license, then the option applies
* only if the new code is made subject to such option by the copyright
* holder.
*/
/*
* WebServiceTesterServlet.java
*
* Created on August 6, 2004, 9:14 AM
*/
package org.glassfish.webservices.monitoring;
import com.sun.enterprise.deployment.WebServiceEndpoint;
import com.sun.enterprise.util.LocalStringManagerImpl;
import com.sun.logging.LogDomains;
import com.sun.tools.ws.spi.WSToolsObjectFactory;
import com.sun.xml.bind.api.JAXBRIContext;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.xml.namespace.QName;
import javax.xml.transform.OutputKeys;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.stream.StreamResult;
import javax.xml.transform.stream.StreamSource;
import javax.xml.ws.Service;
import javax.xml.ws.WebEndpoint;
import java.io.*;
import java.lang.reflect.Method;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLClassLoader;
import java.net.URLDecoder;
import java.util.*;
import java.util.logging.Level;
import java.util.logging.Logger;
import org.glassfish.webservices.WebServiceContractImpl;
import com.sun.enterprise.module.*;
/**
* This servlet is responsible for testing web-services.
*
* @author Jerome Dochez
*/
public class WebServiceTesterServlet extends HttpServlet implements MessageListener {
private WebServiceEndpoint svcEP;
private static Logger logger = LogDomains.getLogger(WebServiceTesterServlet.class,LogDomains.WEBSERVICES_LOGGER);
private static Hashtable<String, Class> gsiClasses = new Hashtable |
