springboot中使用sentinel

homeant | 2019-04-21 14:03 浏览99

随着微服务的流行,服务和服务之间的稳定性变得越来越重要。 Sentinel 以流量为切入点,从流量控制、熔断降级、系统负载保护等多个维度保护服务的稳定性。

Sentinel特征

  • 丰富的应用场景: Sentinel 承接了阿里巴巴近 10 年的双十一大促流量的核心场景,例如秒杀(即突发流量控制在系统容量可以承受的范围)、消息削峰填谷、实时熔断下游不可用应用等。

  • 完备的实时监控: Sentinel 同时提供实时的监控功能。您可以在控制台中看到接入应用的单台机器秒级数据,甚至 500 台以下规模的集群的汇总运行情况。

  • 广泛的开源生态: Sentinel 提供开箱即用的与其它开源框架/库的整合模块,例如与 Spring Cloud、Dubbo、gRPC 的整合。您只需要引入相应的依赖并进行简单的配置即可快速地接入 Sentinel。

  • 完善的 SPI 扩展点: Sentinel 提供简单易用、完善的 SPI 扩展点。您可以通过实现扩展点,快速的定制逻辑。例如定制规则管理、适配数据源等。

Sentinel控制台

Sentinel提供了两种使用方式,包括使用阿里云提供的服务,当初推广的时候是免费的

在线控制台

下载地址

项目使用Sentinel(阿里云控制台)

ahas文档

引入ahas依赖

<dependency>
    <groupId>com.alibaba.csp</groupId>
    <artifactId>ahas-sentinel-client</artifactId>
    <version>1.6.4</version>
</dependency>

添加bean

@Bean
public FilterRegistrationBean sentinelFilterRegistration() {
    FilterRegistrationBean registration = new FilterRegistrationBean();
    registration.setFilter(new CommonFilter());
    registration.addUrlPatterns("/*");
    registration.setName("sentinelCommonFilter");
    registration.setOrder(1);
    return registration;
}

项目启动

java Dproject.name=AppName -Dahas.license=<License> -jar xxxx.jar 

使用自己搭建的控制台

启动Sentinel控制台

java -Dserver.port=8081 -Dcsp.sentinel.dashboard.server=localhost:8081 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard-1.7.2.jar

PS:用户名密码都是sentinel

控制台

引入依赖

<dependency>
    <groupId>com.alibaba.cloud</groupId>
    <artifactId>spring-cloud-starter-alibaba-sentinel</artifactId>
</dependency>

简单示例

@SpringBootApplication
public class SentinelApplication {
	public static void main(String[] args) {
		SpringApplication.run(SentinelApplication.class, args);
	}
}

@RestController
public class IndexController {

	@Autowired
	private SayHelloService sayHelloService;

	@GetMapping
	public String sayHello(String name) {
		return sayHelloService.sayHello(name);
	}
}

public interface SayHelloService {
	String sayHello(String name);
}

@Slf4j
@Service
public class SayHelloServiceImpl implements SayHelloService {
	@SentinelResource("sayHello")
	public String sayHello(String name) {
		log.info(Thread.currentThread().getName());
		try {
			Thread.sleep(1000);
		}catch (Exception e){
			e.printStackTrace();
		}
		return "hello ".concat(name).concat("!");
	}
}

application.yaml配置

spring:
  application:
    name: spring-cloud-sentinel
    sentinel:
      transport:
        port: 8081
        dashboard: localhost:8081

@SentinelResource注解用来标识资源是否被限流、降级。上述例子上该注解的属性 sayHello 表示资源名。

规则配置

流控规则》新增流控规则

  1. 输入资源名,和代码中@SentinelResource注解的值对应
  2. 根据对应需求选择阈值类型,分为QPS线程数
  3. 设置阈值类型对应的数值,比如同一时间内只允许有一个线程访问,可以选择为线程数,单机阈值1

测试结果

线程测试

测试环境:阈值类型为线程数,单机阈值为10,jMeter设置线程为20,失败率为50%

测试结果

QPS测试

测试环境:阈值类型为QPS,单机阈值为10,jMeter设置线程为20,失败率为40%

测试结果

代码地址