hystrix服務(wù)降級(jí)方法使用介紹
當(dāng)一個(gè)服務(wù)端的業(yè)務(wù)響應(yīng)的時(shí)間過(guò)長(zhǎng)的時(shí)候或者業(yè)務(wù)處理邏輯處理異常,不應(yīng)該等待,應(yīng)該給出一種處理方法
超時(shí)導(dǎo)致服務(wù)器變慢(轉(zhuǎn)圈) --->超時(shí)不再等待
出錯(cuò)(宕機(jī)或程序運(yùn)行出錯(cuò)) --->出錯(cuò)要有兜底
pom文件依賴(lài) :
<!--hystrix--> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-hystrix</artifactId> </dependency>
主啟動(dòng)類(lèi)需要加注解:
@EnableHystrix
yml文件設(shè)置:
feign:
hystrix:
enabled: true
feign:hystrix:enabled: true的作用,官網(wǎng)解釋“Feign將使用斷路器包裝所有方法”,也就是將@FeignClient標(biāo)記的那個(gè)service接口下所有的方法進(jìn)行了hystrix包裝(類(lèi)似于在這些方法上加了一個(gè)@HystrixCommand),這些方法會(huì)應(yīng)用一個(gè)默認(rèn)的超時(shí)時(shí)間為1s
情況1
/** * 超時(shí)訪(fǎng)問(wèn),演示降級(jí) * @param id * @return */ @HystrixCommand(fallbackMethod = "paymentInfo_TimeOutHandler",commandProperties = { @HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",value="3000") }) public String paymentInfo_TimeOut(Integer id) { int second = 5; try { TimeUnit.SECONDS.sleep(second); } catch (InterruptedException e) { e.printStackTrace(); } return "線(xiàn)程池:"+Thread.currentThread().getName()+"paymentInfo_TimeOut,id: "+id+"\t"+"O(∩_∩)O,耗費(fèi)秒: "+second; } public String paymentInfo_TimeOutHandler(Integer id){ return "/(ㄒoㄒ)/調(diào)用支付接口超時(shí)或異常:\t"+ "\t當(dāng)前線(xiàn)程池名字" + Thread.currentThread().getName(); }
@HystrixCommand(fallbackMethod = "paymentInfo_TimeOutHandler",
commandProperties ={@HystrixProperty(name="execution.isolation.thread.timeoutInMilliseconds",
value="3000")
})
@HystrixCommand:需要進(jìn)行降級(jí)處理的業(yè)務(wù)處理方法的標(biāo)注注解
fallbackMethod :發(fā)生時(shí)間過(guò)長(zhǎng)的時(shí)候或運(yùn)行錯(cuò)誤的時(shí)候需要調(diào)用的方法
@HystrixProperty:相關(guān)參數(shù)設(shè)置,如上就是設(shè)置超時(shí)時(shí)間,超過(guò)了3s就調(diào)用方法
情況2:每個(gè)業(yè)務(wù)方法對(duì)應(yīng)一個(gè)兜底的方法,代碼膨脹,統(tǒng)一和自定義的分開(kāi)
@RestController @Slf4j @DefaultProperties(defaultFallback = "payment_Global_FallbackMethod") public class PaymentHystirxController { @GetMapping("/consumer/payment/hystrix/timeout/{id}") @HystrixCommand //加了@DefaultProperties屬性注解,并且沒(méi)有寫(xiě)具體方法名字,就用統(tǒng)一全局的 public String paymentInfo_TimeOut(@PathVariable("id") Integer id) { String result = paymentHystrixService.paymentInfo_TimeOut(id); return result; } public String paymentTimeOutFallbackMethod(@PathVariable("id") Integer id) { return "paymentTimeOutFallbackMethod,對(duì)方系統(tǒng)繁忙,請(qǐng)10秒鐘后再次嘗試/(ㄒoㄒ)/"; } public String payment_Global_FallbackMethod() { return "Global異常處理信息,請(qǐng)稍后再試,/(ㄒoㄒ)/~~"; } }
@DefaultProperties(defaultFallback = "payment_Global_FallbackMethod")
defaultFallback :指定默認(rèn)改控制類(lèi)的所有標(biāo)注了@HystrixCommand的控制方法降級(jí)處理都是名字為payment_Global_FallbackMethod
如果需要針對(duì)處理的,可以添加fallbackMethod 參數(shù)和情況1一樣處理掉
情況3:和業(yè)務(wù)邏輯混一起???混亂
說(shuō)明:當(dāng)引發(fā)降級(jí)處理的時(shí)候,也可能是因?yàn)榉?wù)內(nèi)部程序發(fā)生了錯(cuò)誤或調(diào)用的服務(wù)宕機(jī),這個(gè)時(shí)候就需要給客戶(hù)處理的不再是“業(yè)務(wù)繁忙”而是“內(nèi)部程序錯(cuò)誤”
案列:現(xiàn)在有80服務(wù)調(diào)用8001端口的業(yè)務(wù),但8001端口的服務(wù)突然出現(xiàn)宕機(jī);80端口使用feign處理8001端口的調(diào)用
@Component @FeignClient(value = "CLOUD-PROVIDER-HYSTRIX-PAYMENT", fallback = PaymentFallbackService.class) public interface PaymentHystrixService { @GetMapping("/payment/hystrix/ok/{id}") String paymentInfo_OK(@PathVariable("id") Integer id); @GetMapping("/payment/hystrix/timeout/{id}") String paymentInfo_TimeOut(@PathVariable("id") Integer id); }
@FeignClient(value = "CLOUD-PROVIDER-HYSTRIX-PAYMENT",
fallback = PaymentFallbackService.class)
value:是8001端口的服務(wù)名稱(chēng)
fallback :是該接口的實(shí)現(xiàn)類(lèi),也就是在80端口調(diào)用8001端口服務(wù)發(fā)生錯(cuò)誤的時(shí)候需要進(jìn)行的方法
@Component //必須加 //必須加 //必須加 public class PaymentFallbackService implements PaymentHystrixService { @Override public String paymentInfo_OK(Integer id) { return "服務(wù)調(diào)用失敗,提示來(lái)自:cloud-consumer-feign-order80"; } @Override public String paymentInfo_TimeOut(Integer id) { return "服務(wù)調(diào)用失敗,提示來(lái)自:cloud-consumer-feign-order80"; } }
補(bǔ)充 :
說(shuō)明:現(xiàn)在有80端口控制類(lèi)調(diào)用了8001端口業(yè)務(wù)處理類(lèi),但在8001端口這個(gè)服務(wù)也設(shè)置了服務(wù)降級(jí),假設(shè)為5s超時(shí)處理,而80這邊設(shè)置的服務(wù)降級(jí)為3s超時(shí)處理,現(xiàn)在業(yè)務(wù)響如果超過(guò)了3s,那么應(yīng)該響應(yīng)的是80端口這邊的服務(wù)降級(jí)處理
到此這篇關(guān)于hystrix服務(wù)降級(jí)方法使用介紹的文章就介紹到這了,更多相關(guān)hystrix服務(wù)降級(jí)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
mybatis如何設(shè)置useGeneratedKeys=true
這篇文章主要介紹了mybatis如何設(shè)置useGeneratedKeys=true,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。2022-01-01Spring Boot整合QueryDSL的實(shí)現(xiàn)示例
這篇文章主要介紹了Spring Boot整合QueryDSL的實(shí)現(xiàn)示例,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2020-09-09Java如果在try里面執(zhí)行return還會(huì)不會(huì)執(zhí)行finally
這篇文章主要介紹了Java如果在try里面執(zhí)行return,那么還會(huì)不會(huì)執(zhí)行finally,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-01-01