jetty-async-client

gistfile1.java

public class Test {

    public static void main(String[] args) throws Exception {
        final SslContextFactory sslContextFactory = new SslContextFactory();
        sslContextFactory.setValidateCerts(false);
        sslContextFactory.setValidatePeerCerts(false);

        final HttpClient client = new HttpClient(sslContextFactory);
        client.setMaxConnectionsPerDestination(250);
        client.setMaxRequestsQueuedPerDestination(50);
        client.setConnectTimeout(4000);
        client.setIdleTimeout(5000);
        client.setFollowRedirects(true);

        client.start();

        client.newRequest("http://google.com")
                .timeout(10, TimeUnit.SECONDS)
                .onRequestQueued(new Request.QueuedListener() {
                    @Override
                    public void onQueued(Request request) {
                        System.out.println("thread=" + Thread.currentThread().getName());
                    }
                })
                .onRequestHeaders(new Request.HeadersListener() {
                    @Override
                    public void onHeaders(Request request) {
                        System.out.println("thread=" + Thread.currentThread().getName());
                    }
                })
                .onRequestSuccess(new Request.SuccessListener() {
                    @Override
                    public void onSuccess(Request request) {
                        System.out.println("thread=" + Thread.currentThread().getName());
                    }
                })
                .send(new BufferingResponseListener() {
                    @Override
                    public void onComplete(Result result) {
                        System.out.println("thread=" + Thread.currentThread().getName());
                    }
                });

        Thread.sleep(5000);
        client.stop();
    }

}