Decoder
RestClient
会自动根据用户的 Headers
与 期望Entity
类型 等选择合适的Decoder
进行解码。RestClient
内置了下面这些Decoder
:
-
Json
-
jackson :默认,自动通过SPI的方式注入到RestClient中
-
fastjson :需要引入
fastjson
依赖,并将FastJsonCodec
添加到RestClient中 -
gson :需要引入
gson
依赖,并将GsonCodec
添加到RestClient中
-
-
ProtoBuf :需要引入
ProtoBuf
依赖,并将ProtoBufCodec
添加到RestClient中 -
String :自动通过SPI的方式注入到RestClient中
-
byte[] :自动通过SPI的方式注入到RestClient中
除此之外RestClient
也支持用户自定义解码器。
使用Json Decoder
当Response的contentType
为MediaType.APPLICATION_JSON
,将自动使用Json Decoder
来来进行Decode
。
final RestClient client = RestClient.ofDefault();
RestResponseBase response = client.get("localhost:8080/aaa")
.execute()
.toCompletableFuture()
.get();
//当 response.contentType() == MediaType.APPLICATION_JSON 时将自动使用Json Decoder
Person person = response.bodyToEntity(Person.class);
Note
其中Json相关的序列化方式默认配置了日期格式为yyyy-MM-dd HH:mm:ss
使用ProtoBuf Decoder
Step1 : 引入ProtoBuf依赖
<dependency>
<groupId>com.google.protobuf</groupId>
<artifactId>protobuf-java</artifactId>
</dependency>
Step2 : 使用 ProtoBuf Decoder 进行解码
将ProtoBufCodec加入到RestClient中, 当Response的contentType
为ProtoBufCodec.PROTO_BUF
,且response.bodyToEntity()
传入的类型为com.google.protobuf.Message
的子类时,将自动使用ProtoBuf Decoder
来进行Decode
。
//将ProtoBufCodec加入到RestClient中
final RestClient client = RestClient.create()
.addDecoder(new ProtoBufCodec())
.build();
RestResponseBase response = client.get("localhost:8080/aaa")
.execute()
.toCompletableFuture()
.get();
//当 ProtoBufCodec.PROTO_BUF.isCompatibleWith(response.contentType()),且 Person 为 Message 的子类时,将自动使用ProtoBuf Decoder
Person person = response.bodyToEntity(Person.class);
使用String Encoder
当response.bodyToEntity()
传入的类型为String.class
,且Response的contentType
不为MediaType.APPLICATION_JSON
时,将自动使用String Decoder
来进行Decode
。
final RestClient client = RestClient.ofDefault();
RestResponseBase response = client.get("localhost:8080/aaa")
.execute()
.toCompletableFuture()
.get();
//当 !MediaType.APPLICATION_JSON.isCompatibleWith(response.contentType()) 时,自动使用String Decoder来进行Decode
String result = response.bodyToEntity(String.class);
使用byte[] Encoder
当response.bodyToEntity()
传入的类型为byte[].class
,且Response的contentType
不为MediaType.APPLICATION_JSON
时,将自动使用byte[] Decoder
来进行Decode
。
final RestClient client = RestClient.ofDefault();
RestResponseBase response = client.get("localhost:8080/aaa")
.execute()
.toCompletableFuture()
.get();
//当 !MediaType.APPLICATION_JSON.isCompatibleWith(response.contentType()) 时,自动使用byte[] Decoder来进行Decode
byte[] result = response.bodyToEntity(byte[].class);
自定义Decoder
当RestClient
内置的Decoder
无法满足用户需求时,用户可以自定义Decoder
,示例如下:
public class StringDecoder implements ByteDecoder {
@Override
public Object doDecode(DecodeContext<byte[]> ctx) {
if (String.class.isAssignableFrom(ctx.targetType())) {
return new String(ctx.content().value());
}
return ctx.next();
}
}
Tip
在RestClient
中,同时存在多个Decoder
,它们之间通过getOrder()
方法返回值区分执行顺序,值越小,优先级越高。
针对当前Decoder
,分为两种情况:
- 当前
Decoder
可以Decode
该响应: 直接返回Decode
后的结果。 - 当前
Decoder
不可以Decode
该响应: 调用ctx.next()
,将Decode
工作交给下一个Decoder
,如果RestClient
中的所有Decoder
都无法编码该请求,则RestClient
将抛出CodecException
异常。
配置Decoder
Builder
在构造RestClient
时传入自定义的Decoder
实例,如:
final RestClient client = RestClient.create()
.addDecoder(ctx -> {
//decode...
return ctx.next();
})
.build();
SPI
普通SPI
RestClient
支持通过SPI的方式加载Decoder
接口的实现类,使用时只需要按照SPI的加载规则将自定义的Decoder
放入指定的目录下即可。
DecoderFactory
如果用户自定义的Decoder
对于不同RestClient
的配置有不同的实现,则用户可以实现DecoderFactory
接口,并按照SPI的加载规则将自定义的DecoderFactory
放入指定的目录下即可。
public interface DecoderFactory {
Collection<Decoder> decoders(RestClientOptions clientOptions);
}
在RestClient
构建时将调用DecoderFactory.decoders(RestClientOptions clientOptions)
,该方法返回的所有Decoder
都将加入到构建好的RestClient
中。
直接绑定Request
Decoder
可以直接绑定Request
,使用方式如下:
final RestResponseBase response = client.post(url)
.entity(new File("aaa"))
.decoder(ctx -> {
//decode...
return ctx.next();
})
.execute()
.toCompletableFuture()
.get();
Tip
当Request
绑定了Decoder
,该Client中设置的所有Decoder
将对该请求失效。即:如果当前Decoder
无法解码该响应,则RestClient
将会抛出CodecException异常。
执行时机
见请求处理完整流程中的Decoder
。
DecodeAdvice
用户可以通过DecodeAdvice
在Decode
前后进行来插入业务逻辑,来对要解码的 ResponseContent
或者 Decode
后的对象 进行修改替换等操作。
示例
public class DecodeAdviceImpl implements DecodeAdvice {
@Override
public Object aroundDecode(DecodeAdviceContext ctx) throws Exception {
//...before decode
Object decoded = ctx.next();
//...after decode
return decoded;
}
}
Tip
多个DecodeAdvice
之间通过getOrder()
方法返回值区分执行顺序,值越小,优先级越高。
配置方式
Builder
在构造RestClient
时传入自定义的DecodeAdvice
实例,如:
final RestClient client = RestClient.create()
.addDecodeAdvice(ctx ->{
//...before decode
Object decoded = ctx.next();
//...after decode
return decoded;
})
.build();
SPI
普通SPI
RestClient
支持通过SPI的方式加载DecodeAdvice
接口的实现类,使用时只需要按照SPI的加载规则将自定义的DecodeAdvice
放入指定的目录下即可。
DecodeAdviceFactory
如果用户自定义的DecodeAdvice
对于不同RestClient
的配置有不同的实现,则用户可以实现DecodeAdviceFactory
接口,并按照SPI的加载规则将自定义的DecodeAdviceFactory
放入指定的目录下即可。
public interface DecodeAdviceFactory {
Collection<DecodeAdvice> decodeAdvices(RestClientOptions clientOptions);
}
在RestClient
构建时将调用DecodeAdviceFactory.decodeAdvices(RestClientOptions clientOptions)
,该方法返回的所有DecodeAdvice
都将加入到构建好的RestClient
中。
执行时机
见请求处理完整流程中的DecodeAdvice
。
Feedback
Was this page helpful?
Glad to hear it! Please tell us how we can improve.
Sorry to hear that. Please tell us how we can improve.