sentinel基本使用
1.1 編程式
下面是啟動main方法尼酿，然后會創(chuàng)建限流規(guī)則initFlowRules()然后進入while循環(huán)懦胞，代碼塊Thread.sleep(10)和System.out.println("hello world")就是業(yè)務(wù)方法箩艺。然后entry = SphU.entry("HelloWorld")是使用了一個HelloWorld的資源眯分。這個資源的限流模式再initFlowRules()里面已經(jīng)定義了。
public class MySentinelTest {
public static void main(String[] args) {
initFlowRules();
while (true) {
Entry entry = null;
try {
entry = SphU.entry("HelloWorld");
/*您的業(yè)務(wù)邏輯 - 開始*/
Thread.sleep(10);
System.out.println("hello world");
/*您的業(yè)務(wù)邏輯 - 結(jié)束*/
} catch (BlockException | InterruptedException e) {
/*流控邏輯處理 - 開始*/
System.out.println("block!");
/*流控邏輯處理 - 結(jié)束*/
} finally {
if (entry != null) {
entry.exit();
}
}
}
}
private static void initFlowRules(){
List<FlowRule> rules = new ArrayList<>();
FlowRule rule = new FlowRule();
rule.setResource("HelloWorld");
rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
// Set limit QPS to 20.
rule.setCount(20);
rules.add(rule);
FlowRuleManager.loadRules(rules);
}
}
上面代碼執(zhí)行可以新建一個maven項目缚甩，然后導(dǎo)入sentinel依賴谱净。由于現(xiàn)在spring主要推薦3.x所以無法再spring init上面創(chuàng)建jdk為1.8的項目。大家可以去alibaba上面創(chuàng)建空的項目蹄胰。地址如下：https://start.aliyun.com/
1.2 注解式
第一步：創(chuàng)建一個controller層和service層岳遥。其中service層使用注解控制資源
controller層代碼
@RestController
public class MySentinelController {
@Autowired
private MySentinelService mySentinelService;
@GetMapping("/helloworld")
public String helloworld(){
String message = mySentinelService.getInfo();
return message;
}
}
service層代碼
controller層會調(diào)用service的getInfo方法。再getInfo方法上面新增資源注解@SentinelResource(value = "helloworld",blockHandler = "blockMessage其中value是資源的名字裕寨，blockHandler是如果觸發(fā)限流，那么執(zhí)行什么方法。這個例子里面如果觸發(fā)限流會調(diào)用下面的blockMessage方法宾袜。主要這里的入?yún)⑿枰獣rBlockException
@Service
public class MySentinelService {
@SentinelResource(value = "helloworld",blockHandler = "blockMessage")
public String getInfo() {
return "hello world sentinel";
}
public String blockMessage(BlockException e){
System.out.println(e);
return "阻塞了捻艳！";
}
}
第二步：創(chuàng)建限流規(guī)則hellworld
springboot啟動類里面新增初始化限流規(guī)則的方法
@SpringBootApplication
public class LearningSentinelApplication {
public static void main(String[] args) {
SpringApplication.run(LearningSentinelApplication.class, args);
initFlowRules();
}
private static void initFlowRules(){
List<FlowRule> rules = new ArrayList<>();
FlowRule rule = new FlowRule();
rule.setResource("helloworld");
rule.setGrade(RuleConstant.FLOW_GRADE_QPS);
// Set limit QPS to 20.
rule.setCount(1);
rules.add(rule);
FlowRuleManager.loadRules(rules);
}
}
:::success
上面是一個簡單的sentinel入門程序，能夠讓我們看到sentinel的作用庆猫，也了解一些再sentinel里面的概念认轨，比如：資源。下面是根據(jù)上面代碼整合sentinel提供的dashboard
:::
dashboard環(huán)境搭建
2.1 下載dashboard
可以去github下載
2.2 啟動dashboard
java -Dserver.port=8080 -Dcsp.sentinel.dashboard.server=localhost:8080 -Dproject.name=sentinel-dashboard -jar sentinel-dashboard-1.8.7.jar
2.3 訪問dashboard
地址：http://localhost:8080/#/login
默認賬號密碼：sentinel/sentinel
訪問結(jié)果：
2.4 項目接入dashboard
修改項目配置文件
# Sentinel 控制臺地址
spring.cloud.sentinel.transport.dashboard=localhost:8080
# 取消Sentinel控制臺懶加載
# 默認情況下 Sentinel 會在客戶端首次調(diào)用的時候進行初始化月培，開始向控制臺發(fā)送心跳包
# 配置 sentinel.eager=true 時嘁字，取消Sentinel控制臺懶加載功能
spring.cloud.sentinel.eager=true
# 如果有多套網(wǎng)絡(luò)，又無法正確獲取本機IP杉畜，則需要使用下面的參數(shù)設(shè)置當(dāng)前機器可被外部訪問的IP地址纪蜒，供admin控制臺使用
# spring.cloud.sentinel.transport.client-ip=
server.port=8081
spring.application.name=learning_sentinel
spring boot啟動類去掉初始化限流規(guī)則
在spring啟動類中去掉限流規(guī)則〈说可以在dashboard上面創(chuàng)建限流規(guī)則纯续，然后再業(yè)務(wù)代碼中使用。后面也可以整合nacos通過nacos下發(fā)限流規(guī)則
public static void main(String[] args) {
SpringApplication.run(LearningSentinelApplication.class, args);
// initFlowRules();
}
2.5 啟動項目灭袁，在dashboard上面配置helloworld限流規(guī)則
整合nacos實現(xiàn)下發(fā)限流規(guī)則
3.1 下載nacos客戶端
可以去github上面下載
3.2 啟動nacos
啟動nacos
.\startup.cmd -m standalone
訪問地址
http://192.168.31.14:8848/nacos/index.html
3.3 修改項目配置
項目添加nacos依賴
<dependency>
<groupId>com.alibaba.csp</groupId>
<artifactId>sentinel-datasource-nacos</artifactId>
</dependency>
修改項目配置文件
下面是配置項目里面的application.properties新增nacos地址猬错，其中dataId一定要和配置的nacos保持一致，groupId也是一樣
spring.cloud.sentinel.datasource.ds.nacos.server-addr=127.0.0.1:8848
spring.cloud.sentinel.datasource.ds.nacos.dataId=learning-sentinel
spring.cloud.sentinel.datasource.ds.nacos.groupId=DEFAULT_GROUP
spring.cloud.sentinel.datasource.ds.nacos.ruleType=flow
3.4 在nacos上面新增流控配置
其中json表示配置的資源和資源的流控規(guī)則
[
{
"resource": "helloworld",
"limitApp": "default",
"grade": 1,
"count": 2,
"strategy": 0,
"controlBehavior": 0,
"clusterMode": false
}
]
