本文由淺人深，帶你了解如何在項(xiàng)目中整合OpenFeign與Sentinel，分析Sentinel源碼，并打造自己的Sentinel腳手架。

Sentinel是什么

Sentinel是阿里巴巴開源的一款微服務(wù)流量控制組件。是面向分布式、多語言異構(gòu)化服務(wù)架構(gòu)的流量治理組件，主要以流量為切入點(diǎn)，從流量路由、流量控制、流量整形、熔斷降級(jí)、系統(tǒng)自適應(yīng)過載保護(hù)、熱點(diǎn)流量防護(hù)等多個(gè)維度來幫助開發(fā)者保障微服務(wù)的穩(wěn)定性。

OpenFeign調(diào)用

我們先看一下，沒有整合Sentinel，OpenFeign調(diào)用異常時(shí)，是怎樣的情況。假定存在兩個(gè)服務(wù)，order和user，然后再order服務(wù)中，通過feign調(diào)用user中的接口。

公共組件中定義接口：

@FeignClient(name = "xdty-user")
public interface UserApi {

    @GetMapping("/getUserInfo")
    ResponseResult getUserInfo();
}

user服務(wù)中實(shí)現(xiàn)接口：

public class UserController implements UserApi {
    @Override
    public ResponseResult getUserInfo() {
        int i = 1/0; //模擬異常
        return new ResponseResult("200","user info");
    }
}

order服務(wù)中調(diào)用user服務(wù)中的接口：

@RestController
public class OrderController implements OrderApi {

    @Autowired
    private UserApi userApi;

    @Override
    public ResponseResult getOrderInfo() {
        return userApi.getUserInfo();
    }
}

利用postman訪問order服務(wù)。

返回接口：

可以看到，這樣的返回值，是非常不友好的，對(duì)于項(xiàng)目而言，不管接口成功與否，都應(yīng)有統(tǒng)一的返回，如：code，message。

OpenFeign整合Sentinel

引入依賴：

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>

啟用OpenFeign整合Sentinel的自動(dòng)配置。熔斷是在consumer端實(shí)現(xiàn)的，所以在consumer端的application.yaml配置文件中添加如下配置。

feign:
  sentinel:
    enabled: true

定義一個(gè)容錯(cuò)的處理類，當(dāng)調(diào)用遠(yuǎn)程接口失敗或超時(shí)時(shí)，會(huì)調(diào)用對(duì)應(yīng)接口的容錯(cuò)邏輯。

public class UserApiFallback implements UserApi {

    @Override
    public ResponseResult getUserInfo() {
        return new ResponseResult("503","用戶服務(wù)異常");
    }
}

@Component
public class UserApiFallbackFactory implements FallbackFactory<UserApi> {
    @Override
    public UserApi create(Throwable cause) {
        return new UserApiFallback();
    }
}

@FeignClient 注解上增加 fallbackFactory屬性。

@FeignClient(name = "xdty-user",fallbackFactory = UserApiFallbackFactory.class)
public interface UserApi {

    @GetMapping("/getUserInfo")
    ResponseResult getUserInfo();
}

再次調(diào)用接口。

可以發(fā)現(xiàn)，服務(wù)異常后，會(huì)進(jìn)行降級(jí)處理，返回統(tǒng)一定義的異常。

全局異常封裝分析

上述代碼，增加了異常處理邏輯，但存在一個(gè)問題，就是每次都要為其設(shè)置fallbackFactory參數(shù)。導(dǎo)致項(xiàng)目中會(huì)多出很多冗余代碼。那我們能不能有一個(gè)自己定制化的默認(rèn)Fallback去處理這些相同的事情呢？

要想解決這個(gè)問題，需要先了解sentinel中fallback的機(jī)制。前面提到，要使用sentinel需要配置文件中指定feign.sentinel.enabled=true?？吹絊entinelFeignAutoConfiguration的代碼實(shí)現(xiàn)，我想大家也就明天這樣配置的原因了。

@ConditionalOnProperty 中 feign.sentinel.enabled 起了決定性作用，這也就是為什么我們需要在配置文件中指定 feign.sentinel.enabled=true。

接下來看 SentinelFeign.builder 里面的實(shí)現(xiàn)：

build方法中重新實(shí)現(xiàn)了super.invocationHandlerFactory方法，也就是動(dòng)態(tài)代理工廠，構(gòu)建的是InvocationHandler對(duì)象。

build中會(huì)獲取Feign Client中的信息，比如fallback,fallbackFactory等，然后創(chuàng)建一個(gè)SentinelInvocationHandler，SentinelInvocationHandler繼承了InvocationHandler。

SentinelInvocationHandler中的invoke方法里面進(jìn)行熔斷限流的處理。

從這段代碼我就可以看出，在沒有配置fallback時(shí)，并沒有向SentinelInvocationHandler構(gòu)造方法中傳入FallbackFactory。這樣的話我們就有了思路：

• 編寫公共FallbackFactory
• 改寫SentinelFeign使得fallbackFactory為void.class時(shí)，我們傳入自己的公共FallbackFactory實(shí)例。

打造自己的sentinel腳手架

接下來，我們沿著sentinel的思路，編寫一個(gè)屬于自己的小小腳手架，實(shí)現(xiàn)統(tǒng)一的兜底方法。

定義全局的fallback處理器。

定義一個(gè)全局的FallbackFactory。

重新實(shí)現(xiàn)spring-cloud-starter-alibaba-sentinel下的SentinelFeign。

注入我們的SentinelFeign Bean。

注：這里使用AutoConfigureBefore注解，要想該注解生效，必須把自定義的配置類變成自動(dòng)配置類。

這樣，以后只要定義基本屬性@FeignClient，不需要再配置fallBackFactory，就可以完成統(tǒng)一的兜底方法了。