Java - OkHttpからの結果の取得非同期GET

Question

私はSpringブートでweb-appを持っています。また、多くのHTTPリクエストをAPIに渡す部分があり、リクエストが多すぎるとタイムアウトしているようです。同期の要求から非同期の要求への切り替えがこの問題に役立つかもしれないと聞きました。 OkHttpを使用して

、これは私の同期GETリクエストは次のようになります。

private JSONObject run(String url) throws Exception { 
    Request newRequest = new Request.Builder() 
      .url(url) 
      .addHeader("Authorization", token) 
      .build(); 

    try (Response response = client.newCall(newRequest).execute()) { 
     if (!response.isSuccessful()) throw new IOException("Unexpected code " + response); 
     return new JSONObject(response.body().string()); 

    } 
} 

私はレスポンスボディを解析からJSONオブジェクトとして応答を返します。しかし、OkHttp非同期呼び出しを使用しようとして、私は同じアプローチを使用することはできないようです。これは私がこれまで持っているものです。

public void runAsync(String url) throws Exception { 
    Request request = new Request.Builder() 
      .url(url) 
      .addHeader("Authorization", token) 
      .build(); 

    client.newCall(request).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); 

      System.out.println(response.body().string()); 
     } 
    }); 
} 

応答は、ボイドの戻り値を持つコールバックメソッドの内部でラップされているように私は単純に、JSONとして結果を返すことができません。応答を抽出する私の同期GETに似た結果を得る方法についてのアイデアはありますか？

Answer 1

私はSpring Bootのユーザーではないので、これは完全な答えではありません。しかし、それが未来を返すことをサポートすれば、OkHttpコールバックから未来への橋渡しは簡単です。

これが関連する可能性があるhttps://spring.io/guides/gs/async-method/

public class OkHttpResponseFuture implements Callback { 
    public final CompletableFuture<Response> future = new CompletableFuture<>(); 

    public OkHttpResponseFuture() { 
    } 

    @Override public void onFailure(Call call, IOException e) { 
    future.completeExceptionally(e); 
    } 

    @Override public void onResponse(Call call, Response response) throws IOException { 
    future.complete(response); 
    } 
} 

そして未来を製造するようエンキューあなたがそれらを提出することができます処理するために複数の要求がある場合

OkHttpResponseFuture callback = new OkHttpResponseFuture(); 
    client.newCall(request).enqueue(callback); 

    return callback.future.thenApply(response -> { 
    try { 
     return convertResponse(response); 
    } catch (IOException e) { 
     throw Throwables.propagate(e); 
    } finally { 
     response.close(); 
    } 
    }); 

ような仕事何か別々にしてから、すべての結果が利用可能になるのを待ってから組み合わせて返信してください。

public static <T> CompletableFuture<List<T>> join(List<CompletableFuture<T>> futures) { 
    CompletableFuture[] cfs = futures.toArray(new CompletableFuture[futures.size()]); 

    return CompletableFuture.allOf(cfs) 
     .thenApply(v -> combineIndividualResults(c)); 
    }