当前位置：首页 > Java

java如何异步请求

2026-03-22 05:03:32Java

异步请求的实现方式

在Java中实现异步请求可以通过多种方式，包括使用多线程、CompletableFuture、回调机制或第三方库如AsyncHttpClient。以下是几种常见方法：

使用`CompletableFuture`

CompletableFuture是Java 8引入的异步编程工具，适合处理非阻塞任务。以下示例展示如何通过CompletableFuture发起异步HTTP请求：

import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.net.URI;
import java.util.concurrent.CompletableFuture;

public class AsyncHttpExample {
    public static void main(String[] args) {
        HttpClient client = HttpClient.newHttpClient();
        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create("https://example.com/api"))
                .build();

        CompletableFuture<HttpResponse<String>> future = 
            client.sendAsync(request, HttpResponse.BodyHandlers.ofString());

        future.thenAccept(response -> {
            System.out.println("Response status: " + response.statusCode());
            System.out.println("Response body: " + response.body());
        });

        // 主线程继续执行其他任务
        System.out.println("Async request sent, waiting for response...");
    }
}

使用`AsyncHttpClient`

第三方库如AsyncHttpClient简化了异步HTTP请求的实现：

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

import java.util.concurrent.Future;

public class AsyncHttpClientExample {
    public static void main(String[] args) throws Exception {
        try (AsyncHttpClient client = new DefaultAsyncHttpClient()) {
            Future<Response> future = client.prepareGet("https://example.com/api")
                    .execute();

            // 阻塞获取结果（实际场景中应使用回调）
            Response response = future.get();
            System.out.println(response.getResponseBody());
        }
    }
}

回调机制

通过回调处理异步结果，避免阻塞主线程：

java如何异步请求

import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.net.URI;

public class CallbackExample {
    public static void main(String[] args) {
        HttpClient client = HttpClient.newHttpClient();
        HttpRequest request = HttpRequest.newBuilder()
                .uri(URI.create("https://example.com/api"))
                .build();

        client.sendAsync(request, HttpResponse.BodyHandlers.ofString())
              .thenApply(HttpResponse::body)
              .thenAccept(body -> System.out.println("Response: " + body))
              .exceptionally(ex -> {
                  System.err.println("Error: " + ex.getMessage());
                  return null;
              });

        System.out.println("Request sent asynchronously");
    }
}