WebServiceTesterServletpublic class WebServiceTesterServlet extends HttpServlet implements MessageListener| This servlet is responsible for testing web-services. |
| Fields Summary |
|---|
| private com.sun.enterprise.deployment.WebServiceEndpoint | svcEP | | private static Logger | logger | | private static Hashtable | gsiClasses | | private static Hashtable | ports | | private static com.sun.enterprise.util.LocalStringManagerImpl | localStrings | | private MessageTrace | request | | private MessageTrace | response |
| Methods Summary |
|---|
| private void | classNotAccessibleError(java.lang.ClassLoader cl, java.lang.String className, java.io.PrintWriter out)
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.CNFTitle",
"<HTML><HEAD><TITLE>Method invocation exception</TITLE></HEAD>"));
if (cl==null) {
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.CNFServerError",
"<H3>Internal server error, debugging is not available</H3>"));
} else {
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.CNFerror2",
"<H3>Cannot load class {0} - Verify class presence in bundle</H3>",
new Object[] {className}));
}
out.print("<HR>");
out.print("</HTML>");
out.close();
| | private java.lang.Object | convertWebParam(java.lang.Class targetParamType, java.lang.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 | deleteDir(java.io.File path)
File[] files = path.listFiles();
for (File f : files) {
if (f.isDirectory()) {
deleteDir(f);
}
f.delete();
}
path.delete();
| | public void | doGet(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse res)
res.setContentType("text/html");
res.setHeader("pragma", "no-cache");
PrintWriter out = res.getWriter();
String requestURL = req.getRequestURL().toString();
Endpoint myEndpoint;
if(svcEP.implementedByWebComponent()) {
myEndpoint = WebServiceEngineImpl.getInstance().getEndpoint(req.getServletPath());
} else {
myEndpoint = WebServiceEngineImpl.getInstance().getEndpoint(req.getRequestURI());
}
String seiClassName = myEndpoint.getDescriptor().getServiceEndpointInterface();
// For now support Tester servlet for JAXWS based services only
try {
Class seiClass = Thread.currentThread().getContextClassLoader().loadClass(seiClassName);
if(seiClass.getAnnotation(javax.jws.WebService.class) == null) {
testerNotSupportedError(myEndpoint.getDescriptor().getServiceName(), out);
return;
}
} catch (ClassNotFoundException clnfEx) {
classNotAccessibleError(Thread.currentThread().getContextClassLoader(),
seiClassName, out);
return;
}
initializePort(req);
Class clientSEI = gsiClasses.get(requestURL);
out.print("<HTML><HEAD><TITLE>"+
myEndpoint.getDescriptor().getServiceName().getLocalPart()+" "+
localStrings.getLocalString(
"enterprise.webservice.monitoring.title",
"Web Service Tester") + "</TITLE></HEAD>");
out.print("<BODY><H1>"+
myEndpoint.getDescriptor().getServiceName().getLocalPart()+" "+
localStrings.getLocalString(
"enterprise.webservice.monitoring.title",
"Web Service Tester") + "</H1>");
java.util.Enumeration<String> headers = req.getHeaderNames();
// Microsoft Internet Explorer does not handle <BUTTON> properly
boolean isInternetExplorer=false;
String userAgent = req.getHeader("user-agent");
if (userAgent!=null) {
isInternetExplorer=userAgent.indexOf("MSIE")!=-1;
}
StringBuffer sb = new StringBuffer(URLDecoder.decode(requestURL));
sb.append("?WSDL");
out.print("<br>");
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.line1",
"This form will allow you to test your web service implementation (<A HREF=\"{0}\">WSDL File</A>)",
new Object[] {sb.toString()}));
out.print("<hr>");
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.line2",
"To invoke an operation, fill the method parameter(s) input boxes and click on the button labeled with the method name."));
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.methods",
"<H3>Methods :</H3>"));
Method[] methods = clientSEI.getMethods();
for (Method m : methods) {
out.print("<FORM METHOD=\"POST\">");
out.print(m.toString());
out.print("<BR>");
out.print("<INPUT TYPE=SUBMIT NAME=action value="+m.getName()+">");
// out.print("<BUTTON TYPE=SUBMIT TITLE=Invoke NAME=\"submit\" VALUE="+m.getName()+">" + m.getName()+"</BUTTON>");
out.print(" (");
Class[] parameters = m.getParameterTypes();
for (int i=0;i<parameters.length;i++) {
out.print("<INPUT TYPE=TEXT NAME=PARAM"+
m.getName()+i+">");
if (i!=parameters.length-1)
out.print(",");
}
out.print(")");
out.print("<BR>");
out.print("<HR>");
out.print("</FORM></BODY></HTML>");
}
out.close();
| | public void | doPost(javax.servlet.http.HttpServletRequest req, javax.servlet.http.HttpServletResponse res)
res.setContentType("text/html");
res.setHeader("pragma", "no-cache");
PrintWriter out = res.getWriter();
String requestURL = req.getRequestURL().toString();
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.postTitle",
"<HTML><HEAD><TITLE>Method invocation trace</TITLE></HEAD>"));
String operationName = req.getParameter("action");
try {
Endpoint myEndpoint;
if(svcEP.implementedByWebComponent()) {
myEndpoint = WebServiceEngineImpl.getInstance().getEndpoint(req.getServletPath());
} else {
myEndpoint = WebServiceEngineImpl.getInstance().getEndpoint(req.getRequestURI());
}
Class clientSEI = gsiClasses.get(requestURL);
if (clientSEI==null) {
initializePort(req);
clientSEI = gsiClasses.get(requestURL);
}
Object port = ports.get(requestURL);
// find the right method...
Method[] methods = clientSEI.getMethods();
Method toInvoke = null;
for (Method m : methods) {
if (String.valueOf(m.getName()).equals(operationName)) {
toInvoke = m;
}
}
if (toInvoke==null) {
out.print("cannot find method " + operationName);
} else {
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.methodInvocation",
"<H2><A> {0} </A> Method invocation</H2><BR><HR>",
new Object[] {toInvoke.getName()}));
// register ourselves to receive the SOAP messages...
myEndpoint.addListener(this);
Class[] parameterTypes = toInvoke.getParameterTypes();
Object[] parameterValues= new Object[parameterTypes.length];
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.methodTrace",
"<h4>Method parameter(s)</h4>"));
out.print("<table border=\"1\">");
out.print("<tr>");
out.print("<th>Type</th>");
out.print("<th>Value</th>");
out.print("</tr>");
for (int i=0;i<parameterTypes.length;i++) {
out.print("<tr>");
String webValue = req.getParameter("PARAM"+
toInvoke.getName()+i);
out.print("<td>" + parameterTypes[i].getName()+"</td>");
out.print("<td>" + webValue + "</td>");
parameterValues[i] = convertWebParam(parameterTypes[i],webValue);
out.print("</tr>");
}
out.print("</table>");
out.print("<HR>");
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.methodReturn",
"<h4>Method returned</h4>")
+toInvoke.getReturnType().getName() + " : \"<b>"
+ toInvoke.invoke(port, parameterValues)+"</b>\"");
out.print("<HR>");
if (request!=null) {
// let's print the SOAP request
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.soapReq",
"<h4>SOAP Request</h4>"));
dumpMessage(request, out);
}
if (toInvoke.getAnnotation(javax.jws.Oneway.class) == null &&
response!=null) {
// let's print the SOAP request
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.soapResp",
"<h4>SOAP Response</h4>"));
dumpMessage(response, out);
}
myEndpoint.removeListener(this);
}
} catch(Throwable e) {
out.print(localStrings.getLocalString(
"enterprise.webservice.serviceExceptionError",
"<H2>Service invocation threw an exception with message : {0}; Refer to the server log for more details</H2><BR><HR>",
new Object[] {e.getMessage()}));
throw new ServletException(e);
}
out.print("</HTML>");
out.close();
| | private void | dumpMessage(MessageTrace message, java.io.PrintWriter out)
/*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><blockquote><pre xml:lang>");
String value = baos.toString();
value = value.replaceAll("<", "<");
value = value.replaceAll(">", ">");
out.write(value);
out.print("</pre></blockquote><HR>");
/*
baos = new ByteArrayOutputStream();
sr = new StreamResult(baos);
bais.reset();
transformer.transform(ss, sr);
StringReader reader = new StringReader(xsl);
transformer = factory.newTransformer(new StreamSource(reader));
out.write(baos.toString());
*/
| | private java.util.List | getListOfFiles(java.io.File path)
File[] files = path.listFiles();
List<File> result = new ArrayList<File>();
for (File f : files) {
if (f.isDirectory()) {
result.addAll(getListOfFiles(f));
} else {
result.add(f);
}
}
return result;
| | private java.lang.String | getPortClass(Endpoint ep, java.lang.Class serviceClass)
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 java.lang.String | getServiceClass(java.lang.String serviceClassName, java.lang.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 void | initializePort(javax.servlet.http.HttpServletRequest req)
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);
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().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));
}
| | public void | invocationProcessed(MessageTrace request, MessageTrace response)
this.request = request;
this.response = response;
| | public static void | invoke(javax.servlet.http.HttpServletRequest request, javax.servlet.http.HttpServletResponse response, com.sun.enterprise.deployment.WebServiceEndpoint endpoint)
try {
WebServiceTesterServlet servlet = new WebServiceTesterServlet(endpoint);
response.setCharacterEncoding("UTF-8");
if (request.getMethod().equalsIgnoreCase("GET")) {
servlet.doGet(request, response);
} else {
servlet.doPost(request, response);
}
} catch(Exception e) {
try {
PrintWriter out = response.getWriter();
out.print("<HTML><HEAD><TITLE>"+
localStrings.getLocalString(
"enterprise.webservice.monitoring.methodInvocationException",
"Method invocation exception")+"</TITLE></HEAD>");
out.print("<H3>" +
localStrings.getLocalString(
"enterprise.webservice.monitoring.ExceptionDetails",
"Exceptions details : {0}",
new Object[] {e.getMessage()}) + "</H3>");
out.print("<HR>");
e.printStackTrace(out);
out.print("<HR>");
out.print("</HTML>");
out.close();
} catch(Exception ex) {};
}
| | private void | testerNotSupportedError(javax.xml.namespace.QName svcName, java.io.PrintWriter out)
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.TesterNSTitle",
"<HTML><HEAD><TITLE>Tester feature not supported</TITLE></HEAD>"));
out.print("<BODY>");
out.print(localStrings.getLocalString(
"enterprise.webservice.monitoring.TesterNSerror2",
"Service {0} looks like a JAXRPC based webservice.",
new Object[] {svcName}));
out.print("<br><br>");
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 java.lang.String | wsImport(java.net.URL wsdlLocation)
File classesDir = new File(System.getProperty("java.io.tmpdir"));
// 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[4];
wsimportArgs[0]="-d";
wsimportArgs[1]=classesDir.getAbsolutePath();
wsimportArgs[2]="-keep";
wsimportArgs[3]=wsdlLocation.toExternalForm();
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();
|
|
