1. 程式人生 > 實用技巧 >8、SpringCloud 之宣告式服務消費Feign

8、SpringCloud 之宣告式服務消費Feign

Feign 是什麼

Feign是Netflix公司開發的一個宣告式的REST呼叫客戶端;

Ribbon負載均衡、Hystrix服務熔斷是我們Spring Cloud中進行微服務開發非常基礎的元件,在使用的過程中我們也發現它們一般都是同時出現,而且配置很相似,每次開發都有很多相同的程式碼,因此Spring Cloud基於Netflix Feign整合了Ribbon和Hystrix兩個元件,讓我們的開發工作變得更加簡單, 就像Spring Boot是對 SpringFramework+SpringMVC的簡化一樣,Spring Cloud Feign 對 Ribbon 負載均衡、Hystrix 服務熔斷進行簡化,在其基礎上進行了進一步的封裝,不僅在配置上大大簡化了開發工作,同時還提供了一種宣告式的Web服務客戶端定義方式;

使用 Feign 實現消費者

使用Feign實現消費者,我們通過下面步驟進行:

第一步:建立Spring Boot工程

第二步:新增依賴

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-feign -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-feign</artifactId>
    <version>1.4.7.RELEASE</version>
</dependency>

第三步:添加註解

在專案入口類上新增@EnableFeignClients註解表示開啟Spring Cloud Feign的支援功能;

@EnableFeignClients
@SpringBootApplication
public class Application {

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

}

第四步:宣告服務
定義一個HelloService介面,通過@FeignClient註解來指定服務名稱,進而繫結服務,然後再通過SpringMVC中提供的註解來繫結服務提供者提供的介面,如下

//服務名稱是配置服務提供者的配置spring.application.name的名稱
@FeignClient("01-springcloud-service-provider")
public interface HelloService {

    /**
     * 宣告一個方法,這個方法就是遠端的服務提供者的方法
     * @return
     */
    @RequestMapping("/service/hello")
    public String hello();
}

這相當於綁定了一個名叫 01-springcloud-service-provider 的服務提供者提供的/service/hello介面;

@RequestMapping("/service/hello")
public String hello(){
    return "hello spring clound provider 1";
}

第五步:使用Controller中呼叫服務
建立Controller來呼叫上面的服務,如下:

@RestController
public class FeignController {
    @Autowired
    HelloService helloService;

    @RequestMapping("/web/hello")
    public String hello(){
        return helloService.hello();
    }
}

第六步:屬性配置

#訪問埠
server.port=8083
#服務名稱
spring.application.name=05-springcloud-service-feign
#eureka註冊中心地址
eureka.client.service-url.defaultZone=http://eureka8761:8761/eureka,http://eureka8762:8762/eureka

第七步:測試
依次啟動註冊中心、服務提供者和feign實現服務消費者,然後訪問:http://localhost:8083/web/hello

使用 Feign 實現消費者的測試

負載均衡

Spring Cloud 提供了Ribbon來實現負載均衡,使用Ribbo直接注入一個RestTemplate物件即可RestTemplate已經做好了負載均衡的配置;

在Spring Cloud下,使用Feign也是直接可以實現負載均衡的,定義一個註解有@FeignClient 註解的介面,然後使用@RequestMapping 註解到方法上對映遠端的REST服務,此方法也是做好負責均衡配置的。

服務熔斷

第一步、在application.properties檔案開啟hystrix功能

#開啟服務熔斷
feign.hystrix.enabled=true 

第二步、指定熔斷回撥邏輯

(1)常見一個類用於編寫回調方法

@Component
public class MyFallback implements HelloService{
    /**
     * 覆蓋HelloService介面,重寫hello方法
     * @return
     */
    @Override
    public String hello() {
        return "遠端呼叫服務失敗,呼叫熔斷降級方法";
    }
}

(2)介面類新增fallback屬性指定回撥邏輯

/**
 * 服務名稱是配置服務提供者的配置spring.application.name的名稱
 * 當遠端呼叫服務失敗時,會呼叫fallback屬性指定的類的同名方法為回撥方法
 */
@FeignClient(name = "01-springcloud-service-provider", fallback = MyFallback.class)
public interface HelloService {

    /**
     * 宣告一個方法,這個方法就是遠端的服務提供者的方法
     * @return
     */
    @RequestMapping("/service/hello")
    public String hello();
}

3、服務熔斷獲取異常資訊

為@FeignClient修飾的介面加上fallback方法可以實現遠端服務發生異常後進行服務的熔斷,但是不能獲取到遠端服務的異常資訊,如果要獲取遠端服務的異常資訊,此時可以使用fallbackFactory:

/**
 * 實現FallbackFactory介面,泛型為遠端呼叫方法的介面
 */
@Component
public class MyFallbackFactory implements FallbackFactory<HelloService>{
    //重寫creat方法,由於返回值是泛型,所以需要返回介面物件
    @Override
    public HelloService create(Throwable throwable) {
        return new HelloService() {
            @Override
            public String hello() {
                return throwable.getMessage();
            }
        };
    }
}
/**
 * 服務名稱是配置服務提供者的配置spring.application.name的名稱
 */
@FeignClient(name = "01-springcloud-service-provider", fallbackFactory= MyFallbackFactory.class /**fallback = MyFallback.class*/)
public interface HelloService {

    /**
     * 宣告一個方法,這個方法就是遠端的服務提供者的方法
     * @return
     */
    @RequestMapping("/service/hello")
    public String hello();
}