Java AsyncHttpGet类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中com.koushikdutta.async.http.AsyncHttpGet类的典型用法代码示例。如果您正苦于以下问题：Java AsyncHttpGet类的具体用法？Java AsyncHttpGet怎么用？Java AsyncHttpGet使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

AsyncHttpGet类属于com.koushikdutta.async.http包，在下文中一共展示了AsyncHttpGet类的19个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: testMaxAgePrivate

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的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);
    }
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:33，代码来源:CacheTests.java

示例2: testRelativeRedirect

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
public void testRelativeRedirect() throws Exception {
    String ret = AsyncHttpClient.getDefaultInstance()
    .executeString(new AsyncHttpGet("http://localhost:6003/foo/bar"), null)
    .get();

    assertEquals(ret, "SUCCESS!");

    ret = AsyncHttpClient.getDefaultInstance()
    .executeString(new AsyncHttpGet("http://localhost:6003/foo"), null)
    .get();

    assertEquals(ret, "BORAT!");

    ret = AsyncHttpClient.getDefaultInstance()
    .executeString(new AsyncHttpGet("http://localhost:6003/foo/poo"), null)
    .get();

    assertEquals(ret, "SWEET!");
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:20，代码来源:RedirectTests.java

示例3: executeGet

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
public static Future<?> executeGet(Request request, final ResponseCallback responseCallback) {
    StringBuilder stringBuffer = new StringBuilder(request.getURL());
    if (request.getURLParams() != null) {
        String params = HttpUtils.getRequestParams(request.getURLParams());
        if (!TextUtils.isEmpty(params)) {
            stringBuffer.append("?").append(params);
        }
    }
    if (BuildConfig.DEBUG) {
        LogUtils.d(stringBuffer.toString());
    }
    AsyncHttpGet asyncHttpGet = new AsyncHttpGet(stringBuffer.toString());
    CacheControl cacheControl = request.getCacheControl();
    if (cacheControl != null) {
        asyncHttpGet.setHeader("Cache-Control", cacheControl.getCacheHeaderProperty());
    }
    addHead(request.getHeader(), asyncHttpGet);
    return asyncHttpClient.executeString(asyncHttpGet, new AsyncHttpClient.StringCallback() {
        @Override
        public void onCompleted(Exception e, AsyncHttpResponse asyncHttpResponse, String s) {
            if (responseCallback != null) {
                responseCallback.onCompleted(e, asyncHttpResponse, s);
            }
        }
    });
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:27，代码来源:HttpApi.java

示例4: doLongPolling

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
private void doLongPolling() {
    this.client.executeString(new AsyncHttpGet(computedRequestUrl()), new AsyncHttpClient.StringCallback() {
        @Override
        public void onCompleted(Exception e, AsyncHttpResponse source, String result) {
            if (e != null) {
                close(e);
                return;
            }

            sendResult(result);
            doLongPolling();
        }
    });
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:15，代码来源:XHRPollingTransport.java

示例5: testGithubHelloWithFutureCallback

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
public void testGithubHelloWithFutureCallback() throws Exception {
    final Semaphore semaphore = new Semaphore(0);
    client.executeString(new AsyncHttpGet("https://" + githubPath + "hello.txt"), null)
    .setCallback(new FutureCallback<String>() {
        @Override
        public void onCompleted(Exception e, String result) {
            assertEquals(result, "hello world");
            semaphore.release();
        }
    });
    assertTrue("timeout", semaphore.tryAcquire(TIMEOUT, TimeUnit.MILLISECONDS));
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:13，代码来源:HttpClientTests.java

示例6: testProxy

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的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();
        }
    }

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:30，代码来源:HttpClientTests.java

示例7: testKeys

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的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();
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:32，代码来源:SSLTests.java

示例8: disabled__testClientCertificateIssue163

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
public void disabled__testClientCertificateIssue163() throws Exception {
    // https://security.springthroughtest.com/hello.json

    AsyncServer server = new AsyncServer();
    try {
        AsyncHttpClient client = new AsyncHttpClient(server);
        JSONObject json = client.executeJSONObject(new AsyncHttpGet("https://security.springthroughtest.com/hello.json"), null).get();

    }
    finally {
        server.stop();
    }
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:14，代码来源:SSLTests.java

示例9: shareMyApp

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
public void  shareMyApp()
{
    String title ="精彩分享";
    String desc  = "我也有自己的App了：）";

    String url =
  FlyingDataManager.getServerNetAddress() +
  "/aa_get_app_info_from_hp.action?app_id=" +
  FlyingDataManager.getBirdcopyAppID() +
  "&type=page";

    try
    {
        String webURL= AsyncHttpClient.getDefaultInstance().executeString(new AsyncHttpGet(url),null).get();

        Intent shareIntent = new Intent(Intent.ACTION_SEND);
        shareIntent.setType("text/plain");

        shareIntent.putExtra(Intent.EXTRA_TITLE,  "分享精彩");
        shareIntent.putExtra(Intent.EXTRA_SUBJECT, title);
        shareIntent.putExtra(Intent.EXTRA_TEXT, title +"\n"+desc+"\n"+webURL);
        startActivity(Intent.createChooser(shareIntent, "分享精彩"));

        awardCoin();
        //MyApplication.getInstance().playCoinSound();
    }
    catch (Exception e)
    {
    }
}

开发者ID:birdcopy，项目名称:Android-Birdcopy-Application，代码行数:31，代码来源:MainActivity.java

示例10: get

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
public void get(String regex, HttpServerRequestCallback callback) {
    addAction(AsyncHttpGet.METHOD, regex, callback);
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:4，代码来源:AsyncHttpServer.java

示例11: onBodyDecoder

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
@Override
public void onBodyDecoder(OnBodyDataOnRequestSentData data) {
    CachedSocket cached = com.koushikdutta.async.Util.getWrappedSocket(data.socket, CachedSocket.class);
    if (cached != null) {
        data.response.headers().set(SERVED_FROM, CACHE);
        return;
    }

    CacheData cacheData = data.state.get("cache-data");
    RawHeaders rh = RawHeaders.fromMultimap(data.response.headers().getMultiMap());
    rh.removeAll("Content-Length");
    rh.setStatusLine(String.format(Locale.ENGLISH, "%s %s %s", data.response.protocol(), data.response.code(), data.response.message()));
    ResponseHeaders networkResponse = new ResponseHeaders(data.request.getUri(), rh);
    data.state.put("response-headers", networkResponse);
    if (cacheData != null) {
        if (cacheData.cachedResponseHeaders.validate(networkResponse)) {
            data.request.logi("Serving response from conditional cache");
            ResponseHeaders combined = cacheData.cachedResponseHeaders.combine(networkResponse);
            data.response.headers(new Headers(combined.getHeaders().toMultimap()));
            data.response.code(combined.getHeaders().getResponseCode());
            data.response.message(combined.getHeaders().getResponseMessage());

            data.response.headers().set(SERVED_FROM, CONDITIONAL_CACHE);
            conditionalCacheHitCount++;

            CachedBodyEmitter bodySpewer = new CachedBodyEmitter(cacheData.candidate, cacheData.contentLength);
            bodySpewer.setDataEmitter(data.bodyEmitter);
            data.bodyEmitter = bodySpewer;
            bodySpewer.sendCachedData();
            return;
        }

        // did not validate, so fall through and cache the response
        data.state.remove("cache-data");
        StreamUtility.closeQuietly(cacheData.snapshot);
    }

    if (!caching)
        return;

    RequestHeaders requestHeaders = data.state.get("request-headers");
    if (requestHeaders == null || !networkResponse.isCacheable(requestHeaders) || !data.request.getMethod().equals(AsyncHttpGet.METHOD)) {
        /*
         * Don't cache non-GET responses. We're technically allowed to cache
         * HEAD requests and some POST requests, but the complexity of doing
         * so is high and the benefit is low.
         */
        networkCount++;
        data.request.logd("Response is not cacheable");
        return;
    }

    String key = FileCache.toKeyString(data.request.getUri());
    RawHeaders varyHeaders = requestHeaders.getHeaders().getAll(networkResponse.getVaryFields());
    Entry entry = new Entry(data.request.getUri(), varyHeaders, data.request, networkResponse.getHeaders());
    BodyCacher cacher = new BodyCacher();
    EntryEditor editor = new EntryEditor(key);
    try {
        entry.writeTo(editor);
        // create the file
        editor.newOutputStream(ENTRY_BODY);
    }
    catch (Exception e) {
        // Log.e(LOGTAG, "error", e);
        editor.abort();
        networkCount++;
        return;
    }
    cacher.editor = editor;

    cacher.setDataEmitter(data.bodyEmitter);
    data.bodyEmitter = cacher;

    data.state.put("body-cacher", cacher);
    data.request.logd("Caching response");
    cacheStoreCount++;
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:78，代码来源:ResponseCacheMiddleware.java

示例12: testHomepage

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
public void testHomepage() throws Exception {
    Future<String> ret = client.executeString(new AsyncHttpGet("http://google.com"), null);
    assertNotNull(ret.get(TIMEOUT, TimeUnit.MILLISECONDS));
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:5，代码来源:HttpClientTests.java

示例13: testGithubRandomDataWithFuture

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
public void testGithubRandomDataWithFuture() throws Exception {
    final Md5 md5 = Md5.createInstance();
    Future<ByteBufferList> bb = client.executeByteBufferList(new AsyncHttpGet(github), null);
    md5.update(bb.get(TIMEOUT, TimeUnit.MILLISECONDS));
    assertEquals(md5.digest(), dataNameAndHash);
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:7，代码来源:HttpClientTests.java

示例14: testGithubHelloWithFuture

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
public void testGithubHelloWithFuture() throws Exception {
    Future<String> string = client.executeString(new AsyncHttpGet("https://" + githubPath + "hello.txt"), null);
    assertEquals(string.get(TIMEOUT, TimeUnit.MILLISECONDS), "hello world");
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:5，代码来源:HttpClientTests.java

示例15: testUriPathWithSpaces

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
public void testUriPathWithSpaces() throws Exception {
    AsyncHttpRequest request = new AsyncHttpRequest(Uri.parse("http://jpkc.seiee.sjtu.edu.cn/ds/ds2/Course%20lecture/chapter%2010.pdf"), AsyncHttpGet.METHOD);
    String requestLine = request.getRequestLine().toString();
    assertEquals("GET /ds/ds2/Course%20lecture/chapter%2010.pdf HTTP/1.1", requestLine);
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:6，代码来源:HttpClientTests.java

示例16: disabledTestSSLProxy

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
private void disabledTestSSLProxy() throws Exception {
    AsyncHttpGet get = new AsyncHttpGet("http://yahoo.com");
    get.enableProxy("192.168.2.21", 8888);
    get.setLogging("SSLProxy", Log.VERBOSE);
    String ret = AsyncHttpClient.getDefaultInstance().executeString(get, null).get(5000, TimeUnit.DAYS.MILLISECONDS);
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:7，代码来源:ProxyTests.java

示例17: testIon428

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
public void testIon428() throws Exception {
    ByteBufferList bb = AsyncHttpClient.getDefaultInstance().executeByteBufferList(new AsyncHttpGet("https://cdn2.vox-cdn.com/thumbor/KxtZNw37jKNfxdA0hX5edHvbTBE=/0x0:2039x1359/800x536/cdn0.vox-cdn.com/uploads/chorus_image/image/44254028/lg-g-watch.0.0.jpg"), null)
    .get();
}

开发者ID:jacklongway，项目名称:LiteSDK，代码行数:5，代码来源:Issue59.java

示例18: onBodyDecoder

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
@Override
public void onBodyDecoder(OnBodyDataOnRequestSentData data) {
    CachedSocket cached = com.koushikdutta.async.Util.getWrappedSocket(data.socket, CachedSocket.class);
    if (cached != null) {
        data.response.headers().set(SERVED_FROM, CACHE);
        return;
    }

    CacheData cacheData = data.state.get("cache-data");
    RawHeaders rh = RawHeaders.fromMultimap(data.response.headers().getMultiMap());
    rh.removeAll("Content-Length");
    rh.setStatusLine(String.format("%s %s %s", data.response.protocol(), data.response.code(), data.response.message()));
    ResponseHeaders networkResponse = new ResponseHeaders(data.request.getUri(), rh);
    data.state.put("response-headers", networkResponse);
    if (cacheData != null) {
        if (cacheData.cachedResponseHeaders.validate(networkResponse)) {
            data.request.logi("Serving response from conditional cache");
            ResponseHeaders combined = cacheData.cachedResponseHeaders.combine(networkResponse);
            data.response.headers(new Headers(combined.getHeaders().toMultimap()));
            data.response.code(combined.getHeaders().getResponseCode());
            data.response.message(combined.getHeaders().getResponseMessage());

            data.response.headers().set(SERVED_FROM, CONDITIONAL_CACHE);
            conditionalCacheHitCount++;

            CachedBodyEmitter bodySpewer = new CachedBodyEmitter(cacheData.candidate, cacheData.contentLength);
            bodySpewer.setDataEmitter(data.bodyEmitter);
            data.bodyEmitter = bodySpewer;
            bodySpewer.sendCachedData();
            return;
        }

        // did not validate, so fall through and cache the response
        data.state.remove("cache-data");
        StreamUtility.closeQuietly(cacheData.snapshot);
    }

    if (!caching)
        return;

    RequestHeaders requestHeaders = data.state.get("request-headers");
    if (requestHeaders == null || !networkResponse.isCacheable(requestHeaders) || !data.request.getMethod().equals(AsyncHttpGet.METHOD)) {
        /*
         * Don't cache non-GET responses. We're technically allowed to cache
         * HEAD requests and some POST requests, but the complexity of doing
         * so is high and the benefit is low.
         */
        networkCount++;
        data.request.logd("Response is not cacheable");
        return;
    }

    String key = FileCache.toKeyString(data.request.getUri());
    RawHeaders varyHeaders = requestHeaders.getHeaders().getAll(networkResponse.getVaryFields());
    Entry entry = new Entry(data.request.getUri(), varyHeaders, data.request, networkResponse.getHeaders());
    BodyCacher cacher = new BodyCacher();
    EntryEditor editor = new EntryEditor(key);
    try {
        entry.writeTo(editor);
        // create the file
        editor.newOutputStream(ENTRY_BODY);
    }
    catch (Exception e) {
        // Log.e(LOGTAG, "error", e);
        editor.abort();
        networkCount++;
        return;
    }
    cacher.editor = editor;

    cacher.setDataEmitter(data.bodyEmitter);
    data.bodyEmitter = cacher;

    data.state.put("body-cacher", cacher);
    data.request.logd("Caching response");
    cacheStoreCount++;
}

开发者ID:BeckNiu，项目名称:MyCar，代码行数:78，代码来源:ResponseCacheMiddleware.java

示例19: createGetRequest

import com.koushikdutta.async.http.AsyncHttpGet; //导入依赖的package包/类
AsyncHttpRequest createGetRequest() {
    return new AsyncHttpGet(createEndpointUri());
}

开发者ID:lavong，项目名称:SpockUnitTestsDemo，代码行数:4，代码来源:ContactsProvider.java

注：本文中的com.koushikdutta.async.http.AsyncHttpGet类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。