如何在Java中进行异步REST api调用？

import org.apache.http.HttpEntity;
import org.apache.http.client.config.RequestConfig;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.nio.client.CloseableHttpAsyncClient;
import org.apache.http.impl.nio.client.HttpAsyncClients;
import org.apache.http.nio.client.methods.HttpAsyncMethods;
import org.apache.http.nio.protocol.BasicAsyncResponseConsumer;
import org.apache.http.protocol.BasicHttpContext;
import org.apache.http.protocol.HttpContext;

import java.io.IOException;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;

public class AsyncRestApiCallExample {
    public static void main(String[] args) throws ExecutionException, InterruptedException {
        // 创建异步HTTP客户端对象
        CloseableHttpAsyncClient client = HttpAsyncClients.createDefault();

        // 启动异步客户端
        client.start();

        // 创建HTTP请求对象
        HttpGet request = new HttpGet("https://api.example.com/users/1");

        // 设置请求超时时间
        RequestConfig requestConfig = RequestConfig.custom()
                .setConnectTimeout(5000)
                .setSocketTimeout(5000)
                .build();
        request.setConfig(requestConfig);

        // 发起异步请求
        HttpContext context = new BasicHttpContext();
        CompletableFuture<HttpEntity> future = new CompletableFuture<>();
        client.execute(HttpAsyncMethods.create(request), new BasicAsyncResponseConsumer(), context, new CompletableFutureCallback(future));

        // 获取异步响应结果
        HttpEntity response = future.get();

        // 处理异步响应结果
        // ...

        // 关闭异步客户端
        try {
            client.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    // 自定义回调接口实现
    static class CompletableFutureCallback implements org.apache.http.concurrent.FutureCallback<HttpEntity> {
        private final CompletableFuture<HttpEntity> future;

        public CompletableFutureCallback(CompletableFuture<HttpEntity> future) {
            this.future = future;
        }

        @Override
        public void completed(HttpEntity result) {
            future.complete(result);
        }

        @Override
        public void failed(Exception ex) {
            future.completeExceptionally(ex);
        }

        @Override
        public void cancelled() {
            future.cancel(true);
        }
    }
}