Spring Cloud系列之Feign

Spring Cloud系列之Eureka
Spring Cloud系列之配置中心Config
Spring Cloud系列之gateway
Spring Cloud系列之Feign
Spring Cloud系列之Hystrix
Spring Cloud系列之鏈路追蹤

簡介

feign是netfix開發(fā)的一個輕量級的restful的http服務(wù)客戶端，用來發(fā)起請求、遠程調(diào)用。是以java接口注解的方式調(diào)用http請求，而不用像java中通過封裝http請求報文的方式直接調(diào)用。消費者拿到服務(wù)提供者的接口，然后像調(diào)用本地方法一樣去調(diào)用遠程的接口，本質(zhì)上就是feign幫我們?nèi)プ隽朔庋b并且發(fā)起請求。更符合面向接口化的編程邏輯。

  • 可以幫助我們更加便捷優(yōu)雅的調(diào)用http的API，不需要我們?nèi)テ唇觰rl通過restTmplate方式去調(diào)用遠程接口

  • 并且feign支持了springMVC注解

Feign入門

Feign服務(wù)提供者搭建
  • 添加依賴
<dependencies>

    <!-- eureka client依賴 -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

    <!-- configClient依賴 -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-config</artifactId>
    </dependency>


    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <!-- feign依賴 -->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-openfeign</artifactId>
    </dependency>
    <!-- 健康監(jiān)測依賴 -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-actuator</artifactId>
    </dependency>

    <!--鏈路追蹤-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-sleuth</artifactId>
    </dependency>

</dependencies>
  • FeignClient的創(chuàng)建
/**
 * @Description:
 * @author: dy
 * @Date: 2021/11/26
 */
 //@FeignClient表明當(dāng)前類是一個feign客戶端，value指定該客戶端要請求的服務(wù)名稱（登記到注冊中心的服務(wù)提供者名稱）
@FeignClient(value = "user-service",path = UserClient.MAPPING)
public interface UserClient {
    String MAPPING = "/user-service";

    @RequestMapping(value = "/get_user_id", method = RequestMethod.GET)
    public String getUserId();

}

/**
 * @Description:
 * @author: dy
 */
@Slf4j
@RestController
@RequestMapping(UserClient.MAPPING)
public class UserResource implements UserClient {

    @Autowired
    private AppInfo appinfo;

    @Override
    public String getUserId() {
        log.info("==============請求來了===============");
        return "======111111222>>"+appinfo.getAppId();
    }
}
  • 啟動類
/**
 * @Description:
 * @author: dy
 */
@EnableDiscoveryClient //開啟Eureka客戶端發(fā)現(xiàn)功能
@SpringBootApplication
public class UserServiceApplication {

    public static void main(String[] args) {
        SpringApplication.run(UserServiceApplication.class, args);
    }

}
Feign服務(wù)消費者搭建
  • 引入依賴
<dependencies>
    <!--引入user-service依賴-->
    <dependency>
        <groupId>com.dy</groupId>
        <artifactId>user-service</artifactId>
        <version>0.0.1-SNAPSHOT</version>
    </dependency>

    <!--config-client依賴-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-config</artifactId>
    </dependency>

    <!--eureka-client依賴-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>

    <!--鏈路追蹤-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-sleuth</artifactId>
    </dependency>
</dependencies>
  • 啟動類 （開啟feign客戶端功能）
/**
 * @Description:
 * @author: dy
 */
//開啟feign客戶端功能 basePackages指定要掃描的feignClient類所在包路徑
@EnableFeignClients(basePackages = {"com.dy.user.client"})
//開啟Eureka客戶端發(fā)現(xiàn)功能
@EnableDiscoveryClient
@SpringBootApplication
public class UserApiApplication {

    public static void main(String[] args) {
        SpringApplication.run(UserApiApplication.class, args);
    }

}
  • 使用
/**
 * @Description:
 * @author: dy
 * @Date: 2021/11/29
 */
@Slf4j
@RestController
public class UserController implements UserApi {

    @Autowired
    private UserClient userClient;

    @Override
    public String getUserInfo() {
        log.info("==========滴滴========");
        return userClient.getUserId();
    }

}

這樣完成了feign的基本使用，但是我們思考一個問題？如果我們同時啟動了幾個service服務(wù)，那我們的api會調(diào)用哪個service呢？

feign對負載均衡的支持

feign自身已經(jīng)集成了對ribbon依賴和自動配置，因此不需要我們引入額外對ribbon的依賴，可用通過在配置文件里面添加響應(yīng)的配置進行全局的配置或者對某個服務(wù)單獨的負載均衡配置。

feign默認的請求處理超時時長是1s，有時候肯定我們的業(yè)務(wù)處理邏輯是超過1s的，那么這些就需要我們根據(jù)自己的業(yè)務(wù)進行相應(yīng)的配置，以滿足我們對每個服務(wù)的調(diào)用需求

對單個服務(wù)的ribbon配置：

user-service:
  ribbon:
    #請求連接超時時間
    ConnectTimeout: 3000
    #請求處理超時時間
    ReadTimeout: 15000
    #對所有操作都進行重試
    OkToRetryOnAllOperations: true
    #對當(dāng)前選中的實例重試次數(shù)，不包含第一次調(diào)用
    MaxAutoRetries: 0
    #切換實例的重試次數(shù)
    MaxAutoRetriesNextServer: 0
    #負載均衡策略配置
    NFLoadBalancerRuleClassName: com.netfix.loadbalancer.RoundRobinRule

負載均衡邏輯如下：

  • 根據(jù)上面得配置，當(dāng)訪問超時時，系統(tǒng)會再嘗試一次訪問當(dāng)前實例（次數(shù)由MaxAutoRetries配置）

  • 如果不行，就換一個實例進行訪問，如果還不行，再換一個實例訪問（更換次數(shù)由MaxAutoRetriesNextServer這個決定）

  • 如果還不行，就返回失敗結(jié)果

Ribbon默認的負載均衡策略是RoundRobinRule也就是輪詢，當(dāng)然在實際開發(fā)中我們可以根據(jù)我們服務(wù)的響應(yīng)配置進行響應(yīng)的負載均衡策略的自定義

對全局的ribbon配置（就把我們服務(wù)的名字去掉就可以了）：

ribbon:
  #請求連接超時時間
  ConnectTimeout: 3000
  #請求處理超時時間
  ReadTimeout: 15000
  #對所有操作都進行重試
  OkToRetryOnAllOperations: true
  #對當(dāng)前選中的實例重試次數(shù)，不包含第一次調(diào)用
  MaxAutoRetries: 0
  #切換實例的重試次數(shù)
  MaxAutoRetriesNextServer: 0
  #負載均衡策略配置
  NFLoadBalancerRuleClassName: com.netflix.loadbalancer.RoundRobinRule

Feign的日志級別配置

Feign是http請求的客戶端，類似于瀏覽器，在請求和接受響應(yīng)的時候，可以打印出比較詳細的一些信息，比如：響應(yīng)頭、狀態(tài)碼等等

如果我們想看到Feign請求時的日志，我們可以進行一些配置，默認情況下Feign的日志是沒有開啟的。

  • 在api module配置如下
/**
 * @Description:
 * @author: dy
 */
@Configuration
public class FeignConfig {

    /**
     *
     * @return
     */
    @Bean
    Logger.Level feignLevel(){
        return Logger.Level.FULL;
    }

}

LEVEL說明：

  • NONE 不顯示任何日志

  • BASIC 僅記錄請求方法、URL、響應(yīng)狀態(tài)碼、執(zhí)行時間 ，適用于生產(chǎn)環(huán)境

  • HEADERS 在BASIC的基礎(chǔ)上記錄請求響應(yīng)的header

  • FULL 記錄請求響應(yīng)的header、body、元數(shù)據(jù) 適用于開發(fā)及測試環(huán)境

注意配置log日志級別：

logging:
  level:
    com.dy.user: debug

運行結(jié)果如下：

Feign日志結(jié)果輸出.png

Feign對熔斷器的支持

  • 在feign客戶端配置文件添加配置開啟對熔斷的支持
#開啟對hystrix的支持
feign:
  hystrix:
    enabled: true

上面我們設(shè)置了feign的超時時長設(shè)置實際上是對Ribbon的超時時長設(shè)置，但是如果開啟了對hystrix的支持，hystrix還有超時時長設(shè)置，如下

hystrix:
  command:
    default:
      execution:
        isolation:
          thread:
            #hystrix超時時長設(shè)置
            timeoutInMilliseconds: 5000

開啟對hystrix支持后，F(xiàn)eginclient中的方法就會被進行一個管理了，一旦出現(xiàn)問題就會進行默認處理也就是fallback類的方法中的處理

注意：針對超時這塊，這里有兩個超時時間：一個是ribbon的超時時間，一個是hystrix的超時時間，熔斷的時間就是根據(jù)兩個時間中最小的超時時間來進行的，及最短超時時間

  • clent類
/**
 * @Description:
 * @author: dy
 */
//@FeignClient表明當(dāng)前類是一個feign客戶端，value指定該客戶端要請求的服務(wù)名稱（登記到注冊中心的服務(wù)提供者名稱） fallback指定回退類
@FeignClient(value = "user-service",path = UserClient.MAPPING ,fallback = UserFallback.class)
public interface UserClient {
    String MAPPING = "/user-service";

    @RequestMapping(value = "/get_user_id", method = RequestMethod.GET)
    public String getUserId();

}
  • 新建fallback方法
/**
 * @Description:  降級回退邏輯定義一個類，實現(xiàn)Feign接口，實現(xiàn)其中的接口方法，返回默認值
 * @author: dy
 */
@Component
public class UserFallback implements UserClient {
    @Override
    public String getUserId() {
        return "-1";
    }
}

Feign對請求響應(yīng)壓縮的支持

feign支持對請求和響應(yīng)進行GZIP壓縮，以減少通信過程中的性能損耗，這里我們就不進行過多介紹了。

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成，瀏覽時請結(jié)合常識與多方信息審慎甄別。
平臺聲明：文章內(nèi)容（如有圖片或視頻亦包括在內(nèi)）由作者上傳并發(fā)布，文章內(nèi)容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容