快捷導(dǎo)航

SpringCloud Feign隔離與降級詳細分析

更新時間：2022年11月04日 09:42:12 作者：借東西的小人兒

Feign是Netflix公司開發(fā)的一個聲明式的REST調(diào)用客戶端; Ribbon負載均衡、 Hystrⅸ服務(wù)熔斷是我們Spring Cloud中進行微服務(wù)開發(fā)非?；A(chǔ)的組件,在使用的過程中我們也發(fā)現(xiàn)它們一般都是同時出現(xiàn)的,而且配置也都非常相似

序篇

限流是一種預(yù)防措施，雖然限流可以盡量避免因高并發(fā)而引起的服務(wù)故障，但服務(wù)還會因為其它原因而故障。

而要將這些故障控制在一定范圍，避免雪崩，就要靠線程隔離（艙壁模式）和熔斷降級手段了。

線程隔離：調(diào)用者在調(diào)用服務(wù)提供者時，給每個調(diào)用的請求分配獨立線程池，出現(xiàn)故障時，最多消耗這個線程池內(nèi)資源，避免把調(diào)用者的所有資源耗盡。

熔斷降級：是在調(diào)用方這邊加入斷路器，統(tǒng)計對服務(wù)提供者的調(diào)用，如果調(diào)用的失敗比例過高，則熔斷該業(yè)務(wù)，不允許訪問該服務(wù)的提供者了。

可以看到，不管是線程隔離還是熔斷降級，都是對客戶端（調(diào)用方）的保護。需要在調(diào)用方發(fā)起遠程調(diào)用時做線程隔離、或者服務(wù)熔斷。

而我們的微服務(wù)遠程調(diào)用都是基于Feign來完成的，因此我們需要將Feign與Sentinel整合，在Feign里面實現(xiàn)線程隔離和服務(wù)熔斷。

FeignClient整合Sentinel

SpringCloud中，微服務(wù)調(diào)用都是通過Feign來實現(xiàn)的，因此做客戶端保護必須整合Feign和Sentinel。

1.1 修改配置，開啟sentinel功能

修改OrderService的application.yml文件，開啟Feign的Sentinel功能：

feign:
sentinel:
enabled: true # 開啟feign對sentinel的支持

1.2 編寫失敗降級邏輯

業(yè)務(wù)失敗后，不能直接報錯，而應(yīng)該返回用戶一個友好提示或者默認結(jié)果，這個就是失敗降級邏輯。

給FeignClient編寫失敗后的降級邏輯

①方式一：FallbackClass，無法對遠程調(diào)用的異常做處理

②方式二：FallbackFactory，可以對遠程調(diào)用的異常做處理，我們選擇這種

這里我們演示方式二的失敗降級處理。

步驟一：在feing-api項目中定義類，實現(xiàn)FallbackFactory：

代碼：

import cn.itcast.feign.clients.UserClient;
import cn.itcast.feign.pojo.User;
import feign.hystrix.FallbackFactory;
import lombok.extern.slf4j.Slf4j;
@Slf4j
public class UserClientFallbackFactory implements FallbackFactory<UserClient> {
    @Override
    public UserClient create(Throwable throwable) {
        return new UserClient() {
            @Override
            public User findById(Long id) {
                log.error("查詢用戶異常", throwable);
                return new User();
            }
        };
    }
}

步驟二：在feing-api項目中的DefaultFeignConfiguration類中將UserClientFallbackFactory注冊為一個Bean：

@Bean
public UserClientFallbackFactory userClientFallbackFactory(){
    return new UserClientFallbackFactory();
}

步驟三：在feing-api項目中的UserClient接口中使用UserClientFallbackFactory：

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
@FeignClient(value = "userservice", fallbackFactory = UserClientFallbackFactory.class)
public interface UserClient {
    @GetMapping("/user/{id}")
    User findById(@PathVariable("id") Long id);
}

重啟后，訪問一次訂單查詢業(yè)務(wù)，然后查看sentinel控制臺，可以看到新的簇點鏈路：