什么是hystrix?
hystrix是netflix针对微服务分布式系统采用的熔断保护中间件,hystrix提供了在服务不可达或请求超时之后,优雅的给客户端返回响应结果。
为什么用hystrix?
在微服务场景下,很多服务相互依赖,如果不能对依赖的服务进行隔离,那么服务本身也有可能发生故障,hystrix可以是服务间实现隔离,当某一服务出现故障后,他能够优雅的回退并进行降级,避免出现连锁反应
hystrix快速上手
关注公众号“乐哉码农”,回复“hystrix”获取本节基础项目
在consumer服务上进行操作,添加maven依赖
<dependency>
在userConsumerService类上添加注解@HystrixCommand(fallbackMethod = "getUserFallback")
getUserFallback是当方法执行超时或失败的时候,就会去调用这个方法,给出优雅的响应
添加对应的方法
//失败回调
为了验证效果,这次我们之启动eurek和consumer两个项目,让product服务直接调不通,来模拟请求超时,这是单独使用hystrix进行熔断降级,接下来给大家介绍的是hystrix与feign结合,实现熔断降级
注意:因为我这个是单独将feign作为一个独立的项目,用jar包的形式引入到服务中的,在整合过程中会出现很多问题,不过在文章中都给出了解决办法
打开feign项目
修改UserFeign的注解,如下
@FeignClient(value = "eureka-client-order-service",configuration = FeignConfig.class,fallback = UserFeignFallBack.class)public interface UserFeign { @GetMapping("/user/get") User getUser(@RequestParam("name") String name); @PostMapping("/user/getMap") User getUser(@RequestParam Map<String, String> param); @PostMapping("/user/add") User addUser(@RequestParam("name") String name, @RequestParam("email") String email); @PostMapping("/user/addBody") User addUser(@RequestBody User user);
FeignClient注解上添加了fallback = UserFeignFallBack.class,UserFeignFallBack是UserFeign的实现类,当feign接口调用失败的时候会自动去调用UserFeignFallBack里面对应的方法,返回给调用方,UserFeignFallBack内容如下
@Componentpublic class UserFeignFallBack implements UserFeign { @Override
feign项目里面的工作已经完成,现在我们在consumer项目里面开启feign的熔断功能
feign:
现在重启consumer项目,发现项目启动不了,报了一个这样的错误
No fallback instance of type class com.yangle.feign.UserFeignFallBack found for feign client eureka-client-order-service
没找到UserFeignFallBack这个实例。
现在分析下出现这个的原因,没找到这个实例,说明扫包的时候没扫到他,因为feign是作为jar被引入的,是有可能没被扫到,但是为什么没有报FeignConfig.class实例不存在呢,这个很好解释,还记得我们在整合feign的时候,在启动类上面添加了这样一个东西么,
,,但是
这个好像只扫描了他关注的,并没有去扫描被component注解的实例,所以问题找到了,现在要做的就是能够让UserFeignFallBack能被扫描到
第一种解决办法,在启动类上,加上扫描UserFeignFallBack所在的包路径,前面一个是项目基础包
@SpringBootApplication(scanBasePackages = {"com.yangle.feign","com.yangle.eurekaclientproducter"})
现在重新启动应该就可以了,项目启动成功访问http://localhost:8082/consumer/user/get,返回
说明服务熔断降级成功。
虽然熔断降级完成了,但是好像并不是很完美,因为我们虽然能够优雅的给用户响应,但是作为管理员,我们需要找出这次调用不成功的原因,所以必须将出错信息或异常记录下来,其实feign也给我们提供了另外一种方法fallbackFactory
修改feign注解
@FeignClient(value = "eureka-client-order-service",configuration = FeignConfig.class,fallbackFactory =UserFeignFallBackFactory.class)public interface UserFeign { @GetMapping("/user/get") User getUser(@RequestParam("name") String name); @PostMapping("/user/getMap") User getUser(@RequestParam Map<String, String> param); @PostMapping("/user/add") User addUser(@RequestParam("name") String name, @RequestParam("email") String email); @PostMapping("/user/addBody") User addUser(@RequestBody User user);
所有的处理操作都是在create方法里面进行降级操作,在这里能拿到异常对象,将异常信息记录下来,并且优雅的给用户返回错误信息。
总结
本章学习了hystrix,并且通过hystrix实现了服务的保护功能,下一节带领大家学习API网关zuul
欢迎大家关注我的公众号“乐哉码农”,回复“hystrix”领取本节源码,回复“资料领取”,获取人工智能、大数据等更多学习视频资料,如有侵权,请联系作者立即删除!
本文分享自微信公众号 - AI码师(shi_ma_AI)。
如有侵权,请联系 support@oschina.cn 删除。
本文参与“OSC源创计划”,欢迎正在阅读的你也加入,一起分享。