还记得我们前所说的服务降级吗,也就是说我们需要在整个微服务调用链路出现问题的时候,及时对服务进行降级,以防止问题进一步恶化。

那么,各位是否有思考过,如果在某一时刻,服务B出现故障(可能就卡在那里了),而这时服务A依然有大量的请求,在调用服务B,那么,由于服务A没办法再短时间内完成处理,新来的请求就会导致线程数不断地增加,这样,CPU的资源很快就会被耗尽。
那么要防止这种情况,就只能进行隔离了,这里我们提两种隔离方案:

Semaphore类实现的(如果不了解,可以观看本系列 并发编程篇 视频教程),思想基本上与上面是相同的,也是限定指定的线程数量能够同时进行服务调用,但是它相对于线程池隔离,开销会更小一些,使用效果同样优秀,也支持超时等。
好了,说回我们的熔断和降级,当下游服务因为某种原因变得不可用或响应过慢时,上游服务为了保证自己整体服务的可用性,不再继续调用目标服务而是快速返回或是执行自己的替代方案,这便是服务降级。

整个过程分为三个状态:
那么我们来看看Sentinel中如何进行熔断和降级操作,打开管理页面,我们可以自由新增熔断规则:

其中,熔断策略有三种模式:
慢调用,在一个统计时长内,如果请求数目大于最小请求数目,并且被判定为慢调用的请求比例已经超过阈值,将触发熔断。经过熔断时长之后,将会进入到半开状态进行试探(这里和Hystrix一致)- @RequestMapping("/borrow2/{uid}")
- UserBorrowDetail findUserBorrows2(@PathVariable("uid") int uid) throws InterruptedException {
- Thread.sleep(1000);
- return null;
- }
重启,然后我们创建一个新的熔断规则:

可以看到,超时直接触发了熔断,进入到阻止页面:
- @RequestMapping("/borrow2/{uid}")
- UserBorrowDetail findUserBorrows2(@PathVariable("uid") int uid) {
- throw new RuntimeException();
- }
启动服务器,接着添加我们的熔断规则:

现在我们进行访问,会发现后台疯狂报错,然后就熔断了:

那么熔断规则如何设定我们了解了,那么,如何自定义服务降级呢?之前在使用Hystrix的时候,如果出现异常,可以执行我们的替代方案,Sentinel也是可以的。
同样的,我们只需要在@SentinelResource中配置blockHandler参数(那这里跟前面那个方法限流的配置不是一毛一样吗?没错,因为如果添加了@SentinelResource注解,那么这里会进行方法级别细粒度的限制,和之前方法级别限流一样,会在降级之后直接抛出异常,如果不添加则返回默认的限流页面,blockHandler的目的就是处理这种Sentinel机制上的异常,所以这里其实和之前的限流配置是一个道理,因此下面熔断配置也应该对value自定义名称的资源进行配置,才能作用到此方法上):
- @RequestMapping("/borrow2/{uid}")
- @SentinelResource(value = "findUserBorrows2", blockHandler = "test")
- UserBorrowDetail findUserBorrows2(@PathVariable("uid") int uid) {
- throw new RuntimeException();
- }
-
- UserBorrowDetail test(int uid, BlockException e){
- return new UserBorrowDetail(new User(), Collections.emptyList());
- }
接着我们对进行熔断配置,注意是对我们添加的@SentinelResource中指定名称的findUserBorrows2进行配置:

OK,可以看到熔断之后,服务降级之后的效果:

最后我们来看一下如何让Feign的也支持Sentinel,前面我们使用Hystrix的时候,就可以直接对Feign的每个接口调用单独进行服务降级,而使用Sentinel,也是可以的,首先我们需要在配置文件中开启支持:
- feign:
- sentinel:
- enabled: true
之后的步骤其实和之前是一模一样的,首先创建实现类:
- @Component
- public class UserClientFallback implements UserClient{
- @Override
- public User getUserById(int uid) {
- User user = new User();
- user.setName("我是替代方案");
- return user;
- }
- }
然后直接启动就可以了,中途的时候我们吧用户服务全部下掉,可以看到正常使用替代方案:

这样Feign的配置就OK了,那么传统的RestTemplate呢?我们可以使用@SentinelRestTemplate注解实现:
- @Bean
- @LoadBalanced
- @SentinelRestTemplate(blockHandler = "handleException", blockHandlerClass = ExceptionUtil.class,
- fallback = "fallback", fallbackClass = ExceptionUtil.class) //这里同样可以设定fallback等参数
- public RestTemplate restTemplate() {
- return new RestTemplate();
- }
这里就不多做赘述了。