httpproxythreading.java

AsyncServer asyncServer = new AsyncServer();
AsyncHttpServer httpServer = new AsyncHttpServer();
AsyncHttpClient httpClient = new AsyncHttpClient(asyncServer);
ExecutorService executorService = Executors.newCachedThreadPool();

httpServer.get(".*", new HttpServerRequestCallback() {
    @Override
    public void onRequest(final AsyncHttpServerRequest request, final AsyncHttpServerResponse response) {
        executorService.execute(new Runnable() {
            @Override
            public void run() {
                final AsyncHttpGet proxyRequest = new AsyncHttpGet("http://remotehost/" + request.getPath());
                httpClient.executeByteBufferList(proxyRequest, new AsyncHttpClient.DownloadCallback() {
                    @Override
                    public void onCompleted(Exception e, final AsyncHttpResponse proxyResponse, ByteBufferList result) {
                        if (e != null) {
                            // handle error
                            return;
                        }
                        // fill response headers
                        ...
                        // response
                        int size = result.remaining();
                        ByteArrayInputStream is = new ByteArrayInputStream(result.getAllByteArray());
                        response.sendStream(is, result);
                    }
                });
            }
        });
    }


httpServer.listen(asyncServer, 0);