Android网络编程：HttpURLConnection到Retrofit2实战指南

1. Android网络编程基础与核心组件在移动应用开发中网络通信能力是衡量应用质量的重要指标。Android平台提供了多种网络通信方案从基础的HttpURLConnection到高级的Retrofit2框架形成了一个完整的网络编程技术栈。这些技术各有特点适用于不同场景HttpURLConnectionAndroid内置的标准HTTP客户端无需额外依赖库OkHttpSquare公司开发的高效HTTP客户端支持HTTP/2和连接池Retrofit2基于OkHttp的类型安全REST客户端大幅简化API调用JSON处理网络通信中最常用的数据交换格式提示选择网络库时需要考虑应用规模、团队熟悉度和功能需求。小型项目可以从HttpURLConnection开始中大型项目建议直接采用OkHttpRetrofit组合。1.1 HttpURLConnection核心用法作为Java标准库的一部分HttpURLConnection是Android开发中最基础的网络访问方式。虽然功能相对简单但理解其工作原理对掌握网络编程本质很有帮助。典型使用流程包括创建URL对象并打开连接设置请求方法和超时时间添加请求头如Content-Type获取输入/输出流进行数据读写处理响应并关闭连接// 示例GET请求基本实现 URL url new URL(https://api.example.com/data); HttpURLConnection conn (HttpURLConnection) url.openConnection(); conn.setRequestMethod(GET); conn.setConnectTimeout(5000); conn.setReadTimeout(5000); int responseCode conn.getResponseCode(); if (responseCode HttpURLConnection.HTTP_OK) { InputStream in conn.getInputStream(); // 处理输入流... } conn.disconnect();在实际使用中有几点需要特别注意网络操作必须在子线程执行主线程调用会触发NetworkOnMainThreadException需要正确处理各种HTTP状态码如301重定向、401未授权等连接使用后必须及时断开避免资源泄漏生产环境建议添加SSL证书验证等安全措施1.2 JSON数据处理要点JSON作为轻量级数据交换格式在Android网络编程中占据核心地位。Android平台提供了org.json包用于基本JSON处理但对于复杂场景建议使用更强大的第三方库如Gson或Moshi。常见JSON操作包括序列化将Java对象转换为JSON字符串反序列化将JSON字符串解析为Java对象JSON树形结构遍历与修改使用Gson的基本示例// 对象转JSON Gson gson new Gson(); String json gson.toJson(userObject); // JSON转对象 User user gson.fromJson(jsonString, User.class);对于性能敏感的场景可以考虑使用SerializedName注解处理字段名映射注册TypeAdapter处理特殊数据类型启用GsonBuilder的复杂配置考虑替代方案如Moshi以获得更好的Kotlin支持2. OkHttp高效网络通信实践OkHttp是现代Android应用开发的事实标准网络库相比HttpURLConnection提供了更多高级功能连接池减少延迟透明的GZIP压缩响应缓存HTTP/2和WebSocket支持同步/异步调用统一API2.1 OkHttp核心配置一个典型的OkHttpClient配置如下OkHttpClient client new OkHttpClient.Builder() .connectTimeout(10, TimeUnit.SECONDS) .readTimeout(30, TimeUnit.SECONDS) .writeTimeout(30, TimeUnit.SECONDS) .cache(new Cache(context.getCacheDir(), 10 * 1024 * 1024)) // 10MB缓存 .addInterceptor(new LoggingInterceptor()) // 日志拦截器 .build();关键配置项说明超时设置根据网络状况调整移动网络环境下建议适当延长缓存配置合理设置缓存大小和策略可以显著提升用户体验拦截器链OkHttp的强大特性可用于日志记录、认证、重试等2.2 同步与异步请求OkHttp提供了两种执行请求的方式同步请求需自行管理线程Request request new Request.Builder() .url(https://api.example.com/data) .build(); try (Response response client.newCall(request).execute()) { if (!response.isSuccessful()) throw new IOException(Unexpected code response); // 处理响应 }异步请求回调在主线程执行client.newCall(request).enqueue(new Callback() { Override public void onFailure(Call call, IOException e) { // 处理失败 } Override public void onResponse(Call call, Response response) throws IOException { // 处理响应注意仍在子线程 } });注意即使使用异步请求响应处理代码默认仍在子线程执行UI操作需要切换到主线程。2.3 高级特性应用OkHttp的拦截器机制是其最强大的功能之一。常见应用场景包括日志记录拦截器public class LoggingInterceptor implements Interceptor { Override public Response intercept(Chain chain) throws IOException { Request request chain.request(); long t1 System.nanoTime(); Log.d(OkHttp, String.format(Sending request %s, request.url())); Response response chain.proceed(request); long t2 System.nanoTime(); Log.d(OkHttp, String.format(Received response in %.1fms, (t2-t1)/1e6d)); return response; } }认证拦截器自动添加Tokenpublic class AuthInterceptor implements Interceptor { Override public Response intercept(Chain chain) throws IOException { Request original chain.request(); Request.Builder builder original.newBuilder() .header(Authorization, Bearer getAuthToken()); return chain.proceed(builder.build()); } }重试拦截器处理短暂网络故障public class RetryInterceptor implements Interceptor { private int maxRetries; public RetryInterceptor(int maxRetries) { this.maxRetries maxRetries; } Override public Response intercept(Chain chain) throws IOException { Request request chain.request(); Response response null; IOException exception null; for (int i 0; i maxRetries; i) { try { response chain.proceed(request); if (response.isSuccessful()) { return response; } } catch (IOException e) { exception e; } } throw exception ! null ? exception : new IOException(Unknown error); } }3. Retrofit2类型安全API客户端Retrofit2是基于OkHttp的高层封装通过接口和注解的方式定义API自动处理请求构建和响应解析。其主要优势包括类型安全的API定义支持多种数据格式JSON、XML等内置RxJava、Coroutines支持可插拔的组件设计3.1 基础API定义与使用定义一个Retrofit接口示例public interface GitHubService { GET(users/{user}/repos) CallListRepo listRepos(Path(user) String user); POST(users/new) FormUrlEncoded CallUser createUser( Field(name) String name, Field(email) String email ); }创建Retrofit实例并调用APIRetrofit retrofit new Retrofit.Builder() .baseUrl(https://api.github.com/) .addConverterFactory(GsonConverterFactory.create()) .build(); GitHubService service retrofit.create(GitHubService.class); CallListRepo call service.listRepos(octocat); call.enqueue(new CallbackListRepo() { Override public void onResponse(CallListRepo call, ResponseListRepo response) { // 处理响应 } Override public void onFailure(CallListRepo call, Throwable t) { // 处理失败 } });3.2 高级配置与自定义Retrofit2的模块化设计允许深度定制自定义Converter处理特殊数据格式public class XmlConverterFactory extends Converter.Factory { // 实现XML转换逻辑 } Retrofit retrofit new Retrofit.Builder() .addConverterFactory(new XmlConverterFactory()) // 其他配置... .build();自定义CallAdapter支持其他异步机制public class MyCallAdapterFactory extends CallAdapter.Factory { // 实现自定义适配逻辑 } Retrofit retrofit new Retrofit.Builder() .addCallAdapterFactory(new MyCallAdapterFactory()) // 其他配置... .build();动态URL和请求头处理GET CallResponseBody getDynamicUrl(Url String url); GET(user) CallUser getUser(Header(Authorization) String auth);3.3 协程与RxJava集成Retrofit2原生支持Kotlin协程和RxJava协程版本interface GitHubService { GET(users/{user}/repos) suspend fun listRepos(Path(user) String user): ListRepo } // 调用 viewModelScope.launch { try { val repos service.listRepos(octocat) // 更新UI } catch (e: Exception) { // 处理错误 } }RxJava版本interface GitHubService { GET(users/{user}/repos) ObservableListRepo listReposRx(Path(user) String user); } // 调用 service.listReposRx(octocat) .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe(repos - { // 更新UI }, error - { // 处理错误 });4. 实战中的优化与调试技巧4.1 性能优化策略连接池优化new OkHttpClient.Builder() .connectionPool(new ConnectionPool(5, 5, TimeUnit.MINUTES)) // 其他配置... .build();缓存策略配置CacheControl cacheControl new CacheControl.Builder() .maxAge(1, TimeUnit.HOURS) .build(); Request request new Request.Builder() .url(url) .cacheControl(cacheControl) .build();图片加载优化结合Glide/PicassoGlide.with(context) .load(imageUrl) .diskCacheStrategy(DiskCacheStrategy.ALL) .placeholder(R.drawable.placeholder) .into(imageView);4.2 常见问题排查证书验证失败问题OkHttpClient client new OkHttpClient.Builder() .hostnameVerifier((hostname, session) - true) // 仅调试使用 .sslSocketFactory(createInsecureSSLSocketFactory(), trustAllCerts[0]) // 生产环境应使用正规证书验证 .build();网络请求超时调整new OkHttpClient.Builder() .connectTimeout(15, TimeUnit.SECONDS) // 连接超时 .readTimeout(30, TimeUnit.SECONDS) // 读取超时 .writeTimeout(30, TimeUnit.SECONDS) // 写入超时 .build();响应数据量过大处理// 使用流式处理大响应 ResponseBody body response.body(); try (InputStream in body.byteStream()) { // 逐块处理输入流 }4.3 测试与Mock策略MockWebServer测试MockWebServer server new MockWebServer(); server.enqueue(new MockResponse().setBody(hello, world!)); OkHttpClient client new OkHttpClient(); Request request new Request.Builder() .url(server.url(/)) .build(); Response response client.newCall(request).execute(); assertEquals(hello, world!, response.body().string()); server.shutdown();接口Mock实现GitHubService mockService new GitHubService() { Override public CallListRepo listRepos(String user) { ListRepo repos Arrays.asList(new Repo(1, test-repo)); return new CallListRepo() { // 实现Call接口方法... }; } };网络状态模拟// 在Android测试中使用NetworkPolicyManager // 或直接使用OkHttp的Interceptor模拟网络错误 public class FaultInterceptor implements Interceptor { private float failureRate; public FaultInterceptor(float failureRate) { this.failureRate failureRate; } Override public Response intercept(Chain chain) throws IOException { if (Math.random() failureRate) { throw new IOException(Simulated network failure); } return chain.proceed(chain.request()); } }在实际项目中我通常会建立一个网络模块的配置中心集中管理所有网络相关配置。这样可以确保整个应用使用统一的网络策略便于维护和更新。例如public class NetworkModule { private static final long CACHE_SIZE 10 * 1024 * 1024; // 10MB Provides Singleton OkHttpClient provideOkHttpClient(Context context) { File cacheDir new File(context.getCacheDir(), http_cache); Cache cache new Cache(cacheDir, CACHE_SIZE); return new OkHttpClient.Builder() .cache(cache) .addInterceptor(new AuthInterceptor()) .addNetworkInterceptor(new StethoInterceptor()) .build(); } Provides Singleton Retrofit provideRetrofit(OkHttpClient client) { return new Retrofit.Builder() .baseUrl(https://api.example.com/) .client(client) .addConverterFactory(GsonConverterFactory.create()) .addCallAdapterFactory(RxJava2CallAdapterFactory.create()) .build(); } }这种集中式配置方式特别适合中大型项目可以确保所有网络请求使用相同的超时设置和缓存策略统一添加认证、日志等公共拦截器方便进行全局网络行为调整便于进行单元测试和模块替换