sentinel 使用示例

官网：https://sentinelguard.io/zh-cn/docs/quick-start.html

github：https://github.com/alibaba/Sentinel/wiki/%E5%A6%82%E4%BD%95%E4%BD%BF%E7%94%A8

相关类与接口

Sphu

public class SphU {private static final Object[] OBJECTS0 = new Object[0];private SphU() {}public static Entry entry(String name) throws BlockException {public static Entry entry(String name, int batchCount) throws BlockException {public static Entry entry(String name, EntryType trafficType) throws BlockException {public static Entry entry(String name, EntryType trafficType, int batchCount) throws BlockException {public static Entry entry(String name, EntryType trafficType, int batchCount, Object... args) throws BlockException {public static Entry entry(String name, int resourceType, EntryType trafficType) throws BlockException {public static Entry entry(String name, int resourceType, EntryType trafficType, Object[] args) throws BlockException {public static Entry entry(Method method) throws BlockException {public static Entry entry(Method method, int batchCount) throws BlockException {public static Entry entry(Method method, EntryType trafficType) throws BlockException {public static Entry entry(Method method, EntryType trafficType, int batchCount) throws BlockException {public static Entry entry(Method method, EntryType trafficType, int batchCount, Object... args) throws BlockException {public static Entry entryWithPriority(String name) throws BlockException {public static Entry entryWithPriority(String name, EntryType trafficType) throws BlockException {public static AsyncEntry asyncEntry(String name) throws BlockException {public static AsyncEntry asyncEntry(String name, EntryType trafficType) throws BlockException {public static AsyncEntry asyncEntry(String name, EntryType trafficType, int batchCount, Object... args) throws BlockException {public static AsyncEntry asyncEntry(String name, int resourceType, EntryType trafficType) throws BlockException {public static AsyncEntry asyncEntry(String name, int resourceType, EntryType trafficType, Object[] args) throws BlockException {public static AsyncEntry asyncEntry(String name, int resourceType, EntryType trafficType, int batchCount, Object[] args) throws BlockException {

SphO

public class SphO {private static final Object[] OBJECTS0 = new Object[0];public SphO() {}public static boolean entry(String name) {public static boolean entry(String name, int batchCount) {public static boolean entry(String name, EntryType type) {public static boolean entry(String name, EntryType type, int count) {public static boolean entry(String name, EntryType trafficType, int batchCount, Object... args) {public static boolean entry(Method method) {public static boolean entry(Method method, int batchCount) {public static boolean entry(Method method, EntryType type) {public static boolean entry(Method method, EntryType type, int count) {public static boolean entry(Method method, EntryType trafficType, int batchCount, Object... args) {public static void exit(int count, Object... args) {public static void exit(int count) {public static void exit() {

使用示例

Test

public class Test {public static void fun(int index){   //受保护的资源System.out.println("fun方法执行："+index);}public static void initFlowRule(){   //初始化限流规则List<FlowRule> flowRules = new ArrayList<>();FlowRule flowRule = new FlowRule();flowRule.setResource("hello");       //定义受保护的资源名称，需与下方entry中名称一致flowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);flowRule.setCount(20);flowRule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);flowRules.add(flowRule);FlowRuleManager.loadRules(flowRules);}public static void main(String[] args) {initFlowRule();Entry entry;for (int i=0;i<100;i++){try {entry = SphU.entry("hello");   //受保护的资源名称fun(i);                        //调用受保护的方法} catch (Exception e){e.printStackTrace();}finally {if (entry != null){entry.exit();}}}System.exit(0);}
}

点击运行，控制台输出：

INFO: Sentinel log output type is: file
INFO: Sentinel log charset is: utf-8
INFO: Sentinel log base directory is: /Users/huli/logs/csp/
INFO: Sentinel log name use pid is: false
fun方法执行：0
fun方法执行：1
fun方法执行：2
fun方法执行：3
fun方法执行：4
fun方法执行：5
fun方法执行：6
fun方法执行：7
fun方法执行：8
fun方法执行：9
fun方法执行：10
fun方法执行：11
fun方法执行：12
fun方法执行：13
fun方法执行：14
fun方法执行：15
fun方法执行：16
fun方法执行：17
fun方法执行：18
fun方法执行：19
com.alibaba.csp.sentinel.slots.block.flow.FlowException
com.alibaba.csp.sentinel.slots.block.flow.FlowException
com.alibaba.csp.sentinel.slots.block.flow.FlowException
com.alibaba.csp.sentinel.slots.block.flow.FlowException
。。。

输出的日志

1648360038000|2022-03-27 13:47:18|hello|20|80|0|0|0|0|0|0时间戳：1648360038000
对应日期时间：2022-03-27 13:47:18
hello：资源名称
20：通过（pass）的请求数
80：阻塞（block）的请求数

使用示例 2

Test2

public class Test2 {public static void fun(int index){System.out.println("fun方法执行："+index);}public static void initFlowRule(){List<FlowRule> flowRules = new ArrayList<>();FlowRule flowRule = new FlowRule();flowRule.setResource("hello2");flowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);flowRule.setCount(20);flowRule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);flowRules.add(flowRule);FlowRuleManager.loadRules(flowRules);}public static void main(String[] args) {initFlowRule();for (int i=0;i<100;i++){if (SphO.entry("hello2")){try {fun(i);}catch (Exception e){System.out.println("业务异常，触发降级操作");} finally{SphO.exit();    //需与SphO.entry成对出现，否则会导致调用链记录异常，//抛出ErrorEntryFreeException` 异常}}else {System.out.println("服务限流，触发降级操作");}}System.exit(0);}
}

点击运行，控制台输出：

INFO: Sentinel log output type is: file
INFO: Sentinel log charset is: utf-8
INFO: Sentinel log base directory is: /Users/huli/logs/csp/
INFO: Sentinel log name use pid is: false
fun方法执行：0
fun方法执行：1
fun方法执行：2
fun方法执行：3
fun方法执行：4
fun方法执行：5
fun方法执行：6
fun方法执行：7
fun方法执行：8
fun方法执行：9
fun方法执行：10
fun方法执行：11
fun方法执行：12
fun方法执行：13
fun方法执行：14
fun方法执行：15
fun方法执行：16
fun方法执行：17
fun方法执行：18
fun方法执行：19
服务限流，触发降级操作
服务限流，触发降级操作
服务限流，触发降级操作
。。。

使用示例 3

Test3

public class Test3 {public static void fun(int index){System.out.println("fun方法执行："+index);}public static void initFlowRule(){List<FlowRule> flowRules = new ArrayList<>();FlowRule flowRule = new FlowRule();flowRule.setResource("hello3");flowRule.setGrade(RuleConstant.FLOW_GRADE_QPS);flowRule.setCount(20);flowRule.setControlBehavior(RuleConstant.CONTROL_BEHAVIOR_DEFAULT);flowRules.add(flowRule);FlowRuleManager.loadRules(flowRules);}public static void main(String[] args) {initFlowRule();for (int i=0;i<100;i++){try {AsyncEntry entry = SphU.asyncEntry("hello3");int finalI = i;CompletableFuture.runAsync(()->{ContextUtil.runOnContext(entry.getAsyncContext(),()->{try {fun(finalI);}catch (Exception e){e.printStackTrace();}finally {entry.exit();}});});}catch (Exception e){System.out.println("服务限流，触发降级操作");}}System.exit(0);}
}

点击运行，控制台输出：

INFO: Sentinel log output type is: file
INFO: Sentinel log charset is: utf-8
INFO: Sentinel log base directory is: /Users/huli/logs/csp/
INFO: Sentinel log name use pid is: false
fun方法执行：5
fun方法执行：6
fun方法执行：2
fun方法执行：0
fun方法执行：8
fun方法执行：1
fun方法执行：3
fun方法执行：10
fun方法执行：9
fun方法执行：7
fun方法执行：15
fun方法执行：4
fun方法执行：16
fun方法执行：14
fun方法执行：13
fun方法执行：12
fun方法执行：11
fun方法执行：19
fun方法执行：18
fun方法执行：17
服务限流，触发降级操作
服务限流，触发降级操作
服务限流，触发降级操作
。。。

sentinel 使用示例相关推荐

python连接redis哨兵_Python redis.sentinel方法代码示例
本文整理汇总了Python中redis.sentinel方法的典型用法代码示例.如果您正苦于以下问题:Python redis.sentinel方法的具体用法?Python redis.sentine ...
微服务限流Sentinel讲解（五）
授权规则可以对请求方来源做判断和控制. 4.1.授权规则 4.1.1.基本规则授权规则可以对调用方的来源做控制,有白名单和黑名单两种方式. 白名单:来源(origin)在白名单内的调用者允许访问黑 ...
Redis 哨兵Sentinel 文档
Redis 的 Sentinel 系统用于管理多个 Redis 服务器(instance), 该系统执行以下三个任务: 监控(Monitoring): Sentinel 会不断地检查你的主服务器和从服 ...
Sentinel（十九）之主流框架的适配
转载自主流框架的适配注:适配模块仅提供相应适配功能,若希望接入 Sentinel 控制台,请务必参考 Sentinel 控制台文档. 云原生微服务体系 Spring Cloud Spring C ...
Redis Sentinel
2019独角兽企业重金招聘Python工程师标准>>> Redis Sentinel Documentation Redis 的 Sentinel 系统用于管理多个 Redis 服务 ...
Redis 的 Sentinel哨兵介绍与源码分析（1）：初始化部分
http://www.redis.cn/topics/sentinel.html redis-6.0.8 本文是在官方中文文档的基础上进行的源码分析,其中包含完整的原文,并在此基础上,添加源码介绍. ...
redis 之sentinel配置
Redis 命令参考 » Sentinel 本文档翻译自: http://redis.io/topics/sentinel . Redis 的 Sentinel 系统用于管理多个 Redis 服务器( ...
Sentinel 为 RocketMQ 服务保驾护航
在 Apache RocketMQ 中,当消费者去消费消息的时候,无论是通过 pull 的方式还是 push 的方式,都可能会出现大批量的消息突刺.如果此时要处理所有消息,很可能会导致系统负载过高,影 ...
Sentinel微服务流量控制熔断降级及稳定性监控IO框架
目录 Sentinel 介绍 Sentinel 的历史 Sentinel 基本概念资源规则 Sentinel 功能和设计理念流量控制熔断降级系统负载保护 Sentinel 是如何工作的快速 ...

sentinel 使用示例

sentinel 使用示例

相关类与接口

使用示例

使用示例 2

使用示例 3

sentinel 使用示例相关推荐

最新文章

热门文章