java每秒限流_java限流工具类

约定不等于承诺〃 2022-11-08 06:13 108阅读 0赞

代码

import com.google.common.util.concurrent.RateLimiter;

import java.util.concurrent.ConcurrentHashMap;

/\*\*

\* 限流工具类

\* @author ZhangShuzheng

\* @date 2018/8/13

\*/

public class RateLimiterManager \{

private static ConcurrentHashMap<String, RateLimiter> manager = new ConcurrentHashMap<>();

/\*\*

\* 限流

\* @param key 限流key

\* @param qps 频率：每秒返回锁次数

\*/

public static void getLock(String key, int qps) \{

ConcurrentHashMap.KeySetView<String, RateLimiter> keys = manager.keySet();

if (keys.contains(key)) \{

RateLimiter rateLimiter = manager.get(key);

rateLimiter.acquire();

\} else \{

manager.put(key, RateLimiter.create(qps));

\}

\}

\}

使用示例

public static void main(String\[\] args) \{

int count = 100;

ThreadFactory namedThreadFactory = new ThreadFactoryBuilder()

.setNameFormat("demo-pool-%d").build();

ExecutorService threadPoolExecutor = new ThreadPoolExecutor(5, 200,

0L, TimeUnit.MILLISECONDS,

new LinkedBlockingQueue<>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());

threadPoolExecutor.execute(() -> \{

for (int i = 0; i < count; i++) \{

RateLimiterManager.getLock("key1", 10);

System.out.println("111111111111111111111111");

\}

\});

threadPoolExecutor.execute(() -> \{

for (int i = 0; i < count; i++) \{

RateLimiterManager.getLock("key2", 1);

System.out.println("222222222222222222222222");

\}

\});

\}

输出结果

222222222222222222222222

111111111111111111111111

111111111111111111111111

111111111111111111111111

111111111111111111111111

111111111111111111111111

111111111111111111111111

111111111111111111111111

111111111111111111111111

111111111111111111111111

222222222222222222222222

111111111111111111111111

111111111111111111111111

111111111111111111111111

111111111111111111111111

111111111111111111111111

111111111111111111111111

111111111111111111111111

111111111111111111111111

发表评论取消回复

表情：

评论列表（有 0 条评论，108人围观）

还没有评论，来说两句吧...

相关阅读

相关限流是什么？怎么限流？

实现相对固定窗⼝来说⽐较复杂，限流效果和你的滑动单位有关，过大的时间窗口可能导致无法及时处理突发流量，而过小的时间窗口可能导致频繁地滑动窗口和重置计数器，增加系统的开销。...

古城微笑少年丶/ 2024年04月20日 08:01/ 0 赞/ 15 阅读

相关分布式限流方案（gateway限流，redis+lua实现限流，nginx限流）

分布式限流方案（gateway限流，redis+lua实现限流，nginx限流） [终端研发部][Link 1] ![18cf3b89dc4df11da03d4a54b

我不是女神ヾ/ 2023年09月23日 20:12/ 0 赞/ 110 阅读

相关 Java限流之 —— Nginx限流

前言在之前的篇章中，我们谈到了限流的解决方案之一，使用网关进行限流的解决方案，而在众多的网关中，Nginx作为一款高性能、轻量级的组件，也提供了强大的可以配置的限流功能

深藏阁楼爱情的钟/ 2022年12月08日 15:31/ 0 赞/ 186 阅读

相关【限流保护】Springboot接口限流

> 公众号上线啦！ > 搜一搜【国服冰】 > 使命：尽自己所能给自学后端开发的小伙伴提供一个少有弯路的平台 > 回复：国服冰，即可领取我为大家准备的资料，里面包含整

ゝ一纸荒年。/ 2022年11月12日 13:48/ 0 赞/ 193 阅读

相关 java每秒限流_java限流工具类

代码 import com.google.common.util.concurrent.RateLimiter; import java.util.concurrent.C

约定不等于承诺〃/ 2022年11月08日 06:13/ 0 赞/ 109 阅读

相关 java接口限流

系统在设计之初就会有一个预估容量，长时间超过系统能承受的TPS/QPS阈值，系统可能会被压垮，最终导致整个服务不够用。为了避免这种情况，我们就需要对接口请求进行限流。

╰半橙微兮°/ 2022年06月01日 00:41/ 0 赞/ 266 阅读

相关 Java限流策略

概要在大数据量高并发访问时，经常会出现服务或接口面对暴涨的请求而不可用的情况，甚至引发连锁反映导致整个系统崩溃。此时你需要使用的技术手段之一就是限流，当请求达到一定的并

﹏ヽ暗。殇╰゛Y/ 2022年05月28日 07:29/ 0 赞/ 141 阅读

相关 java实现系统限流及IP限流

Java 对IP请求进行限流. 高并发系统下, 有三把利器缓存降级限流. 缓存: 将常用数据缓存起来, 减少数据库或者磁盘IO 降级: 保护核心系统,

电玩女神/ 2022年05月08日 12:54/ 0 赞/ 250 阅读

相关 Redis 简单限流、漏斗限流

简单限流 ![20190322144616896.png][] ![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_

以你之姓@/ 2022年03月01日 11:48/ 0 赞/ 404 阅读

相关限流，单机，分布式限流

总结：解决网站的高访问量，有三大利器，缓存，降级，限流，我这里讲解一下常用的几种限流手段。单机，有型号量，令牌通，漏桶，分布

矫情吗；*/ 2022年01月05日 23:09/ 0 赞/ 282 阅读