12

推荐一个适用于SpringBoot项目的轻量级HTTP客户端框架,快来试试它!

 3 years ago
source link: https://segmentfault.com/a/1190000038265834
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
neoserver,ios ssh client

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

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

前言

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

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

:rocket:项目持续优化迭代,欢迎大家提ISSUE和PR!麻烦大家能给一颗star:sparkles:,您的star是我们持续更新的动力!

功能特性

快速使用

引入依赖

<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官方文档 ,以下是一个简单说明。

注解分类 支持的注解 请求方式 @GET @HEAD @POST @PUT @DELETE @OPTIONS 请求头 @Header @HeaderMap @Headers Query参数 @Query @QueryMap @QueryName path参数 @Path form-encoded参数 @Field @FieldMap @FormUrlEncoded 文件上传 @Multipart @Part @PartMap url参数 @Url

配置项说明

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

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

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步:

BasePathMatchInterceptor

例如我们需要 在请求头里面动态加入 accessKeyIdaccessKeySecret 签名信息才能正常发起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);
    }
}

上述 accessKeyIdaccessKeySecret 字段值会依据 @Sign 注解的 accessKeyId()accessKeySecret() 值自动注入,如果 @Sign 指定的是占位符形式的字符串,则会取配置属性值进行注入 。另外, accessKeyIdaccessKeySecret 字段必须提供 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 的默认连接池。当然,我们也可以在配置文件中配置多个自定义的连接池,然后通过 @RetrofitClientpoolName 属性来指定使用。比如我们要让某个接口下的请求全部使用 poolName=test1 的连接池,代码实现如下:

  1. 配置连接池。

    retrofit:
        # 连接池配置
        pool:
            test1:
            max-idle-connections: 3
            keep-alive-second: 100
            test2:
            max-idle-connections: 5
            keep-alive-second: 50
  2. 通过 @RetrofitClientpoolName 属性来指定使用的连接池。

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

日志打印

很多情况下,我们希望将http请求日志记录下来。通过 retrofit.enableLog 配置可以全局控制日志是否开启。

针对每个接口,可以通过 @RetrofitClientenableLog 控制是否开启,通过 logLevellogStrategy ,可以指定每个接口的日志打印级别以及日志打印策略。 retrofit-spring-boot-starter 支持了5种日志打印级别( ERROR , WARN , INFO , DEBUG , TRACE ),默认 INFO ;支持了4种日志打印策略( NONE , BASIC , HEADERS , BODY ),默认 BASIC 。4种日志打印策略含义如下:

NONE
BASIC
HEADERS
BODY

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> 实现类,泛型参数类型为当前接口类型。另外, fallbackfallbackFactory 实例必须配置成 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调用

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

配置 ServiceInstanceChooserSpring 容器 Bean

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

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

使用 @RetrofitserviceIdpath 属性,可以实现微服务之间的HTTP调用

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

}

调用适配器和数据转码器

调用适配器

Retrofit 可以通过调用适配器 CallAdapterFactoryCall<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> 之外,其它返回类型都可以使用该适配器。
  2. ResponseCallAdapterFactory

    retrofit.enable-response-call-adapter=false
    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 客户端框架,已在线上稳定运行一年多,并且已经有多个外部公司也接入使用。有兴趣的朋友可以尝试一下,如有任何问题,欢迎提issue或者加QQ群(806714302)反馈,极速响应支持。

原创不易,觉得文章写得不错的小伙伴,点个赞:+1: 鼓励一下吧~


About Joyk


Aggregate valuable and interesting links.
Joyk means Joy of geeK