当前位置：首页 > news >正文

在Java项目中使用OkHttp构建高可用的外卖霸王餐API客户端

news 2026/4/12 16:54:45

在Java项目中使用OkHttp构建高可用的外卖霸王餐API客户端

在对接美团外卖霸王餐这类高并发、强时效性的第三方服务时，API客户端的稳定性至关重要。本文将基于OkHttp客户端，通过连接池管理、统一拦截器、异步回调及熔断降级策略，构建一个健壮且易于维护的Java API客户端。

1. 项目依赖与基础配置

首先，确保pom.xml中引入了OkHttp和相关工具库。

<dependencies><dependency><groupId>com.squareup.okhttp3</groupId><artifactId>okhttp</artifactId><version>4.10.0</version></dependency><dependency><groupId>com.alibaba</groupId><artifactId>fastjson</artifactId><version>1.2.83</version></dependency><dependency><groupId>org.slf4j</groupId><artifactId>slf4j-api</artifactId><version>1.7.36</version></dependency></dependencies>

2. 定义核心数据模型

在baodanbao.com.cn.model包下定义通用的响应结构和业务请求体。

通用响应类：

packagecom.baodanbao.cn.model;publicclassApiResponse<T>{privateintstatus;privateStringmsg;privateTresult;publicbooleanisSuccess(){returnthis.status==200;}// Getter和Setter省略}

霸王餐活动查询请求：

packagecom.baodanbao.cn.model.request;publicclassQueryCampaignRequest{privateStringpartnerId;privateStringtimestamp;privateStringtoken;privateStringshopPoiId;privateIntegerpage;privateIntegerpageSize;// Getter和Setter}

3. 构建OkHttpClient实例

利用OkHttp的连接池和拦截器机制，统一处理日志、重试和头部信息。

packagecom.baodanbao.cn.config;importokhttp3.ConnectionPool;importokhttp3.Interceptor;importokhttp3.OkHttpClient;importokhttp3.Response;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importjava.io.IOException;importjava.util.concurrent.TimeUnit;@ConfigurationpublicclassOkHttpConfig{@BeanpublicOkHttpClientbawangcanHttpClient(){returnnewOkHttpClient.Builder().connectTimeout(5,TimeUnit.SECONDS).readTimeout(10,TimeUnit.SECONDS).writeTimeout(10,TimeUnit.SECONDS).connectionPool(newConnectionPool(5,5,TimeUnit.MINUTES))// 添加日志拦截器.addInterceptor(newLoggingInterceptor())// 添加公共参数拦截器.addInterceptor(newCommonHeaderInterceptor()).build();}// 日志拦截器staticclassLoggingInterceptorimplementsInterceptor{@OverridepublicResponseintercept(Chainchain)throwsIOException{Requestrequest=chain.request();longstartTime=System.nanoTime();Responseresponse=chain.proceed(request);longendTime=System.nanoTime();// 实际项目中应使用loggerSystem.out.println(String.format("API调用: %s 耗时: %.1fms",request.url(),(endTime-startTime)/1e6d));returnresponse;}}// 公共头部拦截器staticclassCommonHeaderInterceptorimplementsInterceptor{@OverridepublicResponseintercept(Chainchain)throwsIOException{Requestoriginal=chain.request();Requestrequest=original.newBuilder().header("Content-Type","application/json").header("User-Agent","Baodanbao-Client/1.0").method(original.method(),original.body()).build();returnchain.proceed(request);}}}

4. 封装业务客户端

创建专门的服务类来处理具体的API调用逻辑。

packagecom.baodanbao.cn.service;importcom.alibaba.fastjson.JSON;importcom.baodanbao.cn.config.OkHttpConfig;importcom.baodanbao.cn.model.ApiResponse;importcom.baodanbao.cn.model.request.QueryCampaignRequest;importcom.baodanbao.cn.util.SignatureUtil;importokhttp3.*;importjava.io.IOException;importjava.util.concurrent.CompletableFuture;publicclassMeituanBawangcanService{privatefinalOkHttpClientclient;privatefinalStringbaseUrl="https://api.meituan.com/bawangcan";privatefinalStringpartnerId="your_partner_id";privatefinalStringpartnerSecret="your_secret_key";publicMeituanBawangcanService(){this.client=newOkHttpConfig().bawangcanHttpClient();}/** * 异步查询霸王餐活动列表 */publicCompletableFuture<ApiResponse<String>>queryCampaignsAsync(StringshopPoiId){returnCompletableFuture.supplyAsync(()->{try{QueryCampaignRequestrequest=buildQueryRequest(shopPoiId);Stringjson=JSON.toJSONString(request);Stringsign=SignatureUtil.sign(json,partnerSecret);RequestBodybody=RequestBody.create(json,MediaType.get("application/json; charset=utf-8"));RequesthttpRequest=newRequest.Builder().url(baseUrl+"/query").post(body).addHeader("X-PARTNER-ID",partnerId).addHeader("X-SIGNATURE",sign).build();try(Responseresponse=client.newCall(httpRequest).execute()){if(response.isSuccessful()&&response.body()!=null){StringresponseBody=response.body().string();returnJSON.parseObject(responseBody,newcom.alibaba.fastjson.TypeReference<ApiResponse<String>>(){});}else{thrownewIOException("API调用失败，状态码: "+(response!=null?response.code():"null"));}}}catch(Exceptione){// 在实际项目中，这里应该集成熔断器（如Hystrix或Sentinel）System.err.println("调用异常: "+e.getMessage());ApiResponse<String>errorResponse=newApiResponse<>();errorResponse.setStatus(500);errorResponse.setMsg("服务调用异常");returnerrorResponse;}});}privateQueryCampaignRequestbuildQueryRequest(StringshopPoiId){QueryCampaignRequestreq=newQueryCampaignRequest();req.setPartnerId(partnerId);req.setTimestamp(String.valueOf(System.currentTimeMillis()/1000));req.setShopPoiId(shopPoiId);req.setPage(1);req.setPageSize(10);// Token可以基于时间戳生成req.setToken(java.util.UUID.randomUUID().toString());returnreq;}}

5. 签名工具类

确保请求的安全性。

packagecom.baodanbao.cn.util;importjava.security.MessageDigest;publicclassSignatureUtil{publicstaticStringsign(Stringcontent,Stringsecret){try{MessageDigestmd=MessageDigest.getInstance("MD5");md.update((content+secret).getBytes());byte[]digest=md.digest();StringBuildersb=newStringBuilder();for(byteb:digest){sb.append(String.format("%02x",b&0xff));}returnsb.toString().toUpperCase();}catch(Exceptione){thrownewRuntimeException("签名生成失败",e);}}}

6. 使用示例

publicclassApplication{publicstaticvoidmain(String[]args){MeituanBawangcanServiceservice=newMeituanBawangcanService();service.queryCampaignsAsync("shop_123456").whenComplete((result,throwable)->{if(throwable!=null){System.err.println("异步调用发生错误: "+throwable.getMessage());}else{System.out.println("API响应状态: "+result.getStatus());System.out.println("API响应数据: "+result.getResult());}});// 保持主线程存活以观察异步结果try{Thread.sleep(5000);}catch(InterruptedExceptione){e.printStackTrace();}}}