Spring boot에서 Http request 비동기 요청하기

Spring boot로 http request 코드를 개발할 때 비동기 처리로 요청 및 처리하기위한 내용입니다.

동기방식으로 호출하게되면 앞에 호출된 request의 응답이 완료될 때까지 다음요청이 실행되지 못하게되므로

여러개의 request를 보내는 상황에서는 더 높은 효율을 보여줍니다.

 

이 글에선 http 라이브러리는 okhttp3 를 사용합니다.

 

build.gradle에 의존성 추가

implementation 'com.squareup.okhttp3:okhttp:3.10.0'

 

코드작성 (비동기 요청)

public class Helloworld {
	private void asyncOkHttp() {
    	// http 요청하려는 URL 리스트가 있다고 가정
        List<String> requestUrls = new ArrayList<>();
        requestUrls.add("https://111...");
        requestUrls.add("https://222...");
        requestUrls.add("https://333...");
        
    	OkHttpClient client = new OkHttpClient().newBuilder().build();
        
        for (String url : requestUrls) {
            Request request = new Request.Builder()
                    .url(url)
                    .method("GET", null)
                    .build();

            client.newCall(request).enqueue(new Callback() {
                @Override
                public void onFailure(Call call, IOException e) {
                	// request 요청 실패 응답에 대한 처리
                }

                @Override
                public void onResponse(Call call, Response response) {
                    if (response.isSuccessful()) {
                        // request 요청 성공 응답에 대한 처리
                    }
                }
            });
        }
    }
}

(참고로 동기 요청은 enqueue 메서드 대신 execute 메서드를 사용합니다.)

 

 

 추가로 Request_Limit_Exceeded 라고해서 동일한 IP에서 너무 짧은 간격으로 Request를 요청할 시에 요청자체를 거부하는 경우가 있는데 해당 상황을 해결하기 위해 사용했던 부분도 공유합니다.

 

코드작성 (비동기 요청 + Dispatcher)

public class Helloworld {
	private void asyncOkHttp() {
    	// http 요청하려는 URL 리스트가 있다고 가정
        List<String> requestUrls = new ArrayList<>();
        requestUrls.add("https://111...");
        requestUrls.add("https://222...");
        requestUrls.add("https://333...");
        
        // dispatcher를 생성하여 최대 호출 수를 제어
        Dispatcher dispatcher = new Dispatcher();
        dispatcher.setMaxRequests(50);
        OkHttpClient client = new OkHttpClient().newBuilder().dispatcher(dispatcher).build();

        for (String url : requestUrls) {
            Request request = new Request.Builder()
                    .url(url)
                    .method("GET", null)
                    .build();

            client.newCall(request).enqueue(new Callback() {
                @Override
                public void onFailure(Call call, IOException e) {
                	// request 요청 실패 응답에 대한 처리
                }

                @Override
                public void onResponse(Call call, Response response) {
                    if (response.isSuccessful()) {
                        // request 요청 성공 응답에 대한 처리
                    }
                }
            });
        }
    }
}

사용방법은 크게 다르지 않고 client 객체 build시에 dispatcher를 추가해준 채로 생성해주면 됩니다. 각 디스패처는 ExecutorService를 사용하여 내부적으로 호출을 실행합니다.