HTTP clients perfomance

AsyncHttpApp.java

public class AsyncHttpApp {

    ExecutorService pool = Executors.newFixedThreadPool(25);

    private interface Provider {
        public void provide(String url, int times) throws Exception;
    }

    private class PlainProvider implements Provider {
        public void provide(final String url, int times) throws Exception {
            List<Future<Integer>> futures = new ArrayList<Future<Integer>>();
            for (int i = 0; i < times; i++) {
                futures.add(pool.submit(new Callable<Integer>() {
                    public Integer call() throws Exception {
                        HttpURLConnection connection = (HttpURLConnection) new URL(url).openConnection();
                        int result = IOUtils.toString(connection.getInputStream()).length();
                        connection.disconnect();
                        return result;
                    }
                }));
            }
            for (Future<Integer> future : futures)
                System.out.println(future.get()+":"+System.currentTimeMillis()/1000+" ");
        }
        public String toString() {
            return "PlainProvider";
        }
    }

    private class AsyncProvider implements Provider {
        AsyncHttpClient client;
        public AsyncProvider(AsyncHttpProvider provider) {
            this.client = new AsyncHttpClient(provider);
        }
        public void provide(String url, int times) throws Exception {
            try {
                List<Future<Response>> futures = new ArrayList<Future<Response>>();
                for (int i = 0; i < times; i++) {
                    futures.add(client.prepareGet(url).execute());
                }
                for (Future<Response> future : futures)
                    System.out.println(future.get().getResponseBody().length()+":"+System.currentTimeMillis()/1000+" ");
            } finally {
                client.close();
            }
        }
        public String toString() {
            return client.getProvider().getClass().getSimpleName();
        }
    }

    public AsyncHttpApp() {
        AsyncHttpClientConfig config = new AsyncHttpClientConfig.Builder().setExecutorService(pool).build();
        Provider[] providers = new Provider[] {
        	new PlainProvider(),
        	new AsyncProvider(new JDKAsyncHttpProvider(config)),
        	new AsyncProvider(new NettyAsyncHttpProvider(config))
        };
        for (Provider provider : providers) {
            long begin = System.currentTimeMillis();
            try {
                provider.provide("http://10.7.1.13:3000", 20);
            } catch (Exception e) {
                System.err.println(e.getMessage());
            }
            long total = System.currentTimeMillis() - begin;
            System.out.println(provider + " : " + total);
        }
        pool.shutdown();
    }

    public static void main(String[] args) {
        new AsyncHttpApp();
    }
}

public class AsyncHttpApp {

    ExecutorService pool = Executors.newCachedThreadPool();

    private interface Provider {
        public void provide(String url, int times) throws Exception;
    }

    private class PlainProvider implements Provider {
        public void provide(final String url, int times) throws Exception {
            List<Future<String>> futures = new ArrayList<Future<String>>();
            for (int i = 0; i < times; i++) {
                futures.add(pool.submit(new Callable<String>() {
                    public String call() throws Exception {
                        HttpURLConnection connection = (HttpURLConnection) new URL(url).openConnection();
                        String message = connection.getResponseMessage();
                        IOUtils.toString(connection.getInputStream());
                        connection.disconnect();
                        return message;
                    }
                }));
            }
            for (Future<String> future : futures)
                System.out.print(future.get() + " ");
            System.out.println();
            pool.shutdown();
        }

        public String toString() {
            return "PlainProvider";
        }
    }

    private class AsyncProvider implements Provider {
        AsyncHttpClient client;

        public AsyncProvider(AsyncHttpProvider provider) {
            this.client = new AsyncHttpClient(provider);
        }

        public void provide(String url, int times) throws Exception {
            try {
                List<Future<Response>> futures = new ArrayList<Future<Response>>();
                for (int i = 0; i < times; i++) {
                    futures.add(client.prepareGet(url).execute());
                }
                for (Future<Response> future : futures)
                    System.out.print(future.get().getStatusText() + " ");
                System.out.println();
            } finally {
                client.close();
            }
        }

        public String toString() {
            return client.getProvider().getClass().getSimpleName();
        }
    }

    public AsyncHttpApp() {
        AsyncHttpClientConfig config = new AsyncHttpClientConfig.Builder().build();
        Provider[] providers = new Provider[] { //
        new AsyncProvider(new JDKAsyncHttpProvider(config)),//
                new AsyncProvider(new NettyAsyncHttpProvider(config)),//
                new PlainProvider() };
        for (Provider provider : providers) {
            long begin = System.currentTimeMillis();
            try {
                provider.provide("http://localhost:9000?latency=200", 200);
            } catch (Exception e) {
                System.err.println(e.getMessage());
            }
            long total = System.currentTimeMillis() - begin;
            System.out.println(provider + " : " + total);
        }
    }

    public static void main(String[] args) {
        new AsyncHttpApp();
    }
}