接口请求工具 - Feign

接口请求工具

在微服务还未盛行的时候,一般服务间的请求使用的底层方式: jdk自带的HttpURLConnection 或者 封装的Apache HttpClient / Okhttp 等框架,微服务盛行后优秀的请求框架 Feign 被Spring看中 推荐成了微服务体系里面的请求工具,有着简洁 效率 易读 侵虐性低等优点。本文主要介绍剥离开Spring框架使用Feign,或者在Spring中调用未接入微服务注册中心的服务/系统。

Git 地址

Feign配置

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
// 设置不格式化json
ObjectMapper mapper = new ObjectMapper().disable(SerializationFeature.INDENT_OUTPUT);
JacksonDecoder decoder = new JacksonDecoder();
// json 编码 并兼容表单提交方式
FormEncoder formEncoder = new FormEncoder(new JacksonEncoder(mapper));
// 包含熔断器的builder
HystrixFeign.Builder builder = HystrixFeign.builder()
// 设置底层实现形式 提高效率
.client(new OkHttpClient())
// 请求连接时间 请求等待时间
.options(new Request.Options(10000, 120000))
// 重试机制
.retryer(new Retryer.Default(5000, 5000, 3))
.encoder(formEncoder).decoder(decoder)
.logger(new Slf4jLogger());
}

Get 请求

1
2
3
4
public interface IGetFeign {
@RequestLine("GET /xxxxx?param={id}")
UserVO getXXXById(@Param("id") Long id);
}

可以使用@QueryMap 注解查询多个参数

POST 请求

1
2
3
4
5
6
7
8
public interface IPostFeign {
@RequestLine("POST /xxx/save")
Boolean save(Map data, @HeaderMap Map<String, String> headerMap);

@RequestLine("POST /xxx/get_product")
@Headers("Content-Type: application/x-www-form-urlencoded")
Product getProductInfo(@Param("id") Long id);
}

可以使用 @Headers() 单独添加头信息 变量可以使用 @Param 注解传入,或者 使用 @HeaderMap 添加多个头信息;默认使用json编码传输,可以通过头信息来指定content-type传输,或者使用 @Body 注解直接书写传输内容

使用

1
2
IPostFeign feign = builder.target(IPostFeign.class, "productAddress", fallbackFactory);
Product product = feign.getProductInfo(1L);

使用了熔断器的话 需要写个fallback类 继承 FallbackFactory

Spring中使用

把Feign配置使用@Configuration注解,并把targer生成的对象 添加 @Bean注解 添加到容器中,在使用的地方注入即可

RabbitMQ 拓展篇

jackson

在 rabbitMq 中还有个重要的组件是 MessageConverter,用于消息格式的设置。
默认使用amqp的 SimpleMessageConverter 使用text传输,在传输量较大的数据时比较消耗性能。
另一种就是 Jackson2JsonMessageConverter,使用json传输。

RabbitMQ 基础篇

消息队列

单线程中间件,主要用于异步通知、消息分发、缓存、分布式事务等场景。

RabbitMQ

主要有Exchange 交换器 和 Queue 队列功能组件。
生产者会向Exchange发送消息并且绑定一个RoutingKey,
Exchange 用来接收生产者发送的消息并通过模式和规则将这些消息路由给服务器中的队列,
Exchange通过BindingKey找到匹配的队列,Queue 用来保存消息直到发送给消费者。

aop

spring aop

通过自定义注解和aop实现参数校验.

配置

  • mvc 配置文件 添加
    1
    <aop:aspectj-autoproxy proxy-target-class="true"/>

开启自动切面代理