Javaで非同期でHTTPリクエストを投げたい

Question

Java(Spring)で外部APIにHTTPリクエストを投げたいのですが、そのAPIのレスポンスが遅いので処理に時間がかかります。

APIのレスポンスは処理にはつかわないので、投げっぱなしにして非同期で処理を進めるにはどのように実装したらよいでしょうか。

今はこのように実装しています

import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpMethod;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.web.client.HttpClientErrorException;
import org.springframework.web.client.RestClientException;
import org.springframework.web.client.RestTemplate;

/**
 * 外部APIリクエスト用のクラス.
 *
 * @author regpon
 * @version 0.0.1
 */
@Slf4j
@Component
@RequiredArgsConstructor
public class ExternalApiClient {
  /**
   * APIを呼び出す.
   *
   * @param url URI
   * @param entity HTTP request params
   * @param responseType レスポンスのクラスタイプ
   * @return APIレスポンス
   * @throws RestClientException RestClientエラー
   */
  public <T> T get(final String url,
      final HttpEntity<String> entity,
      final Class<T> responseType) throws RestClientException {
    RestTemplate restTemplate = this.restTemplate();
    try {
      ResponseEntity<T> res = restTemplate.exchange(url, HttpMethod.GET, entity, responseType);

      return res.getBody();
    } catch (HttpClientErrorException hcex) {
      // エラーレスポンスの場合
      log.warn("HttpClientErrorException exception=[{}]", hcex.toString());
      throw hcex;
    } catch (RestClientException rcex) {
      log.warn("RestClientException exception=[{}]", rcex.toString());
      throw rcex;
    }
  }
}

呼び出し元

  public void main(){
    // 中略
    // 外部API実行(パラレルで実行も可能)
    for (Data data : dataList) {
      // ここが遅い（1回につき5秒くらいかかる）
      getRequestData(url, detail.getDataId());
    }
    // 中略
  }

  private void getRequestData(String url, Long id) {
    HttpHeaders headers = new HttpHeaders();
    headers.setContentType(MediaType.APPLICATION_JSON);
    HttpEntity<String> entity = new HttpEntity<>(headers);

    String params = "id=" + id.toString();

    // resは使わない
    Map res = externalApiClient
        .get(url + "?" + params,
            entity,
            Map.class
        );
  }

呼び出し元側でもパラレルで叩いてもOKですが、
そもそもが遅いのでレスポンスを使わないなら投げっぱなしで処理を進めたいのですが可能でしょうか？

Answer 1

Springのクラスから非同期にリクエストを投げて、特にそのレスポンスを利用しないなら、HTTPリクエストを実行するクラスに@Asyncを付けるだけです。

@EnableAsyncをアプリケーション設定に付与してください。

Answer 2

Threadクラスでも使って、非同期で投げてしまえばいいだけのような気がしますが。

new Thread(() -> {
        getRequestData(url, detail.getDataId());
        }).start();

Comments

[退会済みユーザー]

すみません、その単純なことがわかっていませんでした。
助かりました