import com.koushikdutta.async.http.server.HttpServerRequestCallback; //导入依赖的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.http.server.HttpServerRequestCallback; //导入依赖的package包/类
private void startServer() {
    server.get("/", new HttpServerRequestCallback() {
        @Override
        public void onRequest(AsyncHttpServerRequest request, AsyncHttpServerResponse response) {
            response.send("Hello!!!");
        }
    });

    server.post("/testJson", new HttpServerRequestCallback() {
        @Override
        public void onRequest(AsyncHttpServerRequest asyncHttpServerRequest, AsyncHttpServerResponse asyncHttpServerResponse) {
            AsyncHttpRequestBody requestBody = asyncHttpServerRequest.getBody();
            try {
                asyncHttpServerResponse.code(200);
                asyncHttpServerResponse.send(new JSONObject(requestBody.toString()).getJSONObject("menu").getString("value"));
            } catch (JSONException e) {
                Log.e("MainActivity", e.getMessage(), e);
            }
        }
    });
    server.listen(mAsyncServer, 8080);
}
 

import com.koushikdutta.async.http.server.HttpServerRequestCallback; //导入依赖的package包/类
public void testKeys() throws Exception {
    KeyManagerFactory kmf = KeyManagerFactory.getInstance("X509");
    KeyStore ks = KeyStore.getInstance(KeyStore.getDefaultType());

    ks.load(getContext().getResources().openRawResource(R.raw.keystore), "storepass".toCharArray());
    kmf.init(ks, "storepass".toCharArray());


    TrustManagerFactory tmf = TrustManagerFactory.getInstance(TrustManagerFactory.getDefaultAlgorithm());
    KeyStore ts = KeyStore.getInstance(KeyStore.getDefaultType());
    ts.load(getContext().getResources().openRawResource(R.raw.keystore), "storepass".toCharArray());
    tmf.init(ts);

    SSLContext sslContext = SSLContext.getInstance("TLS");
    sslContext.init(kmf.getKeyManagers(), tmf.getTrustManagers(), null);

    AsyncHttpServer httpServer = new AsyncHttpServer();
    httpServer.listenSecure(8888, sslContext);
    httpServer.get("/", new HttpServerRequestCallback() {
        @Override
        public void onRequest(AsyncHttpServerRequest request, AsyncHttpServerResponse response) {
            response.send("hello");
        }
    });

    Thread.sleep(1000);

    AsyncHttpClient.getDefaultInstance().getSSLSocketMiddleware().setSSLContext(sslContext);
    AsyncHttpClient.getDefaultInstance().getSSLSocketMiddleware().setTrustManagers(tmf.getTrustManagers());
    AsyncHttpClient.getDefaultInstance().executeString(new AsyncHttpGet("https://localhost:8888/"), null).get();
}
 

import com.koushikdutta.async.http.server.HttpServerRequestCallback; //导入依赖的package包/类
public BeamServer(String host, int port) {
    mHttpServer = new AsyncHttpServer() {
        protected boolean onRequest(AsyncHttpServerRequest httpServerRequest, AsyncHttpServerResponse httpServerResponse) {
            Timber.d(httpServerRequest.toString());
            httpServerResponse.getHeaders().set("Access-Control-Allow-Origin", "*");
            return super.onRequest(httpServerRequest, httpServerResponse);
        }
    };

    sHost = host;
    sPort = port;

    for (FileType localFileType : FILE_TYPES) {
        VideoFileReponse localVideoFileReponse = new VideoFileReponse(localFileType);
        mHttpServer.get("/video." + localFileType.extension, localVideoFileReponse);
        mHttpServer.addAction("HEAD", "/video." + localFileType.extension, localVideoFileReponse);
    }

    for(FileType localSubsFileType : SUB_TYPES) {
        SubtitleFileResponse localSubsFileReponse = new SubtitleFileResponse(localSubsFileType);
        mHttpServer.get("/video." + localSubsFileType.extension, localSubsFileReponse);
        mHttpServer.addAction("HEAD", "/video." + localSubsFileType.extension, localSubsFileReponse);
    }

    mHttpServer.get("/(.*?)", new HttpServerRequestCallback() {
        @Override
        public void onRequest(AsyncHttpServerRequest request, AsyncHttpServerResponse response) {
            response.send("Not found");
            response.code(404);
        }
    });
}