Java案例如何实现网络请求？

wen java案例 2026-06-11 11

Java案例如何实现网络请求？从零到实战的完整指南

目录导读

引言：为什么Java开发者必须掌握网络请求？
Java网络请求的基础原理与HTTP协议要点
原生API实现：HttpURLConnection案例详解
主流框架实战：Apache HttpClient与OkHttp对比
异步与响应式请求：从CompletableFuture到WebClient
常见问题深度问答（Q&A）
性能优化与最佳实践
总结与延伸学习方向

引言：为什么Java开发者必须掌握网络请求？

在今天的分布式架构与微服务时代,网络请求是Java应用与外界交互的“生命线”，无论是调用第三方REST API、采集数据、实现服务间通信，还是对接云服务，都离不开高效、稳定的网络请求能力，许多初级开发者往往只知道使用HttpURLConnection，却不知如何应对超时、重试、连接池管理等真实场景问题，本文将通过循序渐进的Java案例，带你透彻理解并实现高标准网络请求。

Java案例如何实现网络请求？

Java网络请求的基础原理与HTTP协议要点

HTTP请求的生命周期

Java发起一次HTTP请求,本质上遵循TCP/IP协议栈：

DNS解析域名得到IP
建立TCP三次握手连接
发送HTTP请求报文（请求行、请求头、请求体）
服务端处理并返回HTTP响应报文
完成四次挥手断开连接（或复用Keep-Alive连接）

关键概念速览

请求方法：GET（获取）、POST（创建）、PUT（全量更新）、PATCH（部分更新）、DELETE（删除）
请求头：Content-Type、Authorization（JWT/Token）、User-Agent、Accept
状态码：200成功、301/302重定向、400客户端错误、500服务端错误
连接池：复用TCP连接减少握手开销，提升吞吐量

原生API实现：HttpURLConnection案例详解

经典案例：通过HttpURLConnection调用公开天气API获取数据

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
public class WeatherFetcher {
    public static String fetchWeather(String cityCode) throws Exception {
        String apiUrl = "https://api.weather.cn/v1/city?code=" + cityCode;
        URL url = new URL(apiUrl);
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
        // 设置请求属性
        conn.setRequestMethod("GET");
        conn.setRequestProperty("User-Agent", "Mozilla/5.0");
        conn.setConnectTimeout(5000);
        conn.setReadTimeout(5000);
        // 获取响应码
        int responseCode = conn.getResponseCode();
        if (responseCode != 200) {
            throw new RuntimeException("请求失败，状态码：" + responseCode);
        }
        // 读取响应体
        BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
        String inputLine;
        StringBuilder response = new StringBuilder();
        while ((inputLine = in.readLine()) != null) {
            response.append(inputLine);
        }
        in.close();
        conn.disconnect();
        return response.toString();
    }
    public static void main(String[] args) throws Exception {
        System.out.println(fetchWeather("101010100"));
    }
}

原生API的优缺点

优势	劣势
无需额外依赖	代码冗长，需手动管理连接
适合简单请求	不支持连接池、自动重试
学习成本低	性能不如专业HTTP库

主流框架实战：Apache HttpClient与OkHttp对比

使用Apache HttpClient发送POST JSON请求

import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.StringEntity;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
public class HttpClientPostExample {
    public static String sendJsonPost(String url, String jsonBody) throws Exception {
        try (CloseableHttpClient client = HttpClients.createDefault()) {
            HttpPost httpPost = new HttpPost(url);
            httpPost.setHeader("Content-Type", "application/json");
            httpPost.setEntity(new StringEntity(jsonBody));
            // 执行请求并获取响应
            return client.execute(httpPost, response -> 
                EntityUtils.toString(response.getEntity())
            );
        }
    }
}

OkHttp实现带拦截器的请求（生产级）

import okhttp3.*;
public class OkHttpExample {
    // 创建单例Client，内部自动管理连接池
    private static final OkHttpClient client = new OkHttpClient.Builder()
        .connectTimeout(10, TimeUnit.SECONDS)
        .readTimeout(10, TimeUnit.SECONDS)
        .addInterceptor(chain -> {
            // 添加统一日志拦截器
            Request request = chain.request().newBuilder()
                .addHeader("X-Request-ID", UUID.randomUUID().toString())
                .build();
            return chain.proceed(request);
        })
        .build();
    public String get(String url) throws IOException {
        Request request = new Request.Builder().url(url).get().build();
        try (Response response = client.newCall(request).execute()) {
            return response.body().string();
        }
    }
}

主流框架对比表

特性	Apache HttpClient	OkHttp	Spring WebClient
连接池	支持（PoolingHttpClientConnectionManager）	内建（5个/域名）	内建（Reactor Netty）
异步支持	需要额外封装	内建异步Call	原生响应式
内存占用	中等	低	较高（但适合高并发）
社区活跃度	传统，更新较慢	活跃，Android首选	Spring生态标配

选型建议：

小型项目或Android开发：OkHttp
传统企业SSH项目：Apache HttpClient
Spring Boot微服务：WebClient（推荐升级HttpsURLConnection）

异步与响应式请求：从CompletableFuture到WebClient

案例：使用WebClient发起非阻塞请求（Spring WebFlux）

import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;
public class ReactiveHttpClient {
    private final WebClient webClient = WebClient.create("http://api.example.com");
    public Mono<String> fetchAsync(String path) {
        return webClient.get()
            .uri("/data/{path}", path)
            .retrieve()
            .bodyToMono(String.class)
            .timeout(Duration.ofSeconds(10))
            .doOnError(error -> System.err.println("请求异常: " + error.getMessage()));
    }
}

优势：

单线程可处理数千并发连接（基于Netty事件循环）
天然支持背压（Backpressure）
完美对接Spring Cloud Gateway等网关组件

注意事项：

需要Spring WebFlux环境（非传统Servlet容器）
调试时链路追踪需要额外配置（如Zipkin）

常见问题深度问答（Q&A）

Q1: 为什么我使用HttpURLConnection请求HTTPS时报SSLHandshakeException？

A: 常见原因包括：

JDK版本过低,不支持TLS 1.2以上协议（Java 6/7需手动启用）
服务器证书链不完整或使用了自签名证书
缺少JCE无限强度策略文件（某些Java 8版本）

解决方案：

升级JDK到11+，自动支持TLS 1.3

对于测试环境,可临时信任所有证书（生产环境严禁！）：

TrustManager[] trustAllCerts = new TrustManager[]{
  new X509TrustManager() { ... }
};
SSLContext sc = SSLContext.getInstance("TLS");
sc.init(null, trustAllCerts, new SecureRandom());
HttpsURLConnection.setDefaultSSLSocketFactory(sc.getSocketFactory());

Q2: 如何优雅地实现请求重试机制？

A: 可以使用OkHttp的拦截器或Spring Retry：

// Spring Retry示例
@Retryable(value = {IOException.class}, maxAttempts = 3, backoff = @Backoff(delay = 2000))
public String callWithRetry() { ... }

最佳实践：

仅对幂等请求（GET、PUT）重试
添加指数退避（Exponential Backoff）避免雪崩
记录重试日志以便监控

Q3: 大文件下载如何防止内存溢出？

A: 使用流式传输（streaming）：

// OkHttp流式下载
Request request = new Request.Builder().url(url).build();
Response response = client.newCall(request).execute();
try (BufferedSink sink = Okio.buffer(Okio.sink(new File("local.mp4")))) {
    sink.writeAll(response.body().source());
}

关键点：不调用body().string()，而是直接通过source()管道写入文件。

性能优化与最佳实践

统一连接池配置

OkHttp默认每域名5个连接,高并发需调大：

new OkHttpClient.Builder()
  .connectionPool(new ConnectionPool(20, 5, TimeUnit.MINUTES))

启用HTTP/2协议
OkHttp和Netty都自动支持HTTP/2，可减少头部开销，提升多路复用效率。
合理设置超时
- 连接超时：2~5秒
- 读取超时：根据业务需求（一般5~15秒）
- 写入超时：PUT/POST大文件时需增大
使用JSON序列化优化
- 优先使用Jackson或Gson的ObjectMapper复用单例
- 避免在请求循环中重复创建ObjectMapper
异常分类处理
- 网络异常（SocketTimeoutException、ConnectException）→重试
- 业务异常（400、500）→解析错误体并记录
- 请求中断（IOException）→立即释放资源