• 欢迎访问搞代码网站,推荐使用最新版火狐浏览器和Chrome浏览器访问本网站!
  • 如果您觉得本站非常有看点,那么赶紧使用Ctrl+D 收藏搞代码吧

Spring Cloud Gateway Hystrix fallback获取异常信息的处理

java 搞代码 4年前 (2022-01-05) 37次浏览 已收录 0个评论
文章目录[隐藏]

这篇文章主要介绍了Spring Cloud Gateway Hystrix fallback获取异常信息的处理方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教

Gateway Hystrix fallback获取异常信息

gateway fallback后,需要知道请求的是哪个接口以及具体的异常信息,根据不同的请求以及异常进行不同的处理。一开始根据网上一篇博客上的做法:

pom.xml:

  org.springframework.cloudspring-cloud-starter-gateway org.springframework.cloudspring-cloud-starter-netflix-hystrix

application.yml:

 spring: cloud: gateway: discovery: locator: enabled: false lowerCaseServiceId: true routes: - id: auth-server uri: lb://MS-OAUTH2-SERVER predicates: - Path=/** default-filters: - name: Hystrix args: name: fallbackcmd fallbackUri: forward:/fallback

然后fallback就是这样:

 @RestController @Slf4j public class FallbackController { @RequestMapping(value = "/fallback") @ResponseStatus public Mono<Map> fallback(ServerWebExchange exchange, Throwable throwable) { Map result = new HashMap(3); ServerHttpRequest request = exchange.getRequest(); log.error("接口调用失败,URL={}", request.getPath().pathWithinApplication().value(), throwable); result.put("code", 60002); result.put("data", null); result.put("msg", "接口调用失败!"); return Mono.just(result); } } 

但是测试发现,这样取出来的接口地址只是“/fallback”本身,并且没有异常信息:

后来我重新到HystrixGatewayFilterFactory类中去查看,发现了异常信息其实在exchange里:

而请求的接口也通过debug找到了:

所以将代码改成如下:

 @RestController @Slf4j public class FallbackController { @RequestMapping(value = "/fallbac<em style="color:transparent">来源[email protected]搞@^&代*@码)网</em>k") @ResponseStatus public Mono<Map> fallback(ServerWebExchange exchange) { Map result = new HashMap(3); result.put("code", 60002); result.put("data", null); Exception exception = exchange.getAttribute(ServerWebExchangeUtils.HYSTRIX_EXECUTION_EXCEPTION_ATTR); ServerWebExchange delegate = ((ServerWebExchangeDecorator) exchange).getDelegate(); log.error("接口调用失败,URL={}", delegate.getRequest().getURI(), exception); if (exception instanceof HystrixTimeoutException) { result.put("msg", "接口调用超时"); } else if (exception != null && exception.getMessage() != null) { result.put("msg", "接口调用失败: " + exception.getMessage()); } else { result.put("msg", "接口调用失败"); } return Mono.just(result); } } 

正常取到请求路径以及异常信息:

关于 hystrix 的异常 fallback method wasn’t found

消费者服务–service 的实现如下:

 @Service public class BookService { @Autowired public RestTemplate  restTemplate; @HystrixCommand(fallbackMethod = "addServiceFallback") public  Book   getBook( Integer  bookId ){ return  restTemplate.getForObject("http://provider-service/boot/book?bookId={bookId}",Book.class , bookId); } public  String  addServiceFallback(){ System.out.println("error addServiceFallback.... "); return  "error" ; } }

就会出现如下所述的异常

Whitelabel Error Page
This application has no explicit mapping for /error, so you are seeing this as a fallback.

Fri May 25 14:27:51 CST 2018
There was an unexpected error (type=Internal Server Error, status=500).
fallback method wasn’t found: addServiceFallback([class java.lang.Integer])

这是因为指定的 备用方法 addServiceFallback 和 原方法getBook 的参数个数,参数类型 不同造成的;

修改addServiceFallback 方法:

 public  String addServiceFallback(Integer  bookId){ System.out.println("error addServiceFallback.... "); return  "error" ; }

继续运行,就会出现如下所述的异常

Whitelabel Error Page
This application has no explicit mapping for /error, so you are seeing this as a fallback.

Fri May 25 14:32:24 CST 2018
There was an unexpected error (type=Internal Server Error, status=500).
Incompatible return types. Command method: public com.bmcc.springboot.model.Book com.bmcc.springboot.service.BookService.getBook(java.lang.Integer); Fallback method: public java.lang.String com.bmcc.springboot.service.BookService.addServiceFallback(java.lang.Integer); Hint: Fallback method ‘public java.lang.String com.bmcc.springboot.service.BookService.addServiceFallback(java.lang.Integer)’ must return: class com.bmcc.springboot.model.Book or its subclass

这是因为指定的 备用方法 addServiceFallback 和 原方法getBook 虽然 参数个数,参数类型 相同 ,但是 方法的返回值类型不同造成的;

修改addServiceFallback 方法:

 public  Book  addServiceFallback(Integer  bookId){ System.out.println("error addServiceFallback.... "); return  new Book() ; }

继续运行,这样就可以看到当一个服务提供者异常关闭时, 消费者(消费者采用轮询的方式消费服务)再继续访问服务时,不会抛出异常页面,而是如下:

 {"bookId":0,"bookName":null,"price":null,"publisher":null}

以上为个人经验,希望能给大家一个参考,也希望大家多多支持gaodaima搞代码网

以上就是Spring Cloud Gateway Hystrix fallback获取异常信息的处理的详细内容,更多请关注gaodaima搞代码网其它相关文章!


搞代码网(gaodaima.com)提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected],我们会在看到邮件的第一时间内为您处理,或直接联系QQ:872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接:Spring Cloud Gateway Hystrix fallback获取异常信息的处理

喜欢 (0)
[搞代码]
分享 (0)
发表我的评论
取消评论

表情 贴图 加粗 删除线 居中 斜体 签到

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址