SpringBoot에서 HTTP 클라이언트 도구 Retrofit을 사용하는 방법

소개

Retrofit은 Android 및 Java에 적합한 유형 안전 HTTP 클라이언트 도구입니다. Github에는 이미 39k+별점이 있습니다. 가장 큰 특징은 Feign을 사용하여 마이크로서비스 인터페이스를 호출하는 방식과 유사하게 인터페이스를 통해 HTTP 요청 시작을 지원한다는 것입니다. Android和Java且类型安全的HTTP客户端工具，在Github上已经有39k+Star。其最大的特性的是支持通过接口的方式发起HTTP请求，类似于我们用Feign调用微服务接口的那种方式。

SpringBoot是使用最广泛的Java开发框架，但是Retrofit官方并没有提供专门的Starter。于是有位老哥就开发了retrofit-spring-boot-starter，它实现了Retrofit与SpringBoot框架的快速整合，并且支持了诸多功能增强，极大简化开发。今天我们将使用这个第三方Starter来操作Retrofit。

使用

在SpringBoot中使用Retrofit是非常简单的，下面我们就来体验下。

依赖集成

有了第三方Starter的支持，集成Retrofit仅需一步，添加如下依赖即可。

<!--Retrofit依赖-->
<dependency>
    <groupId>com.github.lianjiatech</groupId>
    <artifactId>retrofit-spring-boot-starter</artifactId>
    <version>2.2.18</version>
</dependency>

基本使用

下面以调用mall-tiny-swagger中的接口为例，我们来体验下Retrofit的基本使用。

首先我们准备一个服务来方便远程调用，使用的是之前的mall-tiny-swagger这个Demo，打开Swagger看下，里面有一个登录接口和需要登录认证的商品品牌CRUD接口，

我们先来调用下登录接口试试，在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")
    CommonResult<LoginInfo> login(@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 {
    @Autowired
    private UmsAdminApi umsAdminApi;
    @Autowired
    private TokenHolder tokenHolder;
    @ApiOperation(value = "调用远程登录接口获取token")
    @PostMapping(value = "/admin/login")
    public CommonResult<LoginInfo> login(@RequestParam String username, @RequestParam String password) {
        CommonResult<LoginInfo> 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.
 */
@Component
public 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.
 */
@Component
public class TokenInterceptor extends BasePathMatchInterceptor {
    @Autowired
    private TokenHolder tokenHolder;
    @Override
    protected 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")
    CommonResult<CommonPage<PmsBrand>> list(@Query("pageNum") Integer pageNum, @Query("pageSize") Integer pageSize);
    @GET("brand/{id}")
    CommonResult<PmsBrand> 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 {
    @Autowired
    private PmsBrandApi pmsBrandApi;
    @ApiOperation("调用远程接口分页查询品牌列表")
    @GetMapping(value = "/brand/list")
    public CommonResult<CommonPage<PmsBrand>> listBrand(@RequestParam(value = "pageNum", defaultValue = "1")
                                                        @ApiParam("页码") Integer pageNum,
                                                        @RequestParam(value = "pageSize", defaultValue = "3")
                                                        @ApiParam("每页数量") Integer pageSize) {
        return pmsBrandApi.list(pageNum, pageSize);
    }
    @ApiOperation("调用远程接口获取指定id的品牌详情")
    @GetMapping(value = "/brand/{id}")
    public CommonResult<PmsBrand> brand(@PathVariable("id") Long id) {
        return pmsBrandApi.detail(id);
    }
    @ApiOperation("调用远程接口添加品牌")
    @PostMapping(value = "/brand/create")
    public CommonResult createBrand(@RequestBody PmsBrand pmsBrand) {
        return pmsBrandApi.create(pmsBrand);
    }
    @ApiOperation("调用远程接口更新指定id品牌信息")
    @PostMapping(value = "/brand/update/{id}")
    public CommonResult updateBrand(@PathVariable("id") Long id, @RequestBody PmsBrand pmsBrand) {
        return pmsBrandApi.update(id,pmsBrand);
    }
    @ApiOperation("调用远程接口删除指定id的品牌")
    @GetMapping(value = "/delete/{id}")
    public CommonResult deleteBrand(@PathVariable("id") Long id) {
        return  pmsBrandApi.delete(id);
    }
}

在Swagger中调用接口进行测试，发现已经可以成功调用。

全局拦截器

如果你想给所有请求都加个请求头的话，可以使用全局拦截器。

创建SourceInterceptor类继承BaseGlobalInterceptor接口，然后在Header中添加source请求头。

/**
 * 全局拦截器，给请求添加source头
 * Created by macro on 2022/1/19.
 */
@Component
public class SourceInterceptor extends BaseGlobalInterceptor {
    @Override
    protected 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

SpringBoot 가장 널리 사용되는 Java 개발 프레임워크이지만 Retrofit은 공식적으로 전용 스타터를 제공하지 않습니다. 그래서 한 노인은 Retrofit과 SpringBoot 프레임워크의 신속한 통합을 실현하고 많은 기능 향상을 지원하여 개발을 크게 단순화하는 retrofit-spring-boot-starter를 개발했습니다. 오늘은 이 타사 Starter를 사용하여 Retrofit을 작동해 보겠습니다.

사용

SpringBoot에서 Retrofit을 사용하는 것은 매우 간단합니다. 아래에서 직접 경험해 보겠습니다.

• 종속성 통합

타사 Starter의 지원을 통해 Retrofit 통합은 한 단계만 거치면 됩니다. 다음 종속성을 추가하기만 하면 됩니다.

• retrofit:
    # 日志打印配置
    log:
      # 启用日志打印
      enable: true
      # 日志打印拦截器
      logging-interceptor: com.github.lianjiatech.retrofit.spring.boot.interceptor.DefaultLoggingInterceptor
      # 全局日志打印级别
      global-log-level: info
      # 全局日志打印策略
      global-log-strategy: body

  기본 사용법

  다음은 mall-tiny-swagger에서 인터페이스를 호출하는 예입니다. Retrofit의 기본 사용법을 경험해 보겠습니다.

  🎜먼저 원격 통화를 용이하게 하는 서비스를 준비합니다. 이전 mall-tiny-swagger 데모를 사용하여 로그인 인증이 필요한 로그인 인터페이스와 제품 브랜드 CRUD를 살펴보겠습니다. . 인터페이스, 🎜🎜 🎜🎜 먼저 로그인 인터페이스를 호출하고 application.yml에서 mall-tiny-swagger의 서비스 주소를 구성해 보겠습니다. 🎜

  retrofit:
    # 全局连接超时时间
    global-connect-timeout-ms: 3000
    # 全局读取超时时间
    global-read-timeout-ms: 3000
    # 全局写入超时时间
    global-write-timeout-ms: 35000
    # 全局完整调用超时时间
    global-call-timeout-ms: 0

  🎜 그런 다음 @RetrofitClient를 전달합니다. Retrofit 클라이언트를 선언합니다. 로그인 인터페이스는 POST 양식을 통해 호출되므로 여기서는 @POST 및 @FormUrlEncoded 주석이 사용됩니다. 이 주석이 무엇을 위한 것인지 잘 모르겠습니다. 아래 표를 보면 기본적으로 이해할 수 있습니다. 자세한 내용은 공식 Retrofit 문서를 참조하세요. 🎜🎜🎜🎜다음으로 UmsAdminApi를 🎜

  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

  🎜로그인 인증이 필요한 인터페이스에 대한 후속 호출을 용이하게 하기 위해 TokenHolder 클래스를 생성하고 세션에 토큰을 저장했습니다. 🎜rrreee🎜 다음으로 Swagger를 통해 테스트합니다. , 인터페이스를 호출하여 원격 서비스를 얻을 수 있습니다. 토큰이 반환됩니다. 액세스 주소: http://localhost:8086/swagger-ui/🎜🎜🎜

  주석 인터셉터

  🎜제품 브랜드 관리 인터페이스, 일반 액세스를 위한 로그인 인증 헤더를 사용하면 Retrofit Annotation 인터셉터가 구현됩니다. 🎜🎜먼저 주석 인터셉터 TokenInterceptor를 생성하고 BasePathMatchInterceptor를 상속한 다음 doIntercept 메서드의 요청에 Authorization을 추가합니다. header; 🎜rrreee🎜 브랜드 관리 인터페이스를 호출하는 클라이언트 PmsBrandApi를 생성하고 @Intercept 주석을 사용하여 인터셉터 및 차단 경로를 구성합니다. 🎜rrreee🎜 그런 다음 < Controller >PmsBrandApi 인스턴스에 코드를 추가하고 원격 서비스를 호출하는 메서드를 추가합니다. 🎜rrreee🎜Swagger에서 인터페이스를 호출하여 성공적으로 호출할 수 있는지 확인합니다. 🎜🎜🎜

  글로벌 인터셉터

  🎜모든 요청에 ​​요청 헤더를 추가하려면 글로벌 인터셉터를 사용하면 됩니다. 🎜🎜SourceInterceptor 클래스를 생성하여 BaseGlobalInterceptor 인터페이스를 상속한 다음 헤더에 source 요청 헤더를 추가하세요. 🎜rrreee

  구성

  🎜Retrofit에는 가장 일반적으로 사용되는 세 가지 구성인 로그 인쇄, 전역 시간 초과 및 전역 요청 재시도에 대해 이야기해 보겠습니다. 🎜

  🎜로그 인쇄의 기본 구성에서 Retrofit은 기본 로그 전략을 사용하며 인쇄된 로그는 매우 간단합니다. 🎜🎜🎜🎜retrofit.global-을 <code>응용 프로그램에 넣을 수 있습니다 .yml log-strategy 속성이 body로 변경되어 가장 완전한 로그를 인쇄합니다. 🎜rrreee🎜로그 인쇄 전략을 수정한 후 로그 정보가 더욱 포괄적입니다. 🎜🎜🎜🎜🎜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：发生任意异常时执行重试。

위 내용은 SpringBoot에서 HTTP 클라이언트 도구 Retrofit을 사용하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!