URLからファイルを非同期ダウンロードする

//取得対象データ（サンプルはロト７の抽選結果）
String[] urlStrings = {
        "https://www.mizuhobank.co.jp/retail/takarakuji/loto/loto7/csv/A1030001.CSV",
        "https://www.mizuhobank.co.jp/retail/takarakuji/loto/loto7/csv/A1030002.CSV",
        "https://www.mizuhobank.co.jp/retail/takarakuji/loto/loto7/csv/A1030003.CSV",
        ...
};

//最大nスレッド（サンプルでは5）のスレッドプールを作成する
ExecutorService executor = Executors.newFixedThreadPool(5);

//複数のダウンロードを並列に実行する例
for(String s : urlStrings) {

    URL url = URI.create(s).toURL();
    String path = url.getPath();
    String name = path.substring(path.lastIndexOf("/") + 1);

    //スレッドプール内でタスクを実行する
    executor.execute(() -> {
        try {
            System.out.println("start. " + url);
            //NIO2を使ってファイル保存する例
            long size = Files.copy(url.openStream(),
                    Paths.get(name),
                    REPLACE_EXISTING);
            System.out.println("complete. " + name + " - " + size + " bytes");
        } catch (IOException e) {
            //error handling
        }
    });
}

//シャットダウンを開始して、これ以降のタスクは受け付けない
executor.shutdown();
//全タスクが完了するかタイムアウトするまでブロックする
executor.awaitTermination(10, TimeUnit.SECONDS);

<!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/httpclient -->
<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
    <version>4.5.10</version>
</dependency>

<!-- https://mvnrepository.com/artifact/org.apache.httpcomponents/fluent-hc -->
<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>fluent-hc</artifactId>
    <version>4.5.10</version>
</dependency>

//取得対象データ（サンプルはロト７の抽選結果）
String[] inUrl = {
        "https://www.mizuhobank.co.jp/retail/takarakuji/loto/loto7/csv/A1030001.CSV",
        "https://www.mizuhobank.co.jp/retail/takarakuji/loto/loto7/csv/A1030002.CSV",
        "https://www.mizuhobank.co.jp/retail/takarakuji/loto/loto7/csv/A1030003.CSV",
        ...
};

//最大nスレッド（サンプルでは5）のスレッドプールを作成する
ExecutorService executor = Executors.newFixedThreadPool(5);

//複数のダウンロードを並列に実行する例
for (String url : inUrl) {

    String path = URI.create(url).getPath();
    String name = path.substring(path.lastIndexOf("/") + 1);

    Async async = Async.newInstance().use(executor);

    //対象のURLに接続するタスクを送信する
    Future future = async.execute(Request.Get(url), new FutureCallback() {

        //対象のURLからのデータ取得が完了した場合の挙動
        @Override
        public void completed(Content content) {
            try {
                //NIO2を使ってファイル保存する例
                long size = Files.copy(content.asStream(),
                        Paths.get(name),
                        StandardCopyOption.REPLACE_EXISTING);
                System.out.println("completed. " + name + " - " + size + " bytes");
            } catch (IOException e) {
                e.printStackTrace();
            }
        }

        @Override
        public void failed(Exception e) {
            System.out.println("failed.");
        }

        @Override
        public void cancelled() {
            System.out.println("cancelled.");
        }
    });

    System.out.println("started. " + url);
}

//シャットダウンを開始して、これ以降のタスクは受け付けない
executor.shutdown();
//全タスクが完了するかタイムアウトするまでブロックする
executor.awaitTermination(10, TimeUnit.SECONDS);

<!-- https://mvnrepository.com/artifact/org.asynchttpclient/async-http-client -->
<dependency>
    <groupId>org.asynchttpclient</groupId>
    <artifactId>async-http-client</artifactId>
    <version>2.10.4</version>
</dependency>

//取得対象データ（サンプルはロト７の抽選結果）
String[] inUrl = {
        "https://www.mizuhobank.co.jp/retail/takarakuji/loto/loto7/csv/A1030001.CSV",
        "https://www.mizuhobank.co.jp/retail/takarakuji/loto/loto7/csv/A1030002.CSV",
        "https://www.mizuhobank.co.jp/retail/takarakuji/loto/loto7/csv/A1030003.CSV",
        ...
};

AsyncHttpClient client = Dsl.asyncHttpClient();
List futures = new ArrayList();

for (String url : inUrl) {

    String path = URI.create(url).getPath();
    String name = path.substring(path.lastIndexOf("/") + 1);

    //対象URLへ接続するリクエスト
    Request request = Dsl.request(HttpConstants.Methods.GET, url).build();
    
    //リクエストが完了した場合のハンドラを指定して非同期で実行
    ListenableFuture f = client.executeRequest(request,
            new AsyncCompletionHandler() {
                @Override
                public Long onCompleted(Response response) throws Exception {
                    //リクエストが完了した時はレスポンスをファイルに保存
                    long size = Files.copy(response.getResponseBodyAsStream(),
                            Paths.get(name),
                            StandardCopyOption.REPLACE_EXISTING);
                    System.out.println("completed. " + name + " - " + size + " bytes");
                    return size;
                }
            });
    System.out.println("started. " + url);

    //後述のCompletableFutureで使用
    futures.add(f.toCompletableFuture());
}

//すべてのタスクが完了してからClientを閉じる
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0]))
        .whenComplete((r, e) -> {
            try {
                client.close();
            } catch (IOException ex) {
                //error handling
            }
        });

if (response.getStatusCode() != 200) {
    //Not HTTP_OK
}

AsyncHttpClientConfig config = Dsl.config()
        .setConnectTimeout(10)
        .setReadTimeout(15)
        .build();
AsyncHttpClient client = Dsl.asyncHttpClient(config);