Sounds like latency is trumping bandwidth.
On Wed, Sep 30, 2009 at 5:43 AM, Vitaly Litvak <[email protected]> wrote:
> Hi.
>
> We are testing our application on a channel with a low bandwidth. For the
> testing we've developed a simple service, which loads some data from a text
> file and then returns it through two web methods:
>
> 1) simply returns file as a string.
> 2) returns a DataSource object, which we suppose to return our file as a
> MTOM attachment to SOAP response.
>
> If test is ran in a local environment we got 15 times performance
> improvements when using MTOM attachments versus method returning a string:
>
> Elapsed time: streaming=2017, string=33955
>
> But if we move server application to remote host on Amazon there are no
> performance gain at all. We've tried moving it to some computer in local
> network and the performance gain present here. After that we've tried to
> move to private remote computer and it works the same as on Amazon again.
> And neither profiling (JProfiler), nor network monitoring (wireshark) can't
> guide us to the root reason of this. We've spent about three days making
> tests and unable to know why this is happening.
>
> Here is the source code (also tried to attached it to e-mail message):
>
> // IWS.java
>
> package test;
> import javax.activation.DataSource;
> import javax.jws.WebService;
>
> public interface IWS
> {
> public DataSource xmlStream();
> public String xmlString();
> }
>
> // CWS.java
>
> package test;
> import java.io.File;
>
> import javax.activation.DataSource;
> import javax.mail.util.ByteArrayDataSource;
>
> import org.apache.commons.io.FileUtils;
>
>
> public class CWS implements IWS
> {
> private static ByteArrayDataSource xml;
> private static String xmlString;
> static
> {
> try
> {
> xmlString = FileUtils.readFileToString(new File("bs.txt"));
> xml = new ByteArrayDataSource(xmlString.getBytes(), null);
> }
> catch (Exception ex)
> {
> ex.printStackTrace();
> }
> }
>
> @Override
> public DataSource xmlStream()
> {
> return xml;
> }
>
> @Override
> public String xmlString()
> {
> return xmlString;
> }
>
> }
>
> // Server.java
>
> package test;
> import java.util.*;
>
> import org.apache.cxf.common.util.SOAPConstants;
> import org.apache.cxf.feature.AbstractFeature;
> import org.apache.cxf.frontend.ServerFactoryBean;
> import org.apache.cxf.transport.http.AbstractHTTPDestination;
> import org.apache.cxf.transport.http.gzip.GZIPFeature;
> import org.apache.cxf.transports.http.configuration.HTTPServerPolicy;
>
>
> public class Server
> {
> public static boolean GZIP = false;
> public static boolean KEEPALIVE = false;
> private static org.apache.cxf.endpoint.Server server;
>
> private static void init()
> {
> if (server == null)
> {
> /**
> * Start main application server
> */
> CWS cws = new CWS();
> ServerFactoryBean sfb = new ServerFactoryBean();
>
> Map<String,Object> props = new HashMap<String, Object>();
> props.put(SOAPConstants.MTOM_ENABLED, Boolean.TRUE.toString());
>
> sfb.setProperties(props);
> sfb.getServiceFactory().setDataBinding(DataBindings.get());
> sfb.setServiceClass(IWS.class);
> sfb.setAddress(Main.address);
> sfb.setServiceBean(cws);
> if (sfb.getFeatures() == null)
> {
> sfb.setFeatures(new ArrayList<AbstractFeature>());
> }
> if (GZIP)
> {
> System.out.println("Enabling GZIP");
> sfb.getFeatures().add(new GZIPFeature());
> }
>
> server = sfb.create();
>
> if (KEEPALIVE)
> {
> System.out.println("Enabling keep-alive");
> HTTPServerPolicy spol = ((AbstractHTTPDestination)
> server.getDestination()).getServer();
> spol.setHonorKeepAlive(true);
> spol.setKeepAliveParameters("timeout=60, max=10;");
> }
> }
> }
>
> public static org.apache.cxf.endpoint.Server get()
> {
> init();
> return server;
> }
>
> public static void main(String... args)
> {
> for (String arg : args)
> {
> if (arg != null)
> {
> if (arg.trim().equalsIgnoreCase("gzip"))
> {
> GZIP = true;
> }
> else if (arg.trim().equalsIgnoreCase("keepalive"))
> {
> KEEPALIVE = true;
> }
> }
> }
> init();
> }
> }
>
> // Client.java
>
> package test;
> import java.io.InputStream;
> import java.util.*;
>
> import javax.activation.DataSource;
>
> import org.apache.cxf.common.util.SOAPConstants;
> import org.apache.cxf.feature.AbstractFeature;
> import org.apache.cxf.frontend.ClientProxy;
> import org.apache.cxf.frontend.ClientProxyFactoryBean;
> import org.apache.cxf.transport.http.HTTPConduit;
> import org.apache.cxf.transport.http.gzip.GZIPFeature;
> import org.apache.cxf.transports.http.configuration.HTTPClientPolicy;
>
>
> public class Client
> {
> public static boolean GZIP = true;
> private static IWS client;
>
> public static void init(String address)
> {
> ClientProxyFactoryBean cfb = new ClientProxyFactoryBean();
> cfb.setServiceClass(IWS.class);
> cfb.setAddress(address);
>
> Map<String,Object> props = new HashMap<String, Object>();
> props.put(SOAPConstants.MTOM_ENABLED, Boolean.TRUE.toString());
>
> cfb.setProperties(props);
> cfb.getServiceFactory().setDataBinding(DataBindings.get());
> if (cfb.getFeatures() == null)
> {
> cfb.setFeatures(new ArrayList<AbstractFeature>());
> }
> if (GZIP)
> {
> cfb.getFeatures().add(new GZIPFeature());
> }
>
> client = (IWS) cfb.create();
>
> org.apache.cxf.endpoint.Client cl = ClientProxy.getClient(client);
>
> HTTPConduit cnd = (HTTPConduit)cl.getConduit();
> HTTPClientPolicy cpol = cnd.getClient();
> cpol.setConnectionTimeout(60 * 1000);
> cpol.setAllowChunking(false);
> cpol.setReceiveTimeout(60 * 1000);
> if (GZIP)
> {
> cpol.setAcceptEncoding("gzip");
> }
> cnd.setClient(cpol);
> }
>
> public static void runPerformanceTests(int COUNT) throws Exception
> {
> long t = System.currentTimeMillis();
> for (int i = 0; i < COUNT; i++)
> {
> DataSource ds = Client.get().xmlStream();
>
> byte[] buf = new byte[100 * 1024];
> InputStream is = ds.getInputStream();
> while (is.read(buf) >= 0)
> {
> }
> is.close();
> }
> long streaming = (System.currentTimeMillis() - t);
>
> t = System.currentTimeMillis();
> for (int i = 0; i < COUNT; i++)
> {
> String xml = Client.get().xmlString();
> }
> long string = (System.currentTimeMillis() - t);
>
> System.out.println("Elapsed time: streaming=" + streaming + ",
> string=" + string);
> }
>
> public static IWS get()
> {
> return client;
> }
>
> public static void main(String args[]) throws Exception
> {
> init("http://remote.server.com:9336/cxf_test";);
> runPerformanceTests(100);
> }
> }
>
> // Main.java
>
> package test;
>
>
> public class Main
> {
> public static String address = "http://localhost:9336/cxf_test";;
> private final static boolean GZIP = true;
>
> public static void main(String... args)
> {
> long t = System.currentTimeMillis();
>
> try
> {
> Client.GZIP = GZIP;
> Server.GZIP = GZIP;
>
> Server.get();
> Client.init(address);
>
> Client.runPerformanceTests(100);
> }
> catch (Throwable ex)
> {
> ex.printStackTrace();
> }
> finally
> {
> Server.get().stop();
> System.out.println("Time running: " +
> (System.currentTimeMillis() - t));
>
> System.exit(0);
> }
> }
> }
>
