Springcloud開發微服務時,基於Feign來做聲明式服務接口,當啟用Hystrix服務熔斷降級時,項目微服務眾多,
每個Feign服務接口都得寫一些重復性的服務降級處理代碼,勢必顯得枯燥無味:
Feign服務接口:
@FeignClient(name="springcloud-nacos-producer", qualifier="productApiService", contextId="productApiService",
fallback=ProductFallbackApiService.class) public interface ProductApiService { /** * 創建商品 * @param product */ @PostMapping(value="/api/product/add", produces=APPLICATION_JSON, consumes=APPLICATION_JSON) public Result<Long> createProduct(@RequestBody Product product); /** * 修改商品 * @param product */ @PutMapping(value="/api/product/update", produces=APPLICATION_JSON, consumes=APPLICATION_JSON) public Result<Object> updateProduct(@RequestBody Product product); /** * 刪除商品 * @param productId */ @DeleteMapping(value="/api/product/delete/{productId}", produces=APPLICATION_JSON) public Result<Object> deleteProductById(@PathVariable("productId") Long productId); /** * 根據productId獲取商品信息 * @param productId * @return */ @GetMapping(value="/api/product/{productId}", produces=APPLICATION_JSON) public Result<Product> getProductById(@PathVariable("productId") Long productId); /** * 根據條件查詢商品列表(分頁、排序) * @param condition * @param page * @param sort * @return */ @GetMapping(value="/api/product/list1", produces=APPLICATION_JSON) public PageResult<List<Product>> getProductListByPage(@RequestParam Product condition, @RequestParam Page page, @RequestParam Sort sort); }
對應的熔斷降級處理類:
@Component public class ProductFallbackApiService implements ProductApiService { private static final HttpStatus SERVICE_UNAVAILABLE = HttpStatus.SERVICE_UNAVAILABLE; protected <T> Result<T> defaultFallbackResult() { return Result.failure().code(String.valueOf(SERVICE_UNAVAILABLE.value())).message(
String.format("請求失敗:%s, %s", SERVICE_UNAVAILABLE.value(), SERVICE_UNAVAILABLE.getReasonPhrase())).build(); } protected <T> PageResult<T> defaultFallbackPageResult() { return PageResult.failure().code(String.valueOf(SERVICE_UNAVAILABLE.value())).message(
String.format("請求失敗:%s, %s", SERVICE_UNAVAILABLE.value(), SERVICE_UNAVAILABLE.getReasonPhrase())).build(); } @Override public Result<Long> createProduct(Product product) { return defaultFallbackResult(); } @Override public Result<Object> updateProduct(Product product) { return defaultFallbackResult(); } @Override public Result<Object> deleteProductById(Long productId) { return defaultFallbackResult(); } @Override public Result<Product> getProductById(Long productId) { return defaultFallbackResult(); } @Override public PageResult<List<Product>> getProductListByPage(Product condition, Page page, Sort sort) { return defaultFallbackPageResult(); } }
當服務較多時寫這樣重復的統一熔斷降級處理顯得十分枯燥無味!
前提場景是你的服務接口具有統一的報文格式,例如我的是Result<T>或者PageResult<T>,這樣才有統一全局處理的可能,否則每個服務的fallback你是省不了的
本文將采用Cglib動態代理來統一處理這些fallback,說來容易做起來卻十分棘手,完成這一功能,費了相當大的力氣: