在上一篇中，我们讲解了 Sentinel 限流详解，其中详细讲解了各个规则下的限流是如何操作，有兴趣的小伙伴可以了解一下，有不少小伙伴在后台留言说，想了解一下 sentinel中如何使用@SentinelResource和openFeign来进行服务熔断和降级的操作，大家知道小农对于小伙伴的要求，那都是尽量满足，今天我们就来好好说一下，@SentinelResource和openFeign。,在上一节中，我们也使用到过这个注解，我们需要了解的是其中两个属性：,value： 资源名称，必填且唯一。,entryType：非必填，entry类型，标记流量的方向，指明是出口流量，还是入口流量；取值 IN/OUT ,默认是OUT。,blockHandler： 处理异常（BlockException）的函数名称，不必填，使用时注意两点：,blockHandlerClass: 非必填，存放blockHandler的类。对应的处理函数必须static修饰，否则无法解析，必须是public，返回类型与原方法一致，参数类型需要和原方法相匹配，并在最后加上BlockException类型的参数。,fallback: 非必填，用于在抛出异常的时候提供fallback处理逻辑。fallback函数可以针对所有类型的异常（除了execptionsToIgnore 里面排除掉的异常类型）进行处理。,exceptionsToIgnore：非必填，指定排除掉哪些异常。排除的异常不会计入异常统计，也不会进入fallback逻辑，而是原样抛出。,今天我们就针对于上面的几个点详细的展开介绍，在实际应用中我们如何进行操作。我们先来编写一个新的控制器类型，这里我们使用cloud-alibaba-sentinel-8006项目进行操作，对应源码已经放在开头位置，需要请自取。,@SentinelResource 既可以配置资源名称也可以配置URL，当我们配置了blockHandler属性时，如果达到阈值时，会调用对应的方法提示限流信息，如果没有配置blockHandler属性，系统会走默认的限流信息（Blocked by Sentinel (flow limiting)）。,首先我们使用默认的@SentinelResource注解，系统会针对对应的地址调用默认的异常处理方法。,先访问http://localhost:8006/restUrl，在添加流控规则。,此时如果没有自己定义限流处理方法，会走系统默认的。,使用@SentinelResource注解同时使用blockHandler属性。,先访问http://localhost:8006/resourceTest，在添加流控规则。,再去快速的去访问http://localhost:8006/resourceTest 就会出现我们在代码中配置的限流异常处理信息，如下图所示：,上面就展示了我们使用blockHandler属性时，出现的我们自己设置的异常提示，但是当我们使用上面两种方案的时候，会出现一些问题，如果我们的业务逻辑比较复杂，熔断的业务场景比较多，上面的显然不能够满足我们的应用，而且这种自定义方法是和我们的业务代码耦合在一起的，在实际开发中，会显得不够优雅，每个业务方法对添加一个对应的限流处理方法，会让代码显得臃肿，而且无法实现统一处理。在这里我们就需要提到我们另外一个属性—blockHandlerClass。,此属性中设置的方法必需为 static 函数，否则无法解析。首先我们需要创建一个类用于专门处理自定义限流处理逻辑，这里记住，方法一定要是静态，否则无法解析，如下所示：,同时我们添加一个可访问的接口方法，设置@SentinelResource注解和blockHandlerClass属性对应的类型和这个类型中对应的处理方法。,然后我们先访问http://localhost:8006/buildExption后，来给它添加限流规则。,我们再次访问http://localhost:8006/buildExption后，这个时候我们来看一下如果超过阈值之后使用的处理方法是否是我们的SentinelExptioinHandler.handlerMethodError()，当我们频繁的访问地址，就会看到出现了我们在异常处理类中设置的方法。,如果我们想要体现，网络异常的操作，我们只需要替换blockHandler中的handlerMethodError改为handlerMethodNetwork，重启项目后，重复上面的步骤，再来看一下，就会出现下面的提示：,在微服务中，由于业务的拆分，一般会出现请求链路过程的情况，当一个用户发起一个请求，通常需要几个微服务才能完成，在高并发的场景下，这种服务之间的依赖对系统的稳定性影响比较大，如果其中一个环节出现网络延迟或者请求超时等问题会导致其他服务的不可用并形成阻塞，从而导致雪崩，服务熔断就是用来解决这种情况，当一个服务提供在无法提供正常服务时，为了放在雪崩的方式，会将当前接口和外部隔离，触发熔断，在熔断时间内，请求都会返回失败，直到服务提供正常，才会结束熔断。简单来说，服务熔断就是应对微服务雪崩的一种链路保护机制。,为了模拟实际的应用场景，我们需要整合Ribbon+openFeign，来搭建真实的应用场景。首先我们需要利用Ribbon进行负载均衡的调用，我们先来创建消费者(cloud-alibab-consumer-8083)和两个服务提供者(cloud-alibaba-provider-9003/9004)。,我们先来搭建服务提供者。,pom文件：,yml文件：,主启动类添加@EnableDiscoveryClient注解。,添加商品信息请求类。,到这里服务提供者就搭建完成了。,注意：另外一个服务提供者一样，只需要端口不一样即可，在这里就不做重复性的演示。,pom：,yml文件：,主启动类添加@EnableDiscoveryClient。,访问类：,我们先启动9003/9004,在启动8083，然后访问http://localhost:8083/consumer/goods/2，就可以看到在浏览器中，如果9003/9004相互切换，说明我们搭建成功。,SentinelResource的fallback属性，是一个可选项，主要用于抛出异常的时候提供处理逻辑，该函数可以针对所有的异常类型（除了exceptionsToIgnore排除的异常类型，等下会讲解）进行处理，对于fallback的函数签名和位置要求：,案例：,在这里如果我们去访问id超过3的数字的时候请求时（http://localhost:8083/consumer/goods/6 ），如果我们没有设置fallback属性，会弹出NullPointerException的错误。,现在当我们去访问设置了 fallback属性的时http://localhost:8083/consumer/goods/6 会出现我们设置的参数。,fallback属性和blockHandler有点类似，也可以设置fallbackClass属性，用来指定对应类型，来处理对应的异常类型，但是方法也是需要为静态方法，否则无法解析。,那么既然fallback属性和blockHandler都能进行限流，那么他们有什么不同，哪一个的优先级更高？首先我们要知道blockHandler属性 是针对于Sentinel异常，blockHandler 对应处理 BlockException 的函数名称，而fallback属性针对于Java异常，如果我们同时设置blockHandler和fallback，会执行哪个方法呢？我们来看一下。,添加熔断规则，在一秒内最小请求次数为5，如果异常超过2个时，触发熔断规则。,这个时候我们再来访问http://localhost:8083/consumer/goods/6时，没有触发熔断之前出现异常，由fallback进行处理。,当我们快速点击，触发熔断规则时，这是时候则由blockHandler进行处理。,当我们介绍上面的操作后，我们再给大家介绍关于sentinel的另外一个属性 exceptionsToIgnore。,用于指定哪些异常被排除，不会计入异常统计中，也不会进入 fallback属性处理的方法，会原样抛出。,启动项目，当我们再去访问http://localhost:8083/consumer/goods/6的时候，出现原有异常。,在这一节中，我们主要讲解了sentinel服务熔断的这些事，包括@SentinelResource注解的使用方式和场景，以及ribbon实现负载均衡的使用，服务熔断场景我们主要讲解两个，一个是ribbon实现的，一个是openFeign实现。下面我们就来了解一下基于openFeign如何实现负载均衡和服务熔断。,OpenFeign是一种声明式、模板化的HTTP客户端。在Spring Cloud中使用OpenFeign，可以做到使用HTTP请求访问远程服务，就像调用本地方法一样的，开发者完全感知不到这是在调用远程方法，更感知不到在访问HTTP请求，用法其实就是编写一个接口，在接口上添加注解即可。,可以简单理解它是借鉴Ribbon的基础之上，封装的一套服务接口+注解的方式的远程调用器。由它来帮助我们定义和实现依赖服务接口的定义，只需创建一个接口并使用注解的方式进行配置。进一步简化我们的操作。,演示项目为：cloud-alibaba-openFeign-8009，调用服务为9003/9004。,pom：,yml配置：,启动类添加 @EnableFeignClients。,@FeignClient。,请求控制类。,我们一次启动，9003/9004，以及我们的消费者服务cloud-alibaba-openFeign-8009，当我们的服务都启动成功后，访问http://localhost:8009/query/1，如果看到我们的端口切换展示就表示成功了。,OpenFeign 默认的超时时间为一秒钟，如果服务端业务超过这个时间，则会报错，为了避免这样的情况，我们可以设置feign客户端的超时控制。我们先来看一下如果我们设置一个延时任务openFeign会提示怎么样的信息。我们需要在服务提供者(9003/9004)那里设置一个阻塞三秒的请求。,然后通过feign进行调用。,这个时候当我们去访问http://localhost:8009/query/readTimeOut时，客户端会提示报错，提示我们连接超时。,这个时候我们可以设置feign的超时时间进行控制，由于OpenFeign 底层是ribbon 。所以超时控制由ribbon来控制。在yml文件中配置，只需要在8009中的yml添加这样一段代码即可。,当我们重新启动项目后，再来访问我们当前接口，成功返回正确信息。,说起OpenFeign，我们不得不提它的一个很小，但是很实用的一个日志功能。我们可以通过配置调整日志级别，这样有利于我们从feign中了解请求和响应的细节，对接口的调用情况进行监控。,OpenFeign 日志级别分类四种：,我们在启动类中通过@Bean注解注入日志功能即可。,yml中添加日志开启功能。,这样我们就可以在请求调用以后看到日志的详细信息了。,我们已经了解了openFeign的基本使用，那么我们要如何将Sentinel和OpenFeign进行整合呢，下面我们就来带大家通过Sentinel来进行整合OpenFegin。,yml中添加Sentinel对OpenFeign的支持。,在feign中添加对fallback的支持。,这个时候我们来请求http://localhost:8009/query/1，时是正常的，但是当我们关闭服务提供者(9003/9004)时，就出触发服务降级操作，提示下面信息。,熔断由服务不可用引起，降级由业务实际情况和系统资源负载设置等关系引起，不管是对于熔断还是降级都是从系统稳定性出发，保证系统的最大可用。
© 版权声明
文章版权归作者所有，未经允许请勿转载。
