使用okhttp3发出多个异步HTTP 2.0请求

Question

    OkHttpClient client = new OkHttpClient();

public void AsyncGet(String url) throws Exception {

    Request request = new Request.Builder().url(url).build();

    Call call = client.newCall(request);

    call.enqueue(new Callback() {
        @Override
        public void onFailure(Call call, IOException e) {
            e.printStackTrace();
        }

        @Override
        public void onResponse(Call call, Response response) throws IOException {
            if (!response.isSuccessful()) {
                throw new IOException("Unexpected code " + response);
            }
            new Thread() {
                @Override
                public void run() {
                    /* Some code */
                }
            }.start();
        }
    });

}

public Response SyncGet(String url) throws Exception {

    Request request = new Request.Builder().url(url).build();

    Call call = client.newCall(request);
    Response response = call.execute();

    if (!response.isSuccessful()) {
        throw new IOException("Unexpected code " + response);
    }

    return response;
}

AsyncGet(Url);
AsyncGet(Url2);

但是，如下所示的调用序列使用相同的TCP连接。

SyncGet(Url);
AsyncGet(Url);
AsyncGet(Url2);

我还没有对此进行调试，但OkHttp似乎迫使我们首先在主线程上发出阻塞HTTP请求，以获得TCP连接上下文，然后与其他线程共享该上下文？或者，我是不是漏掉了什么？

Answer 1

您可以调用async to并为以后的每个调用设置扇区，根据扇区可以区分调用的响应。试试这个代码；希望对你有帮助！

为api调用创建一个单独的类：

public class RestApi {

    protected RestApiResponse serverResponse;
    protected Context c;

    public RestApi(RestApiResponse serverResponse, Context c) {
        this.serverResponse = serverResponse;
        this.c = c;
    }

    public void postDataWithoutAuth(String url,String sector) {


        OkHttpClient client = new OkHttpClient();

        Request request = new Request.Builder()
    .url("http://publicobject.com/helloworld.txt")
    .build();

        client.newCall(request).enqueue(new Callback() {
            @Override
            public void onFailure(Call call, IOException e) {
                Log.e("response", call.request().body().toString());
                serverResponse.onErrorLoaded(call.request().body().toString(), sector);
            }

            @Override
            public void onResponse(Call call, Response response) throws IOException {
                serverResponse.onResponseLoaded(response, sector);
            }


        });
    }
}

然后为回调创建接口

public interface RestApiResponse {

    public void onResponseLoaded(Response response, String sector);

    public void onErrorLoaded(String response, String sector);
} 

RestApi apicall = new RestApi(this, getBaseContext());
apicall.postDataWithoutAuthUrlEncoded("ur url","your sector");