[java] 자바 비동기 IO를 사용한 동시 다운로드 처리 방법

04 Dec 2023

java

오늘은 자바 프로그래밍에서 비동기 IO를 활용하여 동시에 여러 파일을 다운로드하는 방법에 대해 알아보겠습니다.

비동기 IO란?

자바에서 비동기 IO는 입출력 작업을 블로킹하지 않고(non-blocking) 백그라운드에서 처리하는 방식입니다. 이를 통해 다른 작업을 동시에 수행할 수 있으며, IO 작업이 느리거나 대량의 데이터를 다룰 때 유용합니다.

Maven 의존성 추가

비동기 IO를 사용하기 위해 Maven 프로젝트에 다음 의존성을 추가해야 합니다.

<dependency>
    <groupId>org.asynchttpclient</groupId>
    <artifactId>async-http-client</artifactId>
    <version>2.12.3</version>
</dependency>

동시 다운로드 처리 예제

다음은 비동기 IO를 사용하여 여러 파일을 동시에 다운로드하는 예제 코드입니다.

import org.asynchttpclient.AsyncHttpClient;
import org.asynchttpclient.DefaultAsyncHttpClient;
import org.asynchttpclient.ListenableFuture;
import org.asynchttpclient.Response;

import java.util.ArrayList;
import java.util.List;

public class ConcurrentDownloader {
    private AsyncHttpClient asyncHttpClient;

    public ConcurrentDownloader() {
        asyncHttpClient = new DefaultAsyncHttpClient();
    }

    public List<ListenableFuture<Response>> downloadFiles(List<String> urls) {
        List<ListenableFuture<Response>> futures = new ArrayList<>();

        for (String url : urls) {
            ListenableFuture<Response> future = asyncHttpClient.prepareGet(url).execute();
            futures.add(future);
        }

        return futures;
    }

    public void close() {
        asyncHttpClient.close();
    }

    public static void main(String[] args) throws Exception {
        ConcurrentDownloader downloader = new ConcurrentDownloader();

        List<String> urls = new ArrayList<>();
        urls.add("https://example.com/file1.txt");
        urls.add("https://example.com/file2.txt");
        urls.add("https://example.com/file3.txt");

        List<ListenableFuture<Response>> futures = downloader.downloadFiles(urls);

        // 각 다운로드 작업의 완료를 기다리기 위해 get 메서드를 호출합니다.
        for (ListenableFuture<Response> future : futures) {
            Response response = future.get();
            System.out.println("다운로드 완료: " + response.getResponseBody());
        }

        downloader.close();
    }
}

위 예제 코드에서는 AsyncHttpClient를 사용하여 비동기로 파일을 다운로드합니다. downloadFiles 메서드는 주어진 URL 목록에 대해 비동기 다운로드 작업을 생성하고, ListenableFuture 객체를 반환합니다.

main 메서드에서는 다운로드 작업의 완료를 기다리기 위해 get 메서드를 호출하고, 각 다운로드 결과를 출력합니다.

결론

자바에서 비동기 IO를 사용하여 여러 파일을 동시에 다운로드하는 방법을 알아보았습니다. 비동기 IO를 활용하면 IO 작업을 효율적으로 처리할 수 있으며, 다른 작업과 동시에 처리할 수 있습니다.

이러한 비동기 처리 방식은 대량의 데이터 다운로드나 병렬 처리가 필요한 상황에서 매우 유용합니다.