SpringBoot中使用HTTP客户端工具Retrofit
前言
我们平时开发项目时,就算是单体应用,也免不了要调用一下其他服务提供的接口。此时就会用到HTTP客户端工具,之前一直使用的是Hutool中的HttpUtil,虽然容易上手,但用起来颇为麻烦!最近发现一款更好用的HTTP客户端工具Retrofit
,你只需声明接口就可发起HTTP请求,无需进行连接、结果解析之类的重复操作,用起来够优雅,推荐给大家!
SpringBoot实战电商项目mall(50k+star)地址:https://github.com/macrozheng/mall
简介
Retrofit是适用于Android
和Java
且类型安全的HTTP客户端工具,在Github上已经有39k+
Star。其最大的特性的是支持通过接口的方式发起HTTP请求,类似于我们用Feign调用微服务接口的那种方式。
文章图片
SpringBoot是使用最广泛的Java开发框架,但是Retrofit官方并没有提供专门的Starter。于是有位老哥就开发了retrofit-spring-boot-starter
,它实现了Retrofit与SpringBoot框架的快速整合,并且支持了诸多功能增强,极大简化开发。今天我们将使用这个第三方Starter来操作Retrofit。
文章图片
使用
在SpringBoot中使用Retrofit是非常简单的,下面我们就来体验下。
【SpringBoot中使用HTTP客户端工具Retrofit】依赖集成
有了第三方Starter的支持,集成Retrofit仅需一步,添加如下依赖即可。
com.github.lianjiatech retrofit-spring-boot-starter2.2.18
基本使用
下面以调用
mall-tiny-swagger
中的接口为例,我们来体验下Retrofit的基本使用。首先我们准备一个服务来方便远程调用,使用的是之前的
mall-tiny-swagger
这个Demo,打开Swagger看下,里面有一个登录接口和需要登录认证的商品品牌CRUD接口,项目地址:
https://github.com/macrozheng/mall-learning/tree/master/mall-tiny-swagger
文章图片
我们先来调用下登录接口试试,在
application.yml
中配置好mall-tiny-swagger
的服务地址;remote:baseUrl: http://localhost:8088/
再通过
@RetrofitClient
声明一个Retrofit客户端,由于登录接口是通过POST表单形式调用的,这里使用到了@POST
和@FormUrlEncoded
注解;/** * 定义Http接口,用于调用远程的UmsAdmin服务 * Created by macro on 2022/1/19. */@RetrofitClient(baseUrl = "${remote.baseUrl}")public interface UmsAdminApi {@FormUrlEncoded@POST("admin/login")CommonResultlogin(@Field("username") String username, @Field("password") String password); }
如果你不太明白这些注解是干嘛的,看下下面的表基本就懂了,更具体的话可以参考Retrofit官方文档;
文章图片
接下来在Controller中注入
UmsAdminApi
,然后进行调用即可;/** * Retrofit测试接口 * Created by macro on 2022/1/19. */@Api(tags = "RetrofitController", description = "Retrofit测试接口")@RestController@RequestMapping("/retrofit")public class RetrofitController {@Autowiredprivate UmsAdminApi umsAdminApi; @Autowiredprivate TokenHolder tokenHolder; @ApiOperation(value = "https://www.it610.com/article/调用远程登录接口获取token")@PostMapping(value = "https://www.it610.com/admin/login")public CommonResultlogin(@RequestParam String username, @RequestParam String password) {CommonResult result = umsAdminApi.login(username, password); LoginInfo loginInfo = result.getData(); if (result.getData() != null) {tokenHolder.putToken(loginInfo.getTokenHead() + " " + loginInfo.getToken()); }return result; }}
为方便后续调用需要登录认证的接口,我创建了
TokenHolder
这个类,把token存储到了Session中;/** * 登录token存储(在Session中) * Created by macro on 2022/1/19. */@Componentpublic class TokenHolder {/*** 添加token*/public void putToken(String token) {RequestAttributes ra = RequestContextHolder.getRequestAttributes(); HttpServletRequest request = ((ServletRequestAttributes) ra).getRequest(); request.getSession().setAttribute("token", token); }/*** 获取token*/public String getToken() {RequestAttributes ra = RequestContextHolder.getRequestAttributes(); HttpServletRequest request = ((ServletRequestAttributes) ra).getRequest(); Object token = request.getSession().getAttribute("token"); if(token!=null){return (String) token; }return null; }}
接下来通过Swagger进行测试,调用接口就可以获取到远程服务返回的token了,访问地址:http://localhost:8086/swagger-ui/
文章图片
注解式拦截器
商品品牌管理接口,需要添加登录认证头才可以正常访问,我们可以使用Retrofit中的注解式拦截器来实现。
首先创建一个注解式拦截器
TokenInterceptor
继承BasePathMatchInterceptor
,然后在doIntercept
方法中给请求添加Authorization
头;/** * 给请求添加登录Token头的拦截器 * Created by macro on 2022/1/19. */@Componentpublic class TokenInterceptor extends BasePathMatchInterceptor {@Autowiredprivate TokenHolder tokenHolder; @Overrideprotected Response doIntercept(Chain chain) throws IOException {Request request = chain.request(); if (tokenHolder.getToken() != null) {request = request.newBuilder().header("Authorization", tokenHolder.getToken()).build(); }return chain.proceed(request); }}
创建调用品牌管理接口的客户端
PmsBrandApi
,使用@Intercept
注解配置拦截器和拦截路径;/** * 定义Http接口,用于调用远程的PmsBrand服务 * Created by macro on 2022/1/19. */@RetrofitClient(baseUrl = "${remote.baseUrl}")@Intercept(handler = TokenInterceptor.class, include = "/brand/**")public interface PmsBrandApi {@GET("brand/list")CommonResultlist(@Query("pageNum") Integer pageNum, @Query("pageSize") Integer pageSize); @GET("brand/{id}")CommonResult detail(@Path("id") Long id); @POST("brand/create")CommonResult create(@Body PmsBrand pmsBrand); @POST("brand/update/{id}")CommonResult update(@Path("id") Long id, @Body PmsBrand pmsBrand); @GET("brand/delete/{id}")CommonResult delete(@Path("id") Long id); }
再在Controller中注入
PmsBrandApi
实例,并添加方法调用远程服务即可;/** * Retrofit测试接口 * Created by macro on 2022/1/19. */@Api(tags = "RetrofitController", description = "Retrofit测试接口")@RestController@RequestMapping("/retrofit")public class RetrofitController {@Autowiredprivate PmsBrandApi pmsBrandApi; @ApiOperation("调用远程接口分页查询品牌列表")@GetMapping(value = "https://www.it610.com/brand/list")public CommonResultlistBrand(@RequestParam(value = "https://www.it610.com/article/pageNum", defaultValue = "https://www.it610.com/article/1")@ApiParam("页码") Integer pageNum,@RequestParam(value = "https://www.it610.com/article/pageSize", defaultValue = "https://www.it610.com/article/3")@ApiParam("每页数量") Integer pageSize) {return pmsBrandApi.list(pageNum, pageSize); }@ApiOperation("调用远程接口获取指定id的品牌详情")@GetMapping(value = "https://www.it610.com/brand/{id}")public CommonResult brand(@PathVariable("id") Long id) {return pmsBrandApi.detail(id); }@ApiOperation("调用远程接口添加品牌")@PostMapping(value = "https://www.it610.com/brand/create")public CommonResult createBrand(@RequestBody PmsBrand pmsBrand) {return pmsBrandApi.create(pmsBrand); }@ApiOperation("调用远程接口更新指定id品牌信息")@PostMapping(value = "https://www.it610.com/brand/update/{id}")public CommonResult updateBrand(@PathVariable("id") Long id, @RequestBody PmsBrand pmsBrand) {return pmsBrandApi.update(id,pmsBrand); }@ApiOperation("调用远程接口删除指定id的品牌")@GetMapping(value = "https://www.it610.com/delete/{id}")public CommonResult deleteBrand(@PathVariable("id") Long id) {returnpmsBrandApi.delete(id); }}
在Swagger中调用接口进行测试,发现已经可以成功调用。
文章图片
全局拦截器
如果你想给所有请求都加个请求头的话,可以使用全局拦截器。
创建
SourceInterceptor
类继承BaseGlobalInterceptor
接口,然后在Header中添加source
请求头。/** * 全局拦截器,给请求添加source头 * Created by macro on 2022/1/19. */@Componentpublic class SourceInterceptor extends BaseGlobalInterceptor {@Overrideprotected Response doIntercept(Chain chain) throws IOException {Request request = chain.request(); Request newReq = request.newBuilder().addHeader("source", "retrofit").build(); return chain.proceed(newReq); }}
配置
Retrofit的配置很多,下面我们讲讲日志打印、全局超时时间和全局请求重试这三种最常用的配置。日志打印 默认配置下Retrofit使用
basic
日志策略,打印的日志非常简单;文章图片
我们可以将
application.yml
中的retrofit.global-log-strategy
属性修改为body
来打印最全日志;retrofit:# 日志打印配置log:# 启用日志打印enable: true# 日志打印拦截器logging-interceptor: com.github.lianjiatech.retrofit.spring.boot.interceptor.DefaultLoggingInterceptor# 全局日志打印级别global-log-level: info# 全局日志打印策略global-log-strategy: body
修改日志打印策略后,日志信息更全面了;
文章图片
Retrofit支持四种日志打印策略;
- NONE:不打印日志;
- BASIC:只打印日志请求记录;
- HEADERS:打印日志请求记录、请求和响应头信息;
- BODY:打印日志请求记录、请求和响应头信息、请求和响应体信息。
有时候我们需要修改一下Retrofit的请求超时时间,可以通过如下配置实现。
retrofit:# 全局连接超时时间global-connect-timeout-ms: 3000# 全局读取超时时间global-read-timeout-ms: 3000# 全局写入超时时间global-write-timeout-ms: 35000# 全局完整调用超时时间global-call-timeout-ms: 0
全局请求重试
retrofit-spring-boot-starter
支持请求重试,可以通过如下配置实现。retrofit:# 重试配置retry:# 是否启用全局重试enable-global-retry: true# 全局重试间隔时间global-interval-ms: 100# 全局最大重试次数global-max-retries: 2# 全局重试规则global-retry-rules:- response_status_not_2xx- occur_exception# 重试拦截器retry-interceptor: com.github.lianjiatech.retrofit.spring.boot.retry.DefaultRetryInterceptor
重试规则
global-retry-rules
支持如下三种配置。- RESPONSE_STATUS_NOT_2XX:响应状态码不是2xx时执行重试;
- OCCUR_IO_EXCEPTION:发生IO异常时执行重试;
- OCCUR_EXCEPTION:发生任意异常时执行重试。
retrofit-spring-boot-starter
提供的功能远不止于此,它还能支持微服务间的调用和熔断降级,感兴趣的朋友可以研究下!参考资料
官方文档:https://github.com/LianjiaTech/retrofit-spring-boot-starter
项目源码地址
https://github.com/macrozheng/mall-learning/tree/master/mall-tiny-retrofit
本文 GitHub https://github.com/macrozheng/mall-learning 已经收录,欢迎大家Star!
以上就是SpringBoot中使用HTTP客户端工具Retrofit的详细内容,更多关于SpringBoot HTTP客户端Retrofit的资料请关注脚本之家其它相关文章!
推荐阅读
- 在vue项目如何使用base64加密
- vue华视电子身份证阅读器的使用
- pandas100个骚操作|pandas100个骚操作五(使用 explode 实现 pandas 列转行的 2 个常用技巧)
- linux|Linux中的骚操作之第一话
- #yyds干货盘点# 解决剑指offer(数据流中的中位数)
- [ C语言 ] 还不懂指针的一定要进来,带你初识指针,简单使用指针,它没有你想的那么难。
- 实战,Vue 项目中,将 API “类化”
- SpringBoot|设计一个简单的权限管理系统
- 前端相关|JS中的类,函数,对象、原型
- 前端面试必知(JS)|【前端面试必知】ES6中函数新增了哪些扩展