import com.koushikdutta.async.AsyncServerSocket; //导入依赖的package包/类
public void testMaxAgePrivate() throws Exception {
    AsyncHttpClient client = new AsyncHttpClient(AsyncServer.getDefault());
    ResponseCacheMiddleware cache = ResponseCacheMiddleware.addCache(client, new File(getContext().getFilesDir(), "AndroidAsyncTest"), 1024 * 1024 * 10);
    AsyncHttpServer httpServer = new AsyncHttpServer();
    try {
        httpServer.get("/uname/(.*)", new HttpServerRequestCallback() {
            @Override
            public void onRequest(AsyncHttpServerRequest request, AsyncHttpServerResponse response) {
                response.getHeaders().set("Date", HttpDate.format(new Date()));
                response.getHeaders().set("Cache-Control", "private, max-age=10000");
                response.send(request.getMatcher().group(1));
            }
        });

        AsyncServerSocket socket = httpServer.listen(AsyncServer.getDefault(), 0);
        int port = socket.getLocalPort();
        // clear the old cache
        cache.clear();

        client.executeString(new AsyncHttpGet("http://localhost:" + port + "/uname/43434"), null).get();

        client.executeString(new AsyncHttpGet("http://localhost:" + port + "/uname/43434"), null).get();


        assertEquals(cache.getCacheHitCount(), 1);
        assertEquals(cache.getNetworkCount(), 1);
    }
    finally {
        AsyncServer.getDefault().stop();
        client.getMiddleware().remove(cache);
    }
}
 

import com.koushikdutta.async.AsyncServerSocket; //导入依赖的package包/类
public void stop() {
    if (mListeners != null) {
        for (AsyncServerSocket listener: mListeners) {
            listener.stop();
        }
    }
}
 

import com.koushikdutta.async.AsyncServerSocket; //导入依赖的package包/类
public void testProxy() throws Exception {
        wasProxied = false;
        final AsyncServer proxyServer = new AsyncServer();
        try {
            AsyncProxyServer httpServer = new AsyncProxyServer(proxyServer) {
                @Override
                protected boolean onRequest(AsyncHttpServerRequest request, AsyncHttpServerResponse response) {
                    wasProxied = true;
                    return super.onRequest(request, response);
                }
            };

            AsyncServerSocket socket = httpServer.listen(proxyServer, 0);

//            client.getSocketMiddleware().enableProxy("localhost", 5555);

            AsyncHttpGet get = new AsyncHttpGet("http://www.clockworkmod.com");
            get.enableProxy("localhost", socket.getLocalPort());

            Future<String> ret = client.executeString(get, null);
            String data;
            assertNotNull(data = ret.get(TIMEOUT, TimeUnit.MILLISECONDS));
            assertTrue(data.contains("ClockworkMod"));
            assertTrue(wasProxied);
        }
        finally {
            proxyServer.stop();
        }
    }
 

import com.koushikdutta.async.AsyncServerSocket; //导入依赖的package包/类
public AsyncServerSocket getServerSocket() {
    if (mServerWrapper != null) {
        return mServerWrapper.getServerSocket();
    } else {
        return null;
    }
}
 

import com.koushikdutta.async.AsyncServerSocket; //导入依赖的package包/类
public void stop() {
	if (mListeners != null) {
		for (AsyncServerSocket listener : mListeners) {
			listener.stop();
		}
	}
}
 

import com.koushikdutta.async.AsyncServerSocket; //导入依赖的package包/类
@Override
public void onListening(AsyncServerSocket socket) {
    Timber.i("Server listening on port %d", socket.getLocalPort());
}
 

import com.koushikdutta.async.AsyncServerSocket; //导入依赖的package包/类
@Override
public void onListening(AsyncServerSocket socket) {
    mListeners.add(socket);
}
 

import com.koushikdutta.async.AsyncServerSocket; //导入依赖的package包/类
public AsyncServerSocket listen(AsyncServer server, int port) {
    return server.listen(null, port, mListenCallback);
}
 

import com.koushikdutta.async.AsyncServerSocket; //导入依赖的package包/类
@Override
public void onListening(AsyncServerSocket socket) {
	mListeners.add(socket);
}
 

import com.koushikdutta.async.AsyncServerSocket; //导入依赖的package包/类
public void onListening(AsyncServerSocket socket); 

import com.koushikdutta.async.AsyncServerSocket; //导入依赖的package包/类
public AsyncServerSocket getServerSocket() { return mServerSocket; }