SpringCloud集成OpenFeign，轻松RPC

前言

Springcloud解决方案，实现微服务；是目前很多中小公司实现微服务的常见的解决方式；在每个微服务单元之间的RPC调用，在SpringCloud的解决方案中通过Web Restful实现也是最常见的场景，在Springcloud的整体解决方案中，官方推荐的是使用SpringCloud OpenFeign来实现此目的；有关这个话题很多技术论坛都有相关的文章进行介绍，在大多数的文章中，还没有与时俱进，SpringCloud的版本还停留在2019年推出的以地铁站为命名的一系列版本里，例如Hoxton.SRX等；2019版本已经过于旧了，其中的netifix的ribbon和hystrix都已经不进行维护了，今天咱们要给大家介绍的就是使用最新的SpringCloud2021系列的版本进行OpenFeign的集成，从而实现RPC。

SpringCloud&SpringBoot

以上的图是SpringCloud官网上的SpringCloud的release Map图； 最新的SpringCloud的版本是2021.0.X， 注意第二列，由于SpringCloud是基于SpingBoot框架而进行实现和定义接口的，所以需要严格的对应SpringCloud和SpringBoot的版本； 如上图所示， 我们的SpringBoot可以选择使用2.6.X系列或者2.7.X系列， 笔者建议先使用2.6.X系列

SpringCloud OpenFeign

上图是从SpringCloud官网的OpenFeign模块的主页摘录下来的； (https://spring.io/projects/spring-cloud-openfeign)

如图中说示： OpenFeign是声明性REST客户端：Feign创建一个用JAX-RS或Spring MVC注释装饰的接口的动态实现REST RPC的实现。

下图是SpringCloud OpenFeign的版本蓝图， 笔者建议使用3.1.X版本，笔者自己使用的是3.1.1版本

SpringCloud OpenFeign工作流程

Target(动态代理层)，即为我们通过FeignClient实现RPC定义的接口层，此次技术使用了Java的动态代理技术和SpringBoot里的BeanProcessor的Bean生命周期管理的技术；

Constract为合约层，在SpringCloud的WebMvc实现了WebMvcContract，为默认的合约，没有指定合约时即使用该合约； OpenFeign包里实现了Feign的标准合约，通常我们的项目开发里都是没有特别指定的，都是用的Mvc的合约，在FeignClient的RPC接口定义时，使用的annotation也都是MVC的annotation， 如：PostMapping， GetMapping

MethondHandler是动态代理的具体实现方法，对应的就是去Target进行RPC的调用

使用步骤

引入OpenFeign包

<dependency>
    <groupId>org.springframework.cloudgroupId>
    <artifactId>spring-cloud-starter-openfeignartifactId>
dependency>
 
<dependency>
    <groupId>org.springframework.cloudgroupId>
    <artifactId>spring-cloud-starter-loadbalancerartifactId>
dependency>
 
<dependency>
    <groupId>org.springframework.cloudgroupId>
    <artifactId>spring-cloud-loadbalancerartifactId>
dependency>
 
<dependency>
    <groupId>org.springframework.cloudgroupId>
    <artifactId>spring-cloud-starter-circuitbreaker-resilience4jartifactId>
dependency>
 
<dependency>
    <groupId>io.github.resilience4jgroupId>
    <artifactId>resilience4j-feignartifactId>
    <version>1.7.0version>
dependency>

启动类引入Feign支持

@SpringBootApplication
@EnableFeignClients
public class Application {
 
    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }
 
}

在启动类里需要增加@EnableFeignClients注解，这样项目启动是，会有autoconfiguration机制自动的在Application为根包路径下去扫描所有的FeignClient，并产出流程步骤中所表示的动态代理层的Bean对象；

定义客户端RPC接口

在客户端定义接口，去调用服务提供方提供的WEB RESTFUL的服务；

客户端只需要根据服务提供方提供的WEB API的标准，定义出访问的API，通过对客户端的接口访问，就会处理到动态代理层，动态代理层根据合约对接口进行WEB RESTFUL的封装，然后在methodHandler里通过HttpClient的方式去服务提供方进行WEB调用，从而完成RPC的实现；

@FeignClient("stores")
public interface StoreClient {
    @RequestMapping(method = RequestMethod.GET, value = "/stores")
    List getStores();
 
    @RequestMapping(method = RequestMethod.GET, value = "/stores")
    Page getStores(Pageable pageable);
 
    @RequestMapping(method = RequestMethod.POST, value = "/stores/{storeId}", consumes = "application/json")
    Store update(@PathVariable("storeId") Long storeId, Store store);
 
    @RequestMapping(method = RequestMethod.DELETE, value = "/stores/{storeId:\\d+}")
    void delete(@PathVariable Long storeId);
}

上面这些都是使用的MVC的合约，使用的annotation都是MVC的annotation； 下面的例子是使用Feign自己的标准annotation； 笔者建议使用这种方式更为标准

// after Hystrix is removed from SpringCloud2021.0.1, the fallback is ineffective
@FeignClient(name = "${codeman.service.name:codeman}", url = "${codeman.service.address:}", fallback = CodeManFallbackImpl.class)
public interface CodeManFeign extends CodeManService {
 
    @RequestLine("GET /codeman/info/version")
    public String getVersion();
 
    @RequestLine("GET /codeman/info/author")
    public String getAuthor();
 
    @RequestLine("GET /codeman/info/request/{userid}")    //对应请求方式和路径
    public String requestLine(@Param("userid") String userid);
}

调用RPC

@Slf4j
@Component("CodeManService")
public class CodeManServiceImpl implements CodeManService {
 
    @Autowired
    CodeManFeign codeManFeign;
 
    @Override
    @CircuitBreaker(name = "default", fallbackMethod = "getVersionFallback")
    public String getVersion() {
 
        return codeManFeign.getVersion();
    }
 
    @Override
    @CircuitBreaker(name = "default", fallbackMethod = "getAuthorFallback")
    public String getAuthor() {
        return codeManFeign.getAuthor();
    }
 
    @Override
    @CircuitBreaker(name = "default", fallbackMethod = "requestLineFallback")
    public String requestLine(String userid) {
        return codeManFeign.requestLine(userid);
    }
 
 
    public String getVersionFallback(Throwable t) {
        log.info("=================================  Exception(getVersion): {}", t.getMessage());
        return "N/A";
    }
 
    public String getAuthorFallback(Throwable t) {
        log.info("=================================  Exception(getAuthor): {}", t.getMessage());
        return "SpringCloud";
    }
 
    public String requestLineFallback(String userid, Throwable t){
        log.info("=================================  Exception(requestLine): {}", t.getMessage());
        return "Kill team‘s poison " + userid;
    }
}

 

结束语

本文主要介绍的是在springcloud最新版本里使用OpenFeign实现RPC调用，作为完整的OpenFeign的RPC调用实现，还有更高级的一些话题，比如Fallback； LoadBalance； 和服务发现集成使用等高级用法，本文篇幅有限，在以后的相关文章会介绍这些OpenFeign使用的高级用法；敬请大家持续关注；

谢谢大家持续关注，不要错过精彩内容。