OpenFeign整合Sentinel，由淺入深，搭建屬于自己的腳手架

作者：云端行筆 2023-11-21 17:36:04

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

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

Sentinel是什么

OpenFeign調(diào)用

我們先看一下，沒(méi)有整合Sentinel，OpenFeign調(diào)用異常時(shí)，是怎樣的情況。假定存在兩個(gè)服務(wù)，order和user，然后再order服務(wù)中，通過(guò)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訪問(wèn)order服務(wù)。

返回接口：

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

OpenFeign整合Sentinel

引入依賴(lài)：

<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ò)的處理類(lèi)，當(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","用戶(hù)服務(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è)問(wèn)題，就是每次都要為其設(shè)置fallbackFactory參數(shù)。導(dǎo)致項(xiàng)目中會(huì)多出很多冗余代碼。那我們能不能有一個(gè)自己定制化的默認(rèn)Fallback去處理這些相同的事情呢？

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