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();
}