适用于Spring Boot的轻量级 HTTP 客户端框架

逃离我推掉我的手 2021-09-07 06:18 308阅读 0赞

![7b0c1a80a932c1a737ec5fcec4eb4177.gif][]

在`SpringBoot`项目直接使用`okhttp`、`httpClient`或者`RestTemplate`发起`HTTP`请求，既繁琐又不方便统一管理。因此，在这里推荐一个适用于`SpringBoot`项目的轻量级HTTP客户端框架retrofit-spring-boot-starter，使用非常简单方便，同时又提供诸多功能增强。目前项目已经更新至`2.2.2`版本，并且会持续进行迭代优化。

项目地址：https://github.com/LianjiaTech/retrofit-spring-boot-starter

## 前言 ##

`Retrofit`是适用于`Android`和`Java`且类型安全的HTTP客户端，其最大的特性的是**支持通过`接口`的方式发起HTTP请求**。而`spring-boot`是使用最广泛的Java开发框架，但是`Retrofit`官方没有支持与`spring-boot`框架快速整合，因此我们开发了`retrofit-spring-boot-starter`。

**`retrofit-spring-boot-starter`实现了`Retrofit`与`spring-boot`框架快速整合，并且支持了诸多功能增强，极大简化开发**。

????项目持续优化迭代，欢迎大家提ISSUE和PR！麻烦大家能给一颗star✨，您的star是我们持续更新的动力！

## 功能特性 ##

*  \[x\]  自定义注入OkHttpClient
 *  \[x\]  注解式拦截器
 *  \[x\]  连接池管理
 *  \[x\]  日志打印
 *  \[x\]  请求重试
 *  \[x\]  错误解码器
 *  \[x\]  全局拦截器
 *  \[x\]  熔断降级
 *  \[x\]  微服务之间的HTTP调用
 *  \[x\]  调用适配器
 *  \[x\]  数据转换器

## 快速使用 ##

### 引入依赖 ###

<dependency>
        <groupId>com.github.lianjiatech</groupId>
        <artifactId>retrofit-spring-boot-starter</artifactId>
        <version>2.2.2</version>
    </dependency>

### 定义http接口 ###

**接口必须使用`@RetrofitClient`注解标记**！http相关注解可参考官方文档：retrofit官方文档。

@RetrofitClient(baseUrl = "${test.baseUrl}")
    public interface HttpApi {
    
        @GET("person")
        Result<Person> getPerson(@Query("id") Long id);
    }

### 注入使用 ###

**将接口注入到其它Service中即可使用！**

@Service
    public class TestService {
    
        @Autowired
        private HttpApi httpApi;
    
        public void test() {
            // 通过httpApi发起http请求
        }
    }

## HTTP请求相关注解 ##

`HTTP`请求相关注解，全部使用了`retrofit`原生注解。**详细信息可参考官方文档：retrofit官方文档**，以下是一个简单说明。

<table> 
 <thead> 
  <tr> 
   <th>注解分类</th> 
   <th>支持的注解</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>请求方式</td> 
   <td><code>@GET</code>&nbsp;<code>@HEAD</code>&nbsp;<code>@POST</code>&nbsp;<code>@PUT</code>&nbsp;<code>@DELETE</code>&nbsp;<code>@OPTIONS</code></td> 
  </tr> 
  <tr> 
   <td>请求头</td> 
   <td><code>@Header</code>&nbsp;<code>@HeaderMap</code>&nbsp;<code>@Headers</code></td> 
  </tr> 
  <tr> 
   <td>Query参数</td> 
   <td><code>@Query</code>&nbsp;<code>@QueryMap</code>&nbsp;<code>@QueryName</code></td> 
  </tr> 
  <tr> 
   <td>path参数</td> 
   <td><code>@Path</code></td> 
  </tr> 
  <tr> 
   <td>form-encoded参数</td> 
   <td><code>@Field</code>&nbsp;<code>@FieldMap</code>&nbsp;<code>@FormUrlEncoded</code></td> 
  </tr> 
  <tr> 
   <td>文件上传</td> 
   <td><code>@Multipart</code>&nbsp;<code>@Part</code>&nbsp;<code>@PartMap</code></td> 
  </tr> 
  <tr> 
   <td>url参数</td> 
   <td><code>@Url</code></td> 
  </tr> 
 </tbody> 
</table>

## 配置项说明 ##

`retrofit-spring-boot-starter`支持了多个可配置的属性，用来应对不同的业务场景。您可以视情况进行修改，具体说明如下：

<table> 
 <thead> 
  <tr> 
   <th>配置</th> 
   <th>默认值</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>enable-log</td> 
   <td>true</td> 
   <td>启用日志打印</td> 
  </tr> 
  <tr> 
   <td>logging-interceptor</td> 
   <td>DefaultLoggingInterceptor</td> 
   <td>日志打印拦截器</td> 
  </tr> 
  <tr> 
   <td>pool</td> 
   <td><br></td> 
   <td>连接池配置</td> 
  </tr> 
  <tr> 
   <td>disable-void-return-type</td> 
   <td>false</td> 
   <td>禁用java.lang.Void返回类型</td> 
  </tr> 
  <tr> 
   <td>retry-interceptor</td> 
   <td>DefaultRetryInterceptor</td> 
   <td>请求重试拦截器</td> 
  </tr> 
  <tr> 
   <td>global-converter-factories</td> 
   <td>JacksonConverterFactory</td> 
   <td>全局转换器工厂</td> 
  </tr> 
  <tr> 
   <td>global-call-adapter-factories</td> 
   <td>BodyCallAdapterFactory,ResponseCallAdapterFactory</td> 
   <td>全局调用适配器工厂</td> 
  </tr> 
  <tr> 
   <td>enable-degrade</td> 
   <td>false</td> 
   <td>是否启用熔断降级</td> 
  </tr> 
  <tr> 
   <td>degrade-type</td> 
   <td>sentinel</td> 
   <td>熔断降级实现方式(目前仅支持Sentinel)</td> 
  </tr> 
  <tr> 
   <td>resource-name-parser</td> 
   <td>DefaultResourceNameParser</td> 
   <td>熔断资源名称解析器，用于解析资源名称</td> 
  </tr> 
 </tbody> 
</table>

`yml`配置方式：

retrofit:
      enable-response-call-adapter: true
      # 启用日志打印
      enable-log: true
      # 连接池配置
      pool:
        test1:
          max-idle-connections: 3
          keep-alive-second: 100
        test2:
          max-idle-connections: 5
          keep-alive-second: 50
      # 禁用void返回值类型
      disable-void-return-type: false
      # 日志打印拦截器
      logging-interceptor: com.github.lianjiatech.retrofit.spring.boot.interceptor.DefaultLoggingInterceptor
      # 请求重试拦截器
      retry-interceptor: com.github.lianjiatech.retrofit.spring.boot.retry.DefaultRetryInterceptor
      # 全局转换器工厂
      global-converter-factories:
        - retrofit2.converter.jackson.JacksonConverterFactory
      # 全局调用适配器工厂
      global-call-adapter-factories:
        - com.github.lianjiatech.retrofit.spring.boot.core.BodyCallAdapterFactory
        - com.github.lianjiatech.retrofit.spring.boot.core.ResponseCallAdapterFactory
      # 是否启用熔断降级
      enable-degrade: true
      # 熔断降级实现方式
      degrade-type: sentinel
      # 熔断资源名称解析器
      resource-name-parser: com.github.lianjiatech.retrofit.spring.boot.degrade.DefaultResourceNameParser

## 高级功能 ##

### 自定义注入OkHttpClient ###

通常情况下，通过`@RetrofitClient`注解属性动态创建`OkHttpClient`对象能够满足大部分使用场景。但是在某些情况下，用户可能需要自定义`OkHttpClient`，这个时候，可以在接口上定义返回类型是`OkHttpClient.Builder`的静态方法来实现。代码示例如下：

@RetrofitClient(baseUrl = "http://ke.com")
    public interface HttpApi3 {
    
        @OkHttpClientBuilder
        static OkHttpClient.Builder okhttpClientBuilder() {
            return new OkHttpClient.Builder()
                    .connectTimeout(1, TimeUnit.SECONDS)
                    .readTimeout(1, TimeUnit.SECONDS)
                    .writeTimeout(1, TimeUnit.SECONDS);
    
        }
    
        @GET
        Result<Person> getPerson(@Url String url, @Query("id") Long id);
    }

> 方法必须使用`@OkHttpClientBuilder`注解标记！

### 注解式拦截器 ###

很多时候，我们希望某个接口下的某些http请求执行统一的拦截处理逻辑。为了支持这个功能，`retrofit-spring-boot-starter`提供了**注解式拦截器**，做到了**基于url路径的匹配拦截**。使用的步骤主要分为2步：

1.  继承`BasePathMatchInterceptor`编写拦截处理器；
2.  接口上使用`@Intercept`进行标注。如需配置多个拦截器，在接口上标注多个`@Intercept`注解即可！

下面以\_给指定请求的url后面拼接timestamp时间戳\_为例，介绍下如何使用注解式拦截器。

#### 继承`BasePathMatchInterceptor`编写拦截处理器 ####

@Component
    public class TimeStampInterceptor extends BasePathMatchInterceptor {
    
        @Override
        public Response doIntercept(Chain chain) throws IOException {
            Request request = chain.request();
            HttpUrl url = request.url();
            long timestamp = System.currentTimeMillis();
            HttpUrl newUrl = url.newBuilder()
                    .addQueryParameter("timestamp", String.valueOf(timestamp))
                    .build();
            Request newRequest = request.newBuilder()
                    .url(newUrl)
                    .build();
            return chain.proceed(newRequest);
        }
    }

#### 接口上使用`@Intercept`进行标注 ####

@RetrofitClient(baseUrl = "${test.baseUrl}")
    @Intercept(handler = TimeStampInterceptor.class, include = {"/api/**"}, exclude = "/api/test/savePerson")
    public interface HttpApi {
    
        @GET("person")
        Result<Person> getPerson(@Query("id") Long id);
    
        @POST("savePerson")
        Result<Person> savePerson(@Body Person person);
    }

上面的`@Intercept`配置表示：拦截`HttpApi`接口下`/api/**`路径下（排除`/api/test/savePerson`）的请求，拦截处理器使用`TimeStampInterceptor`。

### 扩展注解式拦截器 ###

有的时候，我们需要在**拦截注解**动态传入一些参数，然后再执行拦截的时候需要使用这个参数。这种时候，我们可以扩展实现**自定义拦截注解**。`自定义拦截注解`必须使用`@InterceptMark`标记，并且**注解中必须包括`include()、exclude()、handler()`属性信息**。使用的步骤主要分为3步：

1.  自定义拦截注解
2.  继承`BasePathMatchInterceptor`编写拦截处理器
3.  接口上使用自定义拦截注解；

例如我们需要**在请求头里面动态加入`accessKeyId`、`accessKeySecret`签名信息才能正常发起http请求**，这个时候**可以自定义一个加签拦截器注解`@Sign`来实现**。下面以自定义`@Sign`拦截注解为例进行说明。

#### 自定义`@Sign`注解 ####

@Retention(RetentionPolicy.RUNTIME)
    @Target(ElementType.TYPE)
    @Documented
    @InterceptMark
    public @interface Sign {
        /**
         * 密钥key
         * 支持占位符形式配置。
         *
         * @return
         */
        String accessKeyId();
    
        /**
         * 密钥
         * 支持占位符形式配置。
         *
         * @return
         */
        String accessKeySecret();
    
        /**
         * 拦截器匹配路径
         *
         * @return
         */
        String[] include() default {"/**"};
    
        /**
         * 拦截器排除匹配，排除指定路径拦截
         *
         * @return
         */
        String[] exclude() default {};
    
        /**
         * 处理该注解的拦截器类
         * 优先从spring容器获取对应的Bean，如果获取不到，则使用反射创建一个！
         *
         * @return
         */
        Class<? extends BasePathMatchInterceptor> handler() default SignInterceptor.class;
    }

扩展`自定义拦截注解`有以下2点需要注意：

1.  `自定义拦截注解`必须使用`@InterceptMark`标记。
2.  注解中必须包括`include()、exclude()、handler()`属性信息。

#### 实现`SignInterceptor` ####

@Component
    public class SignInterceptor extends BasePathMatchInterceptor {
    
        private String accessKeyId;
    
        private String accessKeySecret;
    
        public void setAccessKeyId(String accessKeyId) {
            this.accessKeyId = accessKeyId;
        }
    
        public void setAccessKeySecret(String accessKeySecret) {
            this.accessKeySecret = accessKeySecret;
        }
    
        @Override
        public Response doIntercept(Chain chain) throws IOException {
            Request request = chain.request();
            Request newReq = request.newBuilder()
                    .addHeader("accessKeyId", accessKeyId)
                    .addHeader("accessKeySecret", accessKeySecret)
                    .build();
            return chain.proceed(newReq);
        }
    }

**上述`accessKeyId`和`accessKeySecret`字段值会依据`@Sign`注解的`accessKeyId()`和`accessKeySecret()`值自动注入，如果`@Sign`指定的是占位符形式的字符串，则会取配置属性值进行注入**。另外，**`accessKeyId`和`accessKeySecret`字段必须提供`setter`方法**。

#### 接口上使用`@Sign` ####

@RetrofitClient(baseUrl = "${test.baseUrl}")
    @Sign(accessKeyId = "${test.accessKeyId}", accessKeySecret = "${test.accessKeySecret}", exclude = {"/api/test/person"})
    public interface HttpApi {
    
        @GET("person")
        Result<Person> getPerson(@Query("id") Long id);
    
        @POST("savePerson")
        Result<Person> savePerson(@Body Person person);
    }

这样就能在指定url的请求上，自动加上签名信息了。

### 连接池管理 ###

默认情况下，所有通过`Retrofit`发送的http请求都会使用`max-idle-connections=5 keep-alive-second=300`的默认连接池。当然，我们也可以在配置文件中配置多个自定义的连接池，然后通过`@RetrofitClient`的`poolName`属性来指定使用。比如我们要让某个接口下的请求全部使用`poolName=test1`的连接池，代码实现如下：

1.  配置连接池。
    
        retrofit:
        # 连接池配置
        pool:
            test1:
            max-idle-connections: 3
            keep-alive-second: 100
            test2:
            max-idle-connections: 5
            keep-alive-second: 50
2.  通过`@RetrofitClient`的`poolName`属性来指定使用的连接池。
    
        @RetrofitClient(baseUrl = "${test.baseUrl}", poolName="test1")
        public interface HttpApi {
        
        @GET("person")
        Result<Person> getPerson(@Query("id") Long id);
        }

### 日志打印 ###

很多情况下，我们希望将http请求日志记录下来。通过`retrofit.enableLog`配置可以全局控制日志是否开启。  
针对每个接口，可以通过`@RetrofitClient`的`enableLog`控制是否开启，通过`logLevel`和`logStrategy`，可以指定每个接口的日志打印级别以及日志打印策略。`retrofit-spring-boot-starter`支持了5种日志打印级别(`ERROR`, `WARN`, `INFO`, `DEBUG`, `TRACE`)，默认`INFO`；支持了4种日志打印策略（`NONE`, `BASIC`, `HEADERS`, `BODY`），默认`BASIC`。4种日志打印策略含义如下：

1.  `NONE`：No logs.
2.  `BASIC`：Logs request and response lines.
3.  `HEADERS`：Logs request and response lines and their respective headers.
4.  `BODY`：Logs request and response lines and their respective headers and bodies (if present).

`retrofit-spring-boot-starter`默认使用了`DefaultLoggingInterceptor`执行真正的日志打印功能，其底层就是`okhttp`原生的`HttpLoggingInterceptor`。当然，你也可以自定义实现自己的日志打印拦截器，只需要继承`BaseLoggingInterceptor`（具体可以参考`DefaultLoggingInterceptor`的实现），然后在配置文件中进行相关配置即可。

retrofit:
      # 日志打印拦截器
      logging-interceptor: com.github.lianjiatech.retrofit.spring.boot.interceptor.DefaultLoggingInterceptor

### 请求重试 ###

`retrofit-spring-boot-starter`支持请求重试功能，只需要在接口或者方法上加上`@Retry`注解即可。**`@Retry`支持重试次数`maxRetries`、重试时间间隔`intervalMs`以及重试规则`retryRules`配置**。重试规则支持三种配置：

1.  `RESPONSE_STATUS_NOT_2XX`：响应状态码不是`2xx`时执行重试；
2.  `OCCUR_IO_EXCEPTION`：发生IO异常时执行重试；
3.  `OCCUR_EXCEPTION`：发生任意异常时执行重试；

默认响应状态码不是`2xx`或者发生IO异常时自动进行重试。需要的话，你也可以继承`BaseRetryInterceptor`实现自己的请求重试拦截器，然后将其配置上去。

retrofit:
      # 请求重试拦截器
      retry-interceptor: com.github.lianjiatech.retrofit.spring.boot.retry.DefaultRetryInterceptor

### 错误解码器 ###

在`HTTP`发生请求错误(包括发生异常或者响应数据不符合预期)的时候，错误解码器可将`HTTP`相关信息解码到自定义异常中。你可以在`@RetrofitClient`注解的`errorDecoder()`指定当前接口的错误解码器，自定义错误解码器需要实现`ErrorDecoder`接口：

/**
     * 错误解码器。ErrorDecoder.
     * 当请求发生异常或者收到无效响应结果的时候，将HTTP相关信息解码到异常中，无效响应由业务自己判断
     *
     * When an exception occurs in the request or an invalid response result is received, the HTTP related information is decoded into the exception,
     * and the invalid response is determined by the business itself.
     *
     * @author 陈添明
     */
    public interface ErrorDecoder {
    
        /**
         * 当无效响应的时候，将HTTP信息解码到异常中，无效响应由业务自行判断。
         * When the response is invalid, decode the HTTP information into the exception, invalid response is determined by business.
         *
         * @param request  request
         * @param response response
         * @return If it returns null, the processing is ignored and the processing continues with the original response.
         */
        default RuntimeException invalidRespDecode(Request request, Response response) {
            if (!response.isSuccessful()) {
                throw RetrofitException.errorStatus(request, response);
            }
            return null;
        }
    
    
        /**
         * 当请求发生IO异常时，将HTTP信息解码到异常中。
         * When an IO exception occurs in the request, the HTTP information is decoded into the exception.
         *
         * @param request request
         * @param cause   IOException
         * @return RuntimeException
         */
        default RuntimeException ioExceptionDecode(Request request, IOException cause) {
            return RetrofitException.errorExecuting(request, cause);
        }
    
        /**
         * 当请求发生除IO异常之外的其它异常时，将HTTP信息解码到异常中。
         * When the request has an exception other than the IO exception, the HTTP information is decoded into the exception.
         *
         * @param request request
         * @param cause   Exception
         * @return RuntimeException
         */
        default RuntimeException exceptionDecode(Request request, Exception cause) {
            return RetrofitException.errorUnknown(request, cause);
        }
    
    }

## 全局拦截器 ##

### 全局应用拦截器 ###

如果我们需要对整个系统的的http请求执行统一的拦截处理，可以自定义实现全局拦截器`BaseGlobalInterceptor`, 并配置成`spring`容器中的`bean`！例如我们需要在整个系统发起的http请求，都带上来源信息。

@Component
    public class SourceInterceptor extends BaseGlobalInterceptor {
        @Override
        public Response doIntercept(Chain chain) throws IOException {
            Request request = chain.request();
            Request newReq = request.newBuilder()
                    .addHeader("source", "test")
                    .build();
            return chain.proceed(newReq);
        }
    }

### 全局网络拦截器 ###

只需要实现`NetworkInterceptor`接口 并配置成`spring`容器中的`bean`就支持自动织入全局网络拦截器。

### 熔断降级 ###

在分布式服务架构中，对不稳定的外部服务进行熔断降级是保证服务高可用的重要措施之一。由于外部服务的稳定性是不能保证的，当外部服务不稳定时，响应时间会变长。相应地，调用方的响应时间也会变长，线程会产生堆积，最终可能耗尽调用方的线程池，导致整个服务不可用。因此我们需要对不稳定的弱依赖服务调用进行熔断降级，暂时切断不稳定调用，避免局部不稳定导致整体服务雪崩。

`retrofit-spring-boot-starter`支持熔断降级功能，底层基于Sentinel实现。具体来说，支持了**熔断资源自发现**和**注解式降级规则配置**。如需使用熔断降级，只需要进行以下操作即可：

#### 1. 开启熔断降级功能 ####

**默认情况下，熔断降级功能是关闭的，需要设置相应的配置项来开启熔断降级功能**：

retrofit:
      # 是否启用熔断降级
      enable-degrade: true
      # 熔断降级实现方式(目前仅支持Sentinel)
      degrade-type: sentinel
      # 资源名称解析器
      resource-name-parser: com.github.lianjiatech.retrofit.spring.boot.degrade.DefaultResourceNameParser

资源名称解析器用于实现用户自定义资源名称，默认配置是`DefaultResourceNameParser`，对应的资源名称格式为`HTTP_OUT:GET:http://localhost:8080/api/degrade/test`。用户可以继承`BaseResourceNameParser`类实现自己的资源名称解析器。

另外，由于熔断降级功能是可选的，**因此启用熔断降级需要用户自行引入Sentinel依赖**：

<dependency>
        <groupId>com.alibaba.csp</groupId>
        <artifactId>sentinel-core</artifactId>
        <version>1.6.3</version>
    </dependency>

#### 2. 配置降级规则（可选） ####

**`retrofit-spring-boot-starter`支持注解式配置降级规则，通过`@Degrade`注解来配置降级规则**。`@Degrade`注解可以配置在接口或者方法上，配置在方法上的优先级更高。

@Retention(RetentionPolicy.RUNTIME)
    @Target({ElementType.METHOD, ElementType.TYPE})
    @Documented
    public @interface Degrade {
    
        /**
         * RT threshold or exception ratio threshold count.
         */
        double count();
    
        /**
         * Degrade recover timeout (in seconds) when degradation occurs.
         */
        int timeWindow() default 5;
    
        /**
         * Degrade strategy (0: average RT, 1: exception ratio).
         */
        DegradeStrategy degradeStrategy() default DegradeStrategy.AVERAGE_RT;
    }

> **如果应用项目已支持通过配置中心配置降级规则，可忽略注解式配置方式**。

#### 3. @RetrofitClient设置fallback或者fallbackFactory (可选) ####

如果`@RetrofitClient`不设置`fallback`或者`fallbackFactory`，当触发熔断时，会直接抛出`RetrofitBlockException`异常。**用户可以通过设置`fallback`或者`fallbackFactory`来定制熔断时的方法返回值**。`fallback`类必须是当前接口的实现类，`fallbackFactory`必须是`FallbackFactory<T>`实现类，泛型参数类型为当前接口类型。另外，`fallback`和`fallbackFactory`实例必须配置成`Spring`容器的`Bean`。

**`fallbackFactory`相对于`fallback`，主要差别在于能够感知每次熔断的异常原因(cause)**。参考示例如下：

@Slf4j
    @Service
    public class HttpDegradeFallback implements HttpDegradeApi {
    
        @Override
        public Result<Integer> test() {
            Result<Integer> fallback = new Result<>();
            fallback.setCode(100)
                    .setMsg("fallback")
                    .setBody(1000000);
            return fallback;
        }
    }

@Slf4j
    @Service
    public class HttpDegradeFallbackFactory implements FallbackFactory<HttpDegradeApi> {
    
        /**
         * Returns an instance of the fallback appropriate for the given cause
         *
         * @param cause fallback cause
         * @return 实现了retrofit接口的实例。an instance that implements the retrofit interface.
         */
        @Override
        public HttpDegradeApi create(Throwable cause) {
            log.error("触发熔断了! ", cause.getMessage(), cause);
            return new HttpDegradeApi() {
                @Override
                public Result<Integer> test() {
                    Result<Integer> fallback = new Result<>();
                    fallback.setCode(100)
                            .setMsg("fallback")
                            .setBody(1000000);
                    return fallback;
                }
        }
    }

### 微服务之间的HTTP调用 ###

为了能够使用微服务调用，需要进行如下配置：

#### 配置`ServiceInstanceChooser`为`Spring`容器`Bean` ####

用户可以自行实现`ServiceInstanceChooser`接口，完成服务实例的选取逻辑，并将其配置成`Spring`容器的`Bean`。对于`Spring Cloud`应用，`retrofit-spring-boot-starter`提供了`SpringCloudServiceInstanceChooser`实现，用户只需将其配置成`Spring`的`Bean`即可。

@Bean
    @Autowired
    public ServiceInstanceChooser serviceInstanceChooser(LoadBalancerClient loadBalancerClient) {
        return new SpringCloudServiceInstanceChooser(loadBalancerClient);
    }

#### 使用`@Retrofit`的`serviceId`和`path`属性，可以实现微服务之间的HTTP调用 ####

@RetrofitClient(serviceId = "${jy-helicarrier-api.serviceId}", path = "/m/count", errorDecoder = HelicarrierErrorDecoder.class)
    @Retry
    public interface ApiCountService {
    
    }

## 调用适配器和数据转码器 ##

### 调用适配器 ###

`Retrofit`可以通过调用适配器`CallAdapterFactory`将`Call<T>`对象适配成接口方法的返回值类型。`retrofit-spring-boot-starter`扩展2种`CallAdapterFactory`实现：

1.  `BodyCallAdapterFactory`

*  默认启用，可通过配置`retrofit.enable-body-call-adapter=false`关闭
 *  同步执行http请求，将响应体内容适配成接口方法的返回值类型实例。
 *  除了`Retrofit.Call<T>`、`Retrofit.Response<T>`、`java.util.concurrent.CompletableFuture<T>`之外，其它返回类型都可以使用该适配器。

*  `ResponseCallAdapterFactory`
 *   *  默认启用，可通过配置`retrofit.enable-response-call-adapter=false`关闭
     *  同步执行http请求，将响应体内容适配成`Retrofit.Response<T>`返回。
     *  如果方法的返回值类型为`Retrofit.Response<T>`，则可以使用该适配器。
    
    **Retrofit自动根据方法返回值类型选用对应的`CallAdapterFactory`执行适配处理！加上Retrofit默认的`CallAdapterFactory`，可支持多种形式的方法返回值类型：**
    
     *  `Call<T>`: 不执行适配处理，直接返回`Call<T>`对象
     *  `CompletableFuture<T>`: 将响应体内容适配成`CompletableFuture<T>`对象返回
     *  `Void`: 不关注返回类型可以使用`Void`。如果http状态码不是2xx，直接抛错！
     *  `Response<T>`: 将响应内容适配成`Response<T>`对象返回
     *  其他任意Java类型：将响应体内容适配成一个对应的Java类型对象返回，如果http状态码不是2xx，直接抛错！
    
            /**
             * Call<T>
             * 不执行适配处理，直接返回Call<T>对象
             * @param id
             * @return
             */
            @GET("person")
            Call<Result<Person>> getPersonCall(@Query("id") Long id);
        
            /**
             *  CompletableFuture<T>
             *  将响应体内容适配成CompletableFuture<T>对象返回
             * @param id
             * @return
             */
            @GET("person")
            CompletableFuture<Result<Person>> getPersonCompletableFuture(@Query("id") Long id);
        
            /**
             * Void
             * 不关注返回类型可以使用Void。如果http状态码不是2xx，直接抛错！
             * @param id
             * @return
             */
            @GET("person")
            Void getPersonVoid(@Query("id") Long id);
        
            /**
             *  Response<T>
             *  将响应内容适配成Response<T>对象返回
             * @param id
             * @return
             */
            @GET("person")
            Response<Result<Person>> getPersonResponse(@Query("id") Long id);
        
            /**
             * 其他任意Java类型
             * 将响应体内容适配成一个对应的Java类型对象返回，如果http状态码不是2xx，直接抛错！
             * @param id
             * @return
             */
            @GET("person")
            Result<Person> getPerson(@Query("id") Long id);
    
    **我们也可以通过继承`CallAdapter.Factory`扩展实现自己的`CallAdapter`**！
    
    `retrofit-spring-boot-starter`支持通过`retrofit.global-call-adapter-factories`配置全局调用适配器工厂，工厂实例优先从Spring容器获取，如果没有获取到，则反射创建。默认的全局调用适配器工厂是`[BodyCallAdapterFactory, ResponseCallAdapterFactory]`！
    
        retrofit:
          # 全局调用适配器工厂
          global-call-adapter-factories:
            - com.github.lianjiatech.retrofit.spring.boot.core.BodyCallAdapterFactory
            - com.github.lianjiatech.retrofit.spring.boot.core.ResponseCallAdapterFactory
    
    针对每个Java接口，还可以通过`@RetrofitClient`注解的`callAdapterFactories()`指定当前接口采用的`CallAdapter.Factory`，指定的工厂实例依然优先从Spring容器获取。
    
    **注意：如果`CallAdapter.Factory`没有`public`的无参构造器，请手动将其配置成`Spring`容器的`Bean`对象**！
    
    ### 数据转码器 ###
    
    `Retrofit`使用`Converter`将`@Body`注解标注的对象转换成请求体，将响应体数据转换成一个`Java`对象，可以选用以下几种`Converter`：
    
     *  Gson: com.squareup.Retrofit:converter-gson
     *  Jackson: com.squareup.Retrofit:converter-jackson
     *  Moshi: com.squareup.Retrofit:converter-moshi
     *  Protobuf: com.squareup.Retrofit:converter-protobuf
     *  Wire: com.squareup.Retrofit:converter-wire
     *  Simple XML: com.squareup.Retrofit:converter-simplexml
     *  JAXB: com.squareup.retrofit2:converter-jaxb
    
    `retrofit-spring-boot-starter`支持通过`retrofit.global-converter-factories`配置全局数据转换器工厂，转换器工厂实例优先从Spring容器获取，如果没有获取到，则反射创建。默认的全局数据转换器工厂是`retrofit2.converter.jackson.JacksonConverterFactory`，你可以直接通过`spring.jackson.*`配置`jackson`序列化规则，配置可参考Customize the Jackson ObjectMapper！
    
        retrofit:
          # 全局转换器工厂
          global-converter-factories:
            - retrofit2.converter.jackson.JacksonConverterFactory
    
    针对每个Java接口，还可以通过`@RetrofitClient`注解的`converterFactories()`指定当前接口采用的`Converter.Factory`，指定的转换器工厂实例依然优先从Spring容器获取。
    
    **注意：如果`Converter.Factory`没有`public`的无参构造器，请手动将其配置成`Spring`容器的`Bean`对象**！
    
    ## 总结 ##
    
    `retrofit-spring-boot-starter`一个适用于`SpringBoot`项目的轻量级`HTTP`客户端框架，已在线上稳定运行一年多，并且已经有多个外部公司也接入使用。
    
    来源：juejin.cn/post/6898485806587969544

[7b0c1a80a932c1a737ec5fcec4eb4177.gif]: /images/20210730/ac16cfd806e84e5294336a07b4358d2b.png