benchmark.java

xmlrpc-2.0-src.zip java程序

/*
 * Copyright 1999,2005 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.xmlrpc;

import java.io.IOException;
import java.util.Date;
import java.util.Vector;

public class Benchmark
    implements Runnable
{

    XmlRpcClient client;
    static String url;
    static int clients = 16;
    static int loops = 100;

    long start;

    int gCalls = 0, gErrors = 0;

    Date date;

    public Benchmark () throws Exception
    {
        client = new XmlRpcClientLite (url);

        Vector args = new Vector ();
        // Some JITs (Symantec, IBM) have problems with several Threads
        // starting all at the same time.
        // This initial XML-RPC call seems to pacify them.
        args.addElement (new Integer (123));
        client.execute ("math.abs", args);
        date = new Date ();
        date = new Date ((date.getTime() / 1000) * 1000);

        start = System.currentTimeMillis ();
        int nclients = clients;

        for (int i = 0; i < nclients; i++)
            new Thread (this).start ();
    }

    public void run ()
    {
        int errors = 0;
        int calls = 0;
        try
        {
            int val = (int)(-100 * Math.random ());
            Vector args = new Vector ();

            // ECHO STRING
            // args.addElement (Integer.toString (val));
            // ABS INT
            args.addElement (new Integer (val));
            // ECHO DATE
            // args.addElement (date);

            for (int i = 0; i < loops; i++)
            {

                // ABS INT
                Integer ret = (Integer) client.execute ("math.abs", args);
                // ECHO
                // Vector v = (Vector) client.execute ("echo", args);
                // ECHO DATE
                // Date d = (Date) v.elementAt (0);

                // ABS INT
                if (ret.intValue () != Math.abs (val))
                {
                    // ECHO DATE
                    // if (date.getTime() !=  d.getTime()) {
                    // ECHO STRING
                    // if (!Integer.toString(val).equals (v.elementAt (0))) {
                    errors += 1;
                }
                calls += 1;
            }
        }
        catch (IOException x)
        {
            System.err.println ("Exception in client: "+x);
            x.printStackTrace ();
        }
        catch (XmlRpcException x)
        {
            System.err.println ("Server reported error: "+x);
        }
        catch (Exception other)
        {
            System.err.println ("Exception in Benchmark client: "+other);
        }
        int millis = (int)(System.currentTimeMillis () - start);
        checkout (calls, errors, millis);
    }

    private synchronized void checkout (int calls, int errors, int millis)
    {
        clients--;
        gCalls += calls;
        gErrors += errors;
        System.err.println ("Benchmark thread finished: "+calls + " calls, "+
                errors + " errors in "+millis + " milliseconds.");
        if (clients == 0)
        {
            System.err.println ("");
            System.err.println ("Benchmark result: "+
                    (1000 * gCalls / millis) + " calls per second.");
        }
    }

    public static void main (String args[]) throws Exception
    {
        if (args.length > 0 && args.length < 3)
        {
            url = args[0];
            XmlRpc.setKeepAlive (true);
            if (args.length == 2)
                XmlRpc.setDriver (args[1]);
            new Benchmark ();
        }
        else
        {
            System.err.println ("Usage: java org.apache.xmlrpc.Benchmark URL [SAXDriver]");
        }
    }

}