snichol 2002/11/04 11:05:53
Added: java/samples/addressbook ComplexRequest.java perftest.cmd
perftest.sh
Log:
Submitted by: Pavel Ausianik ([EMAIL PROTECTED])
In discussion of what performance gains we got, I created a very simple
performance test, basing on existing addressbook sample (files attached
should be added to java\samples\addressbook\ dir, sorry not sure how correct
patch should be created for new files).
The test allow to run getAddress / putAddress requests in cycle from several
concurrent threads.
I have tested it within following environment:
2XPIII -600, 1G of RAM, W2K
Sun JRE 1.3.1
Tomcat 4.0.3
Xerces 2.x
soap libs 2.2, 2.3.1, current
The number of threads was set up to 8 (with more threads I had a
socketException). Each test included 4000 calls
Before each test server & client SOAP lib was replaced with corresponding
version & server restarted
The test was performed once in each config, sorry had no time for more
accurate testing, maybe someone will complete it.
The results I got following:
SOAP ver , Time to run
2.2 107.091
2.3.1 98.841
CUR 82.451
Revision Changes Path
1.1 xml-soap/java/samples/addressbook/ComplexRequest.java
Index: ComplexRequest.java
===================================================================
/*
* The Apache Software License, Version 1.1
*
*
* Copyright (c) 2000 The Apache Software Foundation. All rights
* reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright
* notice, this list of conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright
* notice, this list of conditions and the following disclaimer in
* the documentation and/or other materials provided with the
* distribution.
*
* 3. The end-user documentation included with the redistribution,
* if any, must include the following acknowledgment:
* "This product includes software developed by the
* Apache Software Foundation (http://www.apache.org/)."
* Alternately, this acknowledgment may appear in the software itself,
* if and wherever such third-party acknowledgments normally appear.
*
* 4. The names "SOAP" and "Apache Software Foundation" must
* not be used to endorse or promote products derived from this
* software without prior written permission. For written
* permission, please contact [EMAIL PROTECTED]
*
* 5. Products derived from this software may not be called "Apache",
* nor may "Apache" appear in their name, without prior written
* permission of the Apache Software Foundation.
*
* THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES
* OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
* DISCLAIMED. IN NO EVENT SHALL THE APACHE SOFTWARE FOUNDATION OR
* ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
* USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY,
* OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT
* OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
* SUCH DAMAGE.
* ====================================================================
*
* This software consists of voluntary contributions made by many
* individuals on behalf of the Apache Software Foundation and was
* originally based on software copyright (c) 2000, International
* Business Machines, Inc., http://www.apache.org. For more
* information on the Apache Software Foundation, please see
* <http://www.apache.org/>.
*/
package samples.addressbook;
import java.io.*;
import java.util.*;
import java.net.*;
import org.w3c.dom.*;
import org.apache.soap.util.xml.*;
import org.apache.soap.*;
import org.apache.soap.encoding.*;
import org.apache.soap.encoding.soapenc.*;
import org.apache.soap.rpc.*;
/**
* See \samples\addressbook\readme for info.
* Runs GetAddress / PutAddress in cycle in concurrent calls
* from different threads
*
* @author Pavel Ausianik ([EMAIL PROTECTED])
*/
public class ComplexRequest implements Runnable {
// Maximum Requests
public static int maxIterations = 100;
// Number of supported calls
public static final int NUM_CALLS = 4;
public static final int PUT_ADDRESS_0 = 0;
public static final int GET_ADDRESS_0 = 1;
public static final int PUT_ADDRESS_1 = 2;
public static final int GET_ADDRESS_1 = 3;
// Current request
public static int currentRequest;
// Number of running threads
public static int numberRequests;
static SOAPMappingRegistry smr = new SOAPMappingRegistry();
static String encodingStyleURI;
static URL url;
Call call;
ComplexRequest() {
call = new Call();
call.setSOAPMappingRegistry(smr);
call.setTargetObjectURI("urn:AddressFetcher");
call.setEncodingStyleURI(encodingStyleURI);
}
/**
* Make a Call to an RPC service with desired reqest type
*/
public void makeCall (int requestType)
throws SOAPException {
// Prepare call params
Vector params = new Vector();
switch (requestType) {
case PUT_ADDRESS_0:
String nameToRegister = "NAME_0 NAME_0";
Address address = new Address(0, "Street_0", "City_0", "State_0",
0, new PhoneNumber(0, "000000", "000000"));
call.setMethodName("addEntry");
params.addElement(new Parameter("nameToRegister", String.class,
nameToRegister, null));
params.addElement(new Parameter("address", Address.class,
address, null));
call.setParams(params);
break;
case PUT_ADDRESS_1:
nameToRegister = "NAME_1 NAME_1";
address = new Address(1, "Street_1", "City_1", "State_1",
0, new PhoneNumber(01, "111111", "111111"));
call.setMethodName("addEntry");
params.addElement(new Parameter("nameToRegister", String.class,
nameToRegister, null));
params.addElement(new Parameter("address", Address.class,
address, null));
break;
case GET_ADDRESS_0:
String nameToLookup = "NAME_0 NAME_0";
call.setMethodName("getAddressFromName");
params.addElement(new Parameter("nameToLookup", String.class,
nameToLookup, null));
break;
case GET_ADDRESS_1:
nameToLookup = "NAME_1 NAME_1";
call.setMethodName("getAddressFromName");
params.addElement(new Parameter("nameToLookup", String.class,
nameToLookup, null));
break;
}
call.setParams(params);
// Invoke the call.
Response resp = call.invoke(url, "");
// Check the response.
if (!resp.generatedFault())
{
// System.out.println("Request " + requestType + " has been finished.
Thread:" + Thread.currentThread().getName());
}
else
{
Fault fault = resp.getFault();
System.err.println("Generated fault: " + fault);
}
}
/**
* run method of the runnable interface
* run Thread, until desired number of calls done
*/
public void run() {
synchronized (ComplexRequest.class) {
numberRequests++;
}
while (true) {
try {
// Get new request type, until available
int requestType = getNextRequestType();
if (requestType == -1)
break;
makeCall(requestType);
}
catch (SOAPException se)
{
// Print and continue running
se.printStackTrace();
}
catch (Throwable e) {
// Print and stop
e.printStackTrace();
break;
}
}
synchronized (ComplexRequest.class) {
numberRequests--;
}
}
/**
* returns next request type, shifting it in turn 0-1-2-3
*/
public synchronized int getNextRequestType() {
if (currentRequest < maxIterations) {
return (currentRequest ++) % NUM_CALLS;
}
return -1;
}
public static void main(String[] args) throws Exception
{
if (args.length != 3
&& (args.length != 4 || !args[0].startsWith("-")))
{
System.err.println("Usage:");
System.err.println(" java " + ComplexRequest.class.getName() +
" [-encodingStyleURI] SOAP-router-URL NumberOfCalls
NumberofThreads");
System.exit (1);
}
// Process the arguments.
int offset = 4 - args.length;
encodingStyleURI = args.length == 4
? args[0].substring(1)
: Constants.NS_URI_SOAP_ENC;
url = new URL(args[1 - offset]);
maxIterations = Integer.parseInt(args[2 - offset]);
int numThreads = Integer.parseInt(args[3 - offset]);
smr = new SOAPMappingRegistry();
BeanSerializer beanSer = new BeanSerializer();
// Map the types.
smr.mapTypes(encodingStyleURI,
new QName("urn:xml-soap-address-demo", "address"),
Address.class, beanSer, beanSer);
smr.mapTypes(encodingStyleURI,
new QName("urn:xml-soap-address-demo", "phone"),
PhoneNumber.class, beanSer, beanSer);
// Fill server registry
ComplexRequest request = new ComplexRequest();
request.makeCall(PUT_ADDRESS_0);
request.makeCall(PUT_ADDRESS_1);
// Start counting time;
long time = System.currentTimeMillis();
Vector threads = new Vector(numThreads);
for (int i=0; i<numThreads; i++) {
Thread t = new Thread( new ComplexRequest(), "Run: " + i);
t.start();
threads.addElement(t);
}
/// Wait for all requests to finish
for (int i=0; i<numThreads; i++) {
try {
((Thread) threads.elementAt(i)).join();
} catch (InterruptedException ie) {
}
}
long time2 = System.currentTimeMillis();
System.out.println("Time to run " + maxIterations + " requests is " +
((time2-time)/1000.0d) + " sec ");
}
}
1.1 xml-soap/java/samples/addressbook/perftest.cmd
Index: perftest.cmd
===================================================================
@echo off
echo This test assumes a server URL of http://localhost:8080/soap/servlet/rpcrouter
echo Deploying the addressbook service...
java org.apache.soap.server.ServiceManagerClient
http://localhost:8080/soap/servlet/rpcrouter deploy DeploymentDescriptor.xml
echo .
echo Verify that it's there
java org.apache.soap.server.ServiceManagerClient
http://localhost:8080/soap/servlet/rpcrouter list
echo .
echo Running Multithread sample
java samples.addressbook.ComplexRequest http://localhost:8080/soap/servlet/rpcrouter
4000 8
echo .
echo Undeploy it now
java org.apache.soap.server.ServiceManagerClient
http://localhost:8080/soap/servlet/rpcrouter undeploy urn:AddressFetcher
echo .
echo Verify that it's gone
java org.apache.soap.server.ServiceManagerClient
http://localhost:8080/soap/servlet/rpcrouter list
1.1 xml-soap/java/samples/addressbook/perftest.sh
Index: perftest.sh
===================================================================
echo This test assumes a server URL of http://localhost:8080/soap/servlet/rpcrouter
echo Deploying the addressbook service...
java org.apache.soap.server.ServiceManagerClient
http://localhost:8080/soap/servlet/rpcrouter deploy DeploymentDescriptor.xml
echo
echo Verify that it\'s there
java org.apache.soap.server.ServiceManagerClient
http://localhost:8080/soap/servlet/rpcrouter list
echo
echo Running Multithread sample
java samples.addressbook.ComplexRequest http://localhost:8080/soap/servlet/rpcrouter
4000 8
echo
echo Undeploy it now
java org.apache.soap.server.ServiceManagerClient
http://localhost:8080/soap/servlet/rpcrouter undeploy urn:AddressFetcher
echo
echo Verify that it\'s gone
java org.apache.soap.server.ServiceManagerClient
http://localhost:8080/soap/servlet/rpcrouter list
--
To unsubscribe, e-mail: <mailto:soap-dev-unsubscribe@;xml.apache.org>
For additional commands, e-mail: <mailto:soap-dev-help@;xml.apache.org>
