- 一、概念介绍
- 二、解决方案
- 三、集成使用
- 四、扩展使用
- 五、网关监控
1、什么是熔断？
2、什么是降级？
3、区别？
4、什么是限流？
springcloud的Hystrix和Alibaba的Sentinel，两者对比如下：
关于springcloud和springcloud-alibaba和各组件的版本对应可参考github官网
https://github.com/alibaba/spring-cloud-alibaba/wiki/%E7%89%88%E6%9C%AC%E8%AF%B4%E6%98%8E
1、springboot引入Sentinel依赖
直接指定版本号
com.alibaba.cloud spring-cloud-starter-alibaba-sentinel 2.2.3.RELEASE
或者引入spring-cloud-alibaba，不加版本号默认会跟据spring-cloud-alibaba选取合适的版本
com.alibaba.cloud spring-cloud-starter-alibaba-sentinel com.alibaba.cloud spring-cloud-alibaba-dependencies 2.2.5.RELEASE pom import
2、下载与2.2.3.RELEASE中核心包core-1.8.0对应的控制台
https://github.com/alibaba/Sentinel/releases/tag/v1.8.0
如果github下载过慢，可以使用我的这个1.8版本的包core-1.8.0
3、使用java -jar sentinel-dashboard-1.8.0.jar来启动控制台（默认端口为8080，可使用--server.port=8888来修改启动端口）
4、springboot配置Sentinel相关信息
spring:
cloud:
sentinel:
transport:
port: 8719
dashboard: localhost:8888
5、配置规则每秒最多请求两次，F5快速刷新测试请求
注意：默认情况下Sentinel只能监控直接调用，如果要监控Feign远程调用，需要加上配置
feign:
sentinel:
enabled: true
这里有三个问题，
①监控图表没显示(搞版本已经解决了此问题，比如我用的1.8.0)
②所有配置都在内存中缓存着，重启失效
③超过配置的访问量后返回的信息是Sentinel自带的，需要自定义
5-1、解决低版本监控图表出不来
引入依赖
org.springframework.boot spring-boot-starter-actuator
添加配置
management.endpoints.web.exposure.include=*
5-2、配置持久化
5-3、自定义违反规则处理参考下面：四、扩展使用
1、新建配置类SentinelConfig，作用于所有默认规则资源，比如像比如在@GetMapping("/testSentinel")这种请求，自定义请求地址资源返回内容
注意：如果是springboot1.x，内置spring4，使用下面的代码
如果是springboot2.x，内置spring5，使用webflux，代码如下：
import com.alibaba.csp.sentinel.adapter.spring.webflux.callback.BlockRequestHandler;
import com.alibaba.csp.sentinel.adapter.spring.webflux.callback.WebFluxCallbackManager;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.function.server.ServerResponse;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
@Configuration
public class SentinelConfig {
public SentinelConfig() {
WebFluxCallbackManager.setBlockHandler(new BlockRequestHandler() {
@Override
public Mono handleRequest(ServerWebExchange serverWebExchange, Throwable throwable) {
Mono body = ServerResponse.ok().body(Mono.just("{"msg":"请求流量过大","code":0}"), String.class);
return body;
}
});
}
}
2、在整个请求里面再细分多个监控降级
比如在@GetMapping("/testSentinel")里处理业务代码有A、B两步，需要对B步骤单独监控限流降级，可以使用以下几种方法
（1）try{}catch{}代码块，自定义异常
try (Entry entry = SphU.entry("B");){
//...执行B业务的代码
} catch (BlockException e) {
e.printStackTrace();
}
此时新增限流规则，设置限流每秒最多一个请求后，在快速刷新请求，就会抛出异常
（2）、基于注解
①、在将B业务抽取成B方法，在B方法上加入注解 @SentinelResource(value = "B",blockHandler = "handlerB")//参数一：规则名称；参数二：B方法违反规则后的处理方法
②、新建handlerB方法，此方法需跟B方法的返回值、参数完全相同，在里面返回自定义提示信息即可
Sentinel不仅能监控请求、方法，在业务层去定义规则，也可以在网关层限流熔断，比如对Gateway进行监控限流
1、在网关服务的pom中添加依赖
com.alibaba.cloud spring-cloud-starter-alibaba-sentinel 2.2.3.RELEASE com.alibaba.cloud spring-cloud-alibaba-sentinel-gateway 2.1.0.RELEASE
2、添加配置
spring:
cloud:
sentinel:
transport:
port: 8719
dashboard: localhost:8888
3、测试使用
4、网关异常统一处理，和业务异常统一处理一样
新建SentinelGatewayConfig类，代码如下
import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.BlockRequestHandler;
import com.alibaba.csp.sentinel.adapter.gateway.sc.callback.GatewayCallbackManager;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.reactive.function.server.ServerResponse;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
@Configuration
public class SentinelGatewayConfig {
public SentinelGatewayConfig() {
GatewayCallbackManager.setBlockHandler(new BlockRequestHandler() {
@Override
public Mono handleRequest(ServerWebExchange serverWebExchange, Throwable throwable) {
Mono body = ServerResponse.ok().body(Mono.just("{"msg":"请求流量过大","code":0}"), String.class);
return body;
}
});
}
}
测试使用，f5快速刷新
