摘要:服務(wù)雪崩效應(yīng)是一種因服務(wù)提供者的不可用導(dǎo)致服務(wù)消費(fèi)者的不可用并將不可用逐漸放大的過程。這種代理能夠記錄最近調(diào)用發(fā)生錯誤的次數(shù),然后決定使用允許操作繼續(xù),或者立即返回錯誤。這個自己持有的上下文默認(rèn)實(shí)現(xiàn)類也是。
?????本篇集成Hystrix,繼續(xù)搭建demo。
雪崩效應(yīng):
在微服務(wù)架構(gòu)中通常會有多個服務(wù)層調(diào)用,基礎(chǔ)服務(wù)的故障可能會導(dǎo)致級聯(lián)故障,進(jìn)而造成整個系統(tǒng)不可用的情況,這種現(xiàn)象被稱為服務(wù)雪崩效應(yīng)。服務(wù)雪崩效應(yīng)是一種因“服務(wù)提供者”的不可用導(dǎo)致“服務(wù)消費(fèi)者”的不可用,并將不可用逐漸放大的過程。
如果下圖所示:A作為服務(wù)提供者,B為A的服務(wù)消費(fèi)者,C和D是B的服務(wù)消費(fèi)者。A不可用引起了B的不可用,并將不可用像滾雪球一樣放大到C和D時(shí),雪崩效應(yīng)就形成了。
熔斷器:
熔斷器的原理很簡單,如同電力過載保護(hù)器。它可以實(shí)現(xiàn)快速失敗,如果它在一段時(shí)間內(nèi)偵測到許多類似的錯誤,會強(qiáng)迫其以后的多個調(diào)用快速失敗,不再訪問遠(yuǎn)程服務(wù)器,從而防止應(yīng)用程序不斷地嘗試執(zhí)行可能會失敗的操作,使得應(yīng)用程序繼續(xù)執(zhí)行而不用等待修正錯誤,或者浪費(fèi)CPU時(shí)間去等到長時(shí)間的超時(shí)產(chǎn)生。熔斷器也可以使應(yīng)用程序能夠診斷錯誤是否已經(jīng)修正,如果已經(jīng)修正,應(yīng)用程序會再次嘗試調(diào)用操作。
熔斷器模式就像是那些容易導(dǎo)致錯誤的操作的一種代理。這種代理能夠記錄最近調(diào)用發(fā)生錯誤的次數(shù),然后決定使用允許操作繼續(xù),或者立即返回錯誤。
熔斷器開關(guān)相互轉(zhuǎn)換的邏輯如下圖:
Hystrix熔斷器:
1.斷路器機(jī)制
斷路器很好理解, 當(dāng)Hystrix Command請求后端服務(wù)失敗數(shù)量超過一定比例(默認(rèn)50%), 斷路器會切換到開路狀態(tài)(Open). 這時(shí)所有請求會直接失敗而不會發(fā)送到后端服務(wù). 斷路器保持在開路狀態(tài)一段時(shí)間后(默認(rèn)5秒), 自動切換到半開路狀態(tài)(HALF-OPEN). 這時(shí)會判斷下一次請求的返回情況, 如果請求成功, 斷路器切回閉路狀態(tài)(CLOSED), 否則重新切換到開路狀態(tài)(OPEN). Hystrix的斷路器就像我們家庭電路中的保險(xiǎn)絲, 一旦后端服務(wù)不可用, 斷路器會直接切斷請求鏈, 避免發(fā)送大量無效請求影響系統(tǒng)吞吐量, 并且斷路器有自我檢測并恢復(fù)的能力.
2.Fallback
Fallback相當(dāng)于是降級操作. 對于查詢操作, 我們可以實(shí)現(xiàn)一個fallback方法, 當(dāng)請求后端服務(wù)出現(xiàn)異常的時(shí)候, 可以使用fallback方法返回的值. fallback方法的返回值一般是設(shè)置的默認(rèn)值或者來自緩存.
3.資源隔離
在Hystrix中, 主要通過線程池來實(shí)現(xiàn)資源隔離. 通常在使用的時(shí)候我們會根據(jù)調(diào)用的遠(yuǎn)程服務(wù)劃分出多個線程池. 例如調(diào)用產(chǎn)品服務(wù)的Command放入A線程池, 調(diào)用賬戶服務(wù)的Command放入B線程池. 這樣做的主要優(yōu)點(diǎn)是運(yùn)行環(huán)境被隔離開了. 這樣就算調(diào)用服務(wù)的代碼存在bug或者由于其他原因?qū)е伦约核诰€程池被耗盡時(shí), 不會對系統(tǒng)的其他服務(wù)造成影響. 但是帶來的代價(jià)就是維護(hù)多個線程池會對系統(tǒng)帶來額外的性能開銷. 如果是對性能有嚴(yán)格要求而且確信自己調(diào)用服務(wù)的客戶端代碼不會出問題的話, 可以使用Hystrix的信號模式(Semaphores)來隔離資源.
我們在movie微服務(wù)中使用Hystirx,新建文件如下目錄
在controller中,可以直接使用Hystrix注解,并且自定義fallback函數(shù),當(dāng)請求后端服務(wù)出現(xiàn)異常的時(shí)候, 可以使用fallback方法返回的值.
@GetMapping("/movie/{id}") @HystrixCommand(fallbackMethod = "fallbackMovie",commandProperties = @HystrixProperty(name = "execution.isolation.strategy",value = "semaphore")) public User findmovie(@PathVariable int id){ return userFeignClient.find(id); } public User fallbackMovie(int id){ User user=new User(); user.setId(10); return user; }
其中commandProperties = @HystrixProperty(name = "execution.isolation.strategy",value = "semaphore")的value Hystrix默認(rèn)為thread,
默認(rèn)使用線程池里隔離的線程,要想切換到調(diào)用者相同線程使用Spring Security的context,就要設(shè)置隔離策略為semaphore。
?????關(guān)于Spring父子容器context:
1.??首先,對于一個web應(yīng)用,其部署在web容器中,web容器提供其一個全局的上下文環(huán)境,這個上下文就是ServletContext,其為后面的spring IoC容器提供宿主環(huán)境;
2.??其次,在web.xml中會提供有contextLoaderListener。在web容器啟動時(shí),會觸發(fā)容器初始化事件,此時(shí)contextLoaderListener會監(jiān)聽到這個事件,其contextInitialized方法會被調(diào)用,在這個方法中,spring會初始化一個啟動上下文,這個上下文被稱為根上下文,即WebApplicationContext,這是一個接口類,確切的說,其實(shí)際的實(shí)現(xiàn)類是XmlWebApplicationContext。這個就是spring的IoC容器,其對應(yīng)的Bean定義的配置由web.xml中的context-param標(biāo)簽指定。在這個IoC容器初始化完畢后,spring以WebApplicationContext.ROOTWEBAPPLICATIONCONTEXTATTRIBUTE為屬性Key,將其存儲到ServletContext中,便于獲?。?/p>
3.??再次,contextLoaderListener監(jiān)聽器初始化完畢后,開始初始化web.xml中配置的Servlet,這個servlet可以配置多個,以最常見的DispatcherServlet為例,這個servlet實(shí)際上是一個標(biāo)準(zhǔn)的前端控制器,用以轉(zhuǎn)發(fā)、匹配、處理每個servlet請求。DispatcherServlet上下文在初始化的時(shí)候會建立自己的IoC上下文,用以持有spring mvc相關(guān)的bean。在建立DispatcherServlet自己的IoC上下文時(shí),會利用WebApplicationContext.ROOTWEBAPPLICATIONCONTEXTATTRIBUTE先從ServletContext中獲取之前的根上下文(即WebApplicationContext)作為自己上下文的parent上下文。有了這個parent上下文之后,再初始化自己持有的上下文。這個DispatcherServlet初始化自己上下文的工作在其initStrategies方法中可以看到,大概的工作就是初始化處理器映射、視圖解析等。這個servlet自己持有的上下文默認(rèn)實(shí)現(xiàn)類也是mlWebApplicationContext。初始化完畢后,spring以與servlet的名字相關(guān)(此處不是簡單的以servlet名為Key,而是通過一些轉(zhuǎn)換,具體可自行查看源碼)的屬性為屬性Key,也將其存到ServletContext中,以便后續(xù)使用。這樣每個servlet就持有自己的上下文,即擁有自己獨(dú)立的bean空間,同時(shí)各個servlet共享相同的bean,即根上下文(第2步中初始化的上下文)定義的那些bean。
feign中使用Hystrix:
feign客戶端
@FeignClient(name="userprovider",configuration = FeignClient.class,fallback = HystrixFallbackClient.class) public interface UserFeignClient { @RequestMapping (value = "/user/{id}",method = RequestMethod.GET) public User find(@PathVariable("id") int id); }
fallback的類HystrixFallbackClient實(shí)現(xiàn)fallback方法
@Component public class HystrixFallbackClient implements UserFeignClient { @Override public User find(int id) { User user=new User(); user.setId(1); return user; } }
若想禁用某個feignClient的Hystrix可以更改feignClient的config,在里面返回feign.bulider,默認(rèn)為Hystrix的
FeignConfig:
@Configuration public class FeignConfig { @Bean public Contract feignContract(){ return new feign.Contract.Default(); } @Bean @Scope("prototype") public Feign.Builder feignBuilder(){ return Feign.builder(); } }
如果需要訪問回退觸發(fā)的原因,Hystrix也提供fallbackfactory :
改寫UserFeignClient的屬性:
@FeignClient(name="userprovider",configuration = FeignClient.class,fallbackFactory = HystrixFallbackFactory.class) public interface UserFeignClient { @RequestMapping (value = "/user/{id}",method = RequestMethod.GET) public User find(@PathVariable("id") int id); }
創(chuàng)建HystrixFallbackFactory,和一個繼承UserFeignClient的接口
HystrixUserFeignClientWithFactory:
public interface HystrixUserFeignClientWithFactory extends UserFeignClient { }
HystrixFallbackFactory:
@Component public class HystrixFallbackFactory implements FallbackFactory{ private static final Logger logger= LoggerFactory.getLogger(HystrixFallbackFactory.class); @Override public UserFeignClient create(Throwable throwable) { this.logger.info("異常原因?yàn)閧}",throwable.getMessage()); return new HystrixUserFeignClientWithFactory() { @Override public User find(int id) { User user=new User(); user.setId(0); return user; } }; } }
hystrix實(shí)時(shí)監(jiān)控可視化可以使用dashboard
eureka的pom添加
`
org.springframework.cloud spring-cloud-starter-hystrix-dashboard
`
并給application添加注解@EnableHystrixDashboard,啟動eureka,movie微服務(wù)(記得改UserFeignClient的fallback為fallbackfactory,刪除fallback屬性以及UserFeignClient實(shí)現(xiàn)類,不然報(bào)錯)訪問hystrix
先使用movie微服務(wù),hystrix才能打印日志記錄,訪問http://localhost:8088/hystrix...
然后在http://localhost:8761/hystrix,輸入http://localhost:8088/hystrix...地址,成功監(jiān)控
文章版權(quán)歸作者所有,未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為,您可以聯(lián)系管理員刪除。
轉(zhuǎn)載請注明本文地址:http://m.hztianpu.com/yun/67701.html
摘要:本系列網(wǎng)絡(luò)資料資料來源于網(wǎng)絡(luò),相關(guān)學(xué)習(xí)微服務(wù)與微服務(wù)架構(gòu)定義理解單一應(yīng)用程序劃分為一組小的服務(wù),每個服務(wù)有自己的進(jìn)程。 本系列(java-study-springcloud-網(wǎng)絡(luò)資料)資料來源于網(wǎng)絡(luò),springcloud相關(guān)學(xué)習(xí) 1、微服務(wù)與微服務(wù)架構(gòu) 定義:https://martinfowler.com/arti... showImg(https://segmentfault.c...
摘要:實(shí)現(xiàn)配置和注冊中心最近,阿里開源的比較火,可以和和共用,對升級到非常的方便。只需要添加依賴,使用配置注冊中心地址即可。配置不生效,沒有使用注解刷新配置分清注冊中心和配置中心是兩個概念,需要配置兩個地址學(xué)會看源碼,看維基。 Springcloud-nacos實(shí)現(xiàn)配置和注冊中心 最近,阿里開源的nacos比較火,可以和springcloud和dubbo共用,對dubbo升級到springc...
摘要:調(diào)用百度實(shí)現(xiàn)圖像識別使用渲染導(dǎo)出的制作的超級炫酷的三維模型一個代碼庫本人本人瀏覽器調(diào)試及所有錯誤代碼整合千峰超級好用的各種開發(fā)自學(xué)文檔這是它對應(yīng)的學(xué)習(xí)視頻使用教程詳細(xì)虛擬機(jī)安裝系統(tǒng)詳解版網(wǎng)易開源鏡像站在線數(shù)據(jù)互轉(zhuǎn)使 1.Java調(diào)用百度API實(shí)現(xiàn)圖像識別 2.使用Three.js渲染Sketchup導(dǎo)出的dae 3.three.js制作的超級炫酷的三維模型 4.three.js - 一...
摘要:調(diào)用百度實(shí)現(xiàn)圖像識別使用渲染導(dǎo)出的制作的超級炫酷的三維模型一個代碼庫本人本人瀏覽器調(diào)試及所有錯誤代碼整合千峰超級好用的各種開發(fā)自學(xué)文檔這是它對應(yīng)的學(xué)習(xí)視頻使用教程詳細(xì)虛擬機(jī)安裝系統(tǒng)詳解版網(wǎng)易開源鏡像站在線數(shù)據(jù)互轉(zhuǎn)使 1.Java調(diào)用百度API實(shí)現(xiàn)圖像識別 2.使用Three.js渲染Sketchup導(dǎo)出的dae 3.three.js制作的超級炫酷的三維模型 4.three.js - 一...
閱讀 2809·2021-09-26 10:19
閱讀 2207·2021-09-24 10:27
閱讀 2597·2021-09-01 10:42
閱讀 2370·2019-08-29 16:09
閱讀 2556·2019-08-29 15:17
閱讀 1508·2019-08-29 15:09
閱讀 694·2019-08-29 11:14
閱讀 2384·2019-08-26 13:25