Spring Cloud Feign
在此之前，各个微服务都是以HTTP接口的形式暴露自身服务的，因此在调用远程服务时就必须使用HTTP客户端，使用起来很不方便，需要了解URL，有时还需要拼装真正请求的URL。有没有一种用起来更方便、更优雅的方式吗？答案是肯定的，Spring Cloud想到了这些————Feign。Spring Cloud Feign是一套基于Netflix Feign实现的声明式服务调用客户端。它使得编写Web服务客户端变得更加简单。在Spring Cloud中使用Feign, 我们只需要通过创建接口并用注解来配置既可完成对Web服务接口的绑定，可以做到使用HTTP请求远程服务时能与调用本地方法一样的编码体验，感知不到这是个HTTP请求，同时还整合了Ribbon和Eureka来提供均衡负载的HTTP客户端实现，实现透明化的负载均衡。
Feign是一个声明式Web Service客户端。使用Feign能让编写Web Service客户端更加简单, 它的使用方法是定义一个接口，然后在上面添加注解，同时也支持JAX-RS标准的注解。Feign也支持可拔插式的编码器和解码器。Spring Cloud对Feign进行了封装，使其支持了Spring MVC标准注解和HttpMessageConverters。Feign可以与Eureka和Ribbon组合使用以支持负载均衡。
举一个栗子
下面，通过一个例子来展现Feign如何方便的声明对eureka-service-provider服务的定义和调用。
- 为之前的服务提供者
eureka-service-provider代码增加Feign支持，在pom.xml文件中添加依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-feign</artifactId>
</dependency>
- 创建一个Feign的客户端接口定义。使用
@FeignClient注解来指定这个接口所要调用的服务名称，接口中定义的各个函数使用Spring MVC的注解就可以来绑定服务提供方的REST接口，一般情况，我会把这些Client放到一个core项目里，此项目就是提供给客户端调用，比如下面的代码放到eureka-service-core项目中：
import com.gemantic.commons.ResultData;
import com.gemantic.simulate.model.EntrustQueue;
import org.springframework.cloud.netflix.feign.FeignClient;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
@FeignClient("eureka-service-provider")
public interface EntrustQueueClient {
@PostMapping("/entrusQueue")
ResponseEntity<ResultData> addEntrust(@RequestBody EntrustQueue entrustQueue);
}
- 将上面定义的接口引入客户端，在客户端项目中的pom.xml文件中增加依赖
<!-- Fegin 自定义Client接口依赖 -->
<dependency>
<groupId>com.xxx.demo</groupId>
<artifactId>eureka-service-core</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<!-- Fegin 依赖 -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-feign</artifactId>
</dependency>
- 最后，在
main方法上增加注解@EnableFeignClients
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.feign.EnableFeignClients;
/**
* Hello world!
*/
@SpringBootApplication
@EnableFeignClients
@EnableDiscoveryClient
public class Server {
public static void main(String[] args) {
SpringApplication.run(Server.class, args);
}
}
- 客户端调用，调用本地方法一样的编码体验！通过对比发现是不是更方便、更优雅哈～
@Slf4j
@RestController
@Api(description = "模拟交易委托队列接口")
public class EntrustQueueController {
@Autowired
private RestTemplate restTemplate;
@Autowired
private EntrustQueueClient entrustQueueClient;
@ApiOperation(value = "新增加委托请求")
@PostMapping("/entrusQueue")
public ResponseEntity<ResultData> addEntrust(@RequestBody EntrustQueue entrustQueue) {
log.info("entrusQueue" + entrustQueue.toString());
ResultData resultData = restTemplate.postForObject("http://simulate-trade-service/entrusQueue", entrustQueue, ResultData.class);
return ResponseEntity.ok(resultData);
}
@ApiOperation(value = "新增加委托请求Feign")
@PostMapping("/entrusQueueFeign")
public ResponseEntity<ResultData> addEntrust2(@RequestBody EntrustQueue entrustQueue) {
log.info("entrusQueueFeign:" + entrustQueue.toString());
ResponseEntity<ResultData> resultData = entrustQueueClient.addEntrust(entrustQueue);
return resultData;
}
}
在完成了上面你的代码编写之后，就可以把eureka服务注册中心、服务提供者（多启动几个，体验一下负载均衡）、服务消费者启动进行测试了。由于Feign是基于Ribbon实现的，所以它自带了客户端负载均衡功能。
