【发布时间】:2019-11-08 20:26:50
【问题描述】:
我使用 Hystrix 设置了 Feign 客户端,我正在尝试将我从 API 调用中获得的所有 HTTP 状态代码记录到数据库中。所以这意味着,如果我的一个电话给我一个 201,我想将它记录到数据库中。如果我的调用导致失败,我的后备处理程序显然可以记录下来,但我想在一个地方插入数据库。 feign 是否有办法获得响应或某种通用回调?
【问题讨论】:
我使用 Hystrix 设置了 Feign 客户端,我正在尝试将我从 API 调用中获得的所有 HTTP 状态代码记录到数据库中。所以这意味着,如果我的一个电话给我一个 201,我想将它记录到数据库中。如果我的调用导致失败,我的后备处理程序显然可以记录下来,但我想在一个地方插入数据库。 feign 是否有办法获得响应或某种通用回调?
【问题讨论】:
您必须提供自定义decoder 才能在ResponseEntity<Object> 中获得回复。
NotificationClient notificationClient = Feign.builder()
.encoder(new JacksonEncoder())
.decoder(customDecoder())
.target(Target.EmptyTarget.create(NotificationClient.class));
在这里定义您的自定义解码器 bean。您可以通过实现 Decoder 来定义自己的,但我使用的是 spring 解码器。
@Bean
public Decoder customDecoder() {
HttpMessageConverter jacksonConverter = new MappingJackson2HttpMessageConverter(customObjectMapper());
ObjectFactory<HttpMessageConverters> objectFactory = () -> new HttpMessageConverters(jacksonConverter);
return new ResponseEntityDecoder(new SpringDecoder(objectFactory));
}
现在在ResponseEntity<Object>收集您的回复
ResponseEntity<Object> response = notificationClient.notify();
int status = response.getStatusCodeValue();
【讨论】:
另一种选择是创建自己的 feign.Logger 实现,覆盖 logAndRebufferResponse 方法:
protected Response logAndRebufferResponse(
String configKey, Level logLevel, Response response, long elapsedTime);
这可能比创建Decoder 更简单,并且无论状态如何,都保证在收到响应时调用。 Decoders 只有在请求没有触发错误时才会被调用。
【讨论】: