Java设置请求响应时间的多种实现方式

import java.net.HttpURLConnection;
import java.net.URL;

public class HttpTimeoutExample {
    public static void main(String[] args) {
        try {
            URL url = new URL("https://example.com/api/data");
            HttpURLConnection connection = (HttpURLConnection) url.openConnection();

            // 设置连接超时（单位：毫秒）
            connection.setConnectTimeout(5000); // 5秒

            // 设置读取超时（单位：毫秒）
            connection.setReadTimeout(10000); // 10秒

            // 发送请求
            connection.setRequestMethod("GET");
            int responseCode = connection.getResponseCode();
            System.out.println("Response Code: " + responseCode);

            // 处理响应数据...
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

<dependency>
    <groupId>org.apache.httpcomponents.client5</groupId>
    <artifactId>httpclient5</artifactId>
    <version>5.1</version>
</dependency>

import org.apache.hc.client5.http.classic.methods.HttpGet;
import org.apache.hc.client5.http.classic.methods.HttpUriRequest;
import org.apache.hc.client5.http.impl.classic.CloseableHttpClient;
import org.apache.hc.client5.http.impl.classic.CloseableHttpResponse;
import org.apache.hc.client5.http.impl.classic.HttpClients;
import org.apache.hc.core5.http.io.entity.EntityUtils;
import org.apache.hc.core5.util.Timeout;

import java.util.concurrent.TimeUnit;

public class HttpClientTimeoutExample {
    public static void main(String[] args) {
        try (CloseableHttpClient httpClient = HttpClients.custom()
                .setConnectionTimeout(Timeout.of(5, TimeUnit.SECONDS)) // 连接超时
                .setResponseTimeout(Timeout.of(10, TimeUnit.SECONDS))  // 响应超时
                .build()) {

            HttpUriRequest request = new HttpGet("https://example.com/api/data");
            try (CloseableHttpResponse response = httpClient.execute(request)) {
                System.out.println("Response Code: " + response.getCode());
                String responseBody = EntityUtils.toString(response.getEntity());
                System.out.println("Response Body: " + responseBody);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

import org.springframework.http.client.HttpComponentsClientHttpRequestFactory;
import org.springframework.web.client.RestTemplate;

public class RestTemplateTimeoutExample {
    public static void main(String[] args) {
        // 创建RequestFactory并设置超时
        HttpComponentsClientHttpRequestFactory factory = new HttpComponentsClientHttpRequestFactory();
        factory.setConnectTimeout(5000); // 连接超时 5秒
        factory.setReadTimeout(10000);   // 读取超时 10秒

        // 创建RestTemplate
        RestTemplate restTemplate = new RestTemplate(factory);

        // 发送请求
        String url = "https://example.com/api/data";
        String response = restTemplate.getForObject(url, String.class);
        System.out.println("Response: " + response);
    }
}

import org.springframework.web.reactive.function.client.WebClient;
import reactor.netty.http.client.HttpClient;
import java.time.Duration;

public class WebClientTimeoutExample {
    public static void main(String[] args) {
        // 配置HttpClient
        HttpClient httpClient = HttpClient.create()
                .responseTimeout(Duration.ofSeconds(10)); // 响应超时 10秒

        // 创建WebClient
        WebClient webClient = WebClient.builder()
                .clientConnector(new ReactorClientHttpConnector(httpClient))
                .build();

        // 发送请求
        String url = "https://example.com/api/data";
        String response = webClient.get()
                .uri(url)
                .retrieve()
                .bodyToMono(String.class)
                .block(); // 阻塞获取结果
        System.out.println("Response: " + response);
    }
}

const controller = new AbortController();
const signal = controller.signal;

// 设置超时
setTimeout(() => controller.abort(), 10000); // 10秒超时

fetch('https://example.com/api/data', { signal })
    .then(response => response.json())
    .then(data => console.log(data))
    .catch(err => console.error('Request failed:', err));

const xhr = new XMLHttpRequest();
xhr.open('GET', 'https://example.com/api/data', true);

// 设置超时
xhr.timeout = 10000; // 10秒超时

xhr.onload = function () {
    if (xhr.status === 200) {
        console.log(xhr.responseText);
    }
};
xhr.ontimeout = function () {
    console.error('Request timed out');
};
xhr.send();