赞
踩
在使用feign进行远程方法调用时,如果远程服务端方法出现异常,客户端有时需要捕获,并且把异常信息返回给前端,而如果在开启熔断
之后,这个异常会被消化,所以说,如果希望拿到服务端异常,feign.hystrix.enable
需要设置为false,而当不开熔断时,我们也有几种方法把拿到服务端的异常信息,下面总结一下。
注册一个Bean对象,当feign调用出现异常的时候,会触发这个方法:
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); } }
注意,使用这个方式,需要在熔断器关闭时才起作用,因为它们的执行过程是,先走这个拦截器,再走熔断的fallback,所以这个异常会被熔断吞掉,返回状态为200,返回值为你的fallback的默认值。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。