废话

其实大部分人都是苦于不知道用啥工具去做限流，如果自己写一个限流逻辑，似乎又比较low，所以，当看到我这个标题的时候，其实本章大概率是不需要再去看了。

建议直接看官方文档吧，写得挺清楚的：https://github.com/alibaba/Sentinel

我这里就做一个最简单的限流示例，规则是每秒1次请求，超出1次就返回请求过于频繁的提示。

概述

Sentinel支持两种模式，1种是简单的导个包，跑限流策略，另外一种是可以安装一个他提供的管理后台，提供了不少比较丰富的（花里胡哨）的功能，我这里图省事，搞第一种就好。

有些人会比较关心另外一个问题，就是集群限流功能，大一点的业务量不可能只有一个Gateway，Gateway之间的内存肯定也无法共享，如果是接入Redis做计数，肯定也会有资源、时间成本等问题。我个人的看法，解决集群限流的问题可以从两个方面着手：

（1）统一计数中心，例如搞个Redis做计数，范围时间内超了就拒绝，也就是会面临时间、资源成本。当然了，Sentinel提供了这种能力，秉承着无需重复造轮子的初衷，我选择相信它能比我自己处理的要好。

（2）负载均衡策略调整，如Nginx可支持根据来源IP地址做负载均衡规则，确保每一个IP的请求都指向同一个Gateway，这样也有风险，当你运气实在是不好的时候，就可能出现某个Gateway忙不过来，而某个Gateway却无人问津。

现实总是这样，很难有完美的东西，总是会在不同的选择之间妥协。

开搞

导包

        <dependency><groupId>com.alibaba.csp</groupId><artifactId>sentinel-core</artifactId><version>1.8.0</version></dependency>

最简单的示例

    @Overridepublic void run(String... args) throws Exception {log.info("初始化");initFlowRules();while (true) {Entry entry = null;try {entry = SphU.entry("HelloWorld");/*您的业务逻辑 - 开始*/log.info("hello world");/*您的业务逻辑 - 结束*/} catch (BlockException e1) {/*流控逻辑处理 - 开始*/log.info("被限流了");/*流控逻辑处理 - 结束*/} 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(1);rules.add(rule);FlowRuleManager.loadRules(rules);}

这个run等同于main，运行没错的话，大概率就是没秒打印1个hello world，以及n个被限流了，如果把“被限流了”注释掉，就会每秒打印一个hello world。

真正用上的时候，另起一个Gateway过滤器，把HelloWorld换成你的用户Token或者其他用于限频的凭证即可。