FeignClient服務(wù)器拋出異常客戶端處理方案
FeignClient服務(wù)器拋出異??蛻舳颂幚?/h2>
在使用feign進(jìn)行遠(yuǎn)程方法調(diào)用時(shí),如果遠(yuǎn)程服務(wù)端方法出現(xiàn)異常,客戶端有時(shí)需要捕獲,并且把異常信息返回給前端,而如果在開啟熔斷之后,這個(gè)異常會(huì)被消化,所以說,如果希望拿到服務(wù)端異常,
feign.hystrix.enable需要設(shè)置為false,而當(dāng)不開熔斷時(shí),我們也有幾種方法把拿到服務(wù)端的異常信息,下面總結(jié)一下。
feign異常攔截器
注冊(cè)一個(gè)Bean對(duì)象,當(dāng)feign調(diào)用出現(xiàn)異常的時(shí)候,會(huì)觸發(fā)這個(gè)方法:
import com.test.JsonUtils; import feign.Response; import feign.Util; import feign.codec.ErrorDecoder; import io.test.BadRequestException; import io.test.InternalServerErrorException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.context.annotation.Configuration; import java.io.IOException; import java.util.HashMap; import java.util.Map; import static feign.FeignException.errorStatus; /** * @author 飄逝才子 * @date 2020/11/05 * @description */ @Configuration public class FeignClientErrorDecoder implements ErrorDecoder { private Logger logger = LoggerFactory.getLogger(FeignClientErrorDecoder.class); @Override public Exception decode(String methodKey, Response response) { Map<String, Object> jsonBody = new HashMap<>(); jsonBody.put("message", "Internal server error"); try { String body = Util.toString(response.body().asReader()); jsonBody = JsonUtils.toMap(body); } catch (IOException e) { logger.error("feign.IOException", e); } assert jsonBody != null; if (response.status() >= 400 && response.status() < 500) { throw new BadRequestException(jsonBody.get("message").toString()); } if (response.status() >= 500) { throw new InternalServerErrorException(jsonBody.get("message").toString()); } return errorStatus(methodKey, response); } }
注意,使用這個(gè)方式,需要在熔斷器關(guān)閉時(shí)才起作用,因?yàn)樗鼈兊膱?zhí)行過程是,先走這個(gè)攔截器,再走熔斷的fallback,所以這個(gè)異常會(huì)被熔斷吞掉,返回狀態(tài)為200,返回值為你的fallback的默認(rèn)值。
FeignClient異常合集Mark
問題1
feignClient調(diào)用報(bào)異常cause:Content-Type cannot contain wildcard type ‘*’
是因?yàn)檫h(yuǎn)程調(diào)用的時(shí)候入?yún)⒆R(shí)別不了application/json
解決辦法:在方法上加上類型即可consumes = MediaType.APPLICATION_JSON_VALUE
@RequestMapping(value = "/xxx/xxx/xxx/xxx/xxx/xxx/result",method = RequestMethod.GET, consumes = MediaType.APPLICATION_JSON_VALUE)
ResponseResult xxx(TaskParam taskParam);
問題2
fallback 與fallbackFactory的使用
fallbackFactory:拋出異??刹榭矗话憧蠢锩鎾伋龅漠惓H罩炯纯膳袛噙h(yuǎn)程調(diào)用的問題所在。
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。
相關(guān)文章
解決java.net.SocketTimeoutException: Read timed out的問題
這篇文章主要介紹了解決java.net.SocketTimeoutException: Read timed out的問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-06-06vscode 配置java環(huán)境并調(diào)試運(yùn)行的詳細(xì)過程
這篇文章主要介紹了vscode 配置java環(huán)境并調(diào)試運(yùn)行的詳細(xì)過程,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2021-05-05