Java实现限流算法

下面是一个使用Java实现的令牌桶算法的例子:

import java.util.concurrent.atomic.AtomicLong;public class RateLimiter {private final long capacity; // 令牌桶容量private final long rate; // 令牌生成速率private AtomicLong tokens; // 当前令牌数量private long lastRefillTime; // 上次令牌生成时间public RateLimiter(long capacity, long rate) {this.capacity = capacity;this.rate = rate;this.tokens = new AtomicLong(0);this.lastRefillTime = System.currentTimeMillis();}public boolean allowRequest() {refillTokens();return tokens.getAndDecrement() > 0;}private void refillTokens() {long currentTime = System.currentTimeMillis();long elapsedTime = currentTime - lastRefillTime;long newTokens = elapsedTime * rate / 1000;if (newTokens > 0) {tokens.set(Math.min(tokens.get() + newTokens, capacity));lastRefillTime = currentTime;}}
}

使用示例:

public class Main {public static void main(String[] args) {RateLimiter rateLimiter = new RateLimiter(10, 2); // 每秒生成2个令牌,令牌桶容量为10for (int i = 0; i < 20; i++) {if (rateLimiter.allowRequest()) {System.out.println("Request " + (i + 1) + ": Allowed");} else {System.out.println("Request " + (i + 1) + ": Denied");}try {Thread.sleep(500);} catch (InterruptedException e) {e.printStackTrace();}}}
}

这个例子中,RateLimiter类表示令牌桶,构造函数参数中的capacity表示令牌桶容量,rate表示令牌生成速率(每秒生成令牌数量)。tokens是一个原子长整型变量,用于表示当前令牌桶中的令牌数量。lastRefillTime是一个长整型变量,用于记录上次令牌生成时间。

allowRequest()方法用于判断当前是否允许发送请求。在每次调用allowRequest()方法之前,会先调用refillTokens()方法来生成令牌。refillTokens()方法

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.hqwc.cn/news/288763.html

如若内容造成侵权/违法违规/事实不符,请联系编程知识网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

RAII智能指针

RAII resource acquisition is initialization RAII是利用对象声明周期来控制程序资源的简单技术 在对象构造时获取资源&#xff0c;控制着对资源的访问使之在对象的生命周期内始终保持有效&#xff0c;最后在对象析构的时候释放资源。借此&#xff0c;我们实际上把管理一份资源…

2024Web自动化测试的技术框架和工具有哪些?

Web 自动化测试是一种自动化测试方式&#xff0c;旨在模拟人工操作对 Web 应用程序进行测试。这种测试方式可以提高测试效率和测试精度&#xff0c;减少人工测试的工作量和测试成本。在 Web 自动化测试中&#xff0c;技术框架和工具起着至关重要的作用。本文将介绍几种常见的 W…

VM安装Sonoma【笔记】

VMware Workstation安装MacOS Sonoma 1、配置虚拟机&#xff0c;根据系统性能调整参数&#xff1b; 2、先不焦急启动虚拟机&#xff0c;打开虚拟机存储目录&#xff0c;以文本方式打开.vmx文件&#xff08;这里以Sonoma.vmx为例&#xff09;&#xff1b; 这里只针对Inter CP…

vue-springboot二手图书商城交易系统ij5dr

本系统依赖于MySQL数据库来储存信息&#xff0c;系统完成后&#xff0c;所有需要的数据都要从数据库中读取&#xff0c;这也意味着无论是插入、更新还是删除操作&#xff0c;只要对数据有改动的操作都需要与数据库交互&#xff0c;因此&#xff0c;系统的全部数据都要储存在数据…

C++相关闲碎记录(18)

1、strftime()的转换指示器 #include <locale> #include <chrono> #include <ctime> #include <iostream> #include <exception> #include <cstdlib> using namespace std;int main () {try {// query local time:auto now chrono::syste…

Python 多维数组详解(numpy)

文章目录 1 概述1.1 numpy 简介1.2 ndarray 简介 2 数组操作2.1 创建数组&#xff1a;array()2.2 裁切数组&#xff1a;切片2.3 拼接数组&#xff1a;concatenate()2.4 拆分数组&#xff1a;array_split()2.5 改变数组形状&#xff1a;reshape() 3 元素操作3.1 获取元素&#x…

飞天使-k8s知识点1-kubernetes架构简述

文章目录 名词功能要点 k8s核心要素CNCF 云原生框架简介k8s组建介绍 名词 CI 持续集成, 自动化构建和测试&#xff1a;通过使用自动化构建工具和自动化测试套件&#xff0c;持续集成可以帮助开发人员自动构建和测试他们的代码。这样可以快速检测到潜在的问题&#xff0c;并及早…

【QT】解决QTableView修改合并单元格内容无法修改到合并范围内的单元格

问题:修改合并单元格的内容 修改合并单元格的内容时,希望直接修改到合并范围内的单元格,Qt没有实现这个功能,需要自己写出 Delegate来实现 方案:Delegate class EditDelegate : public QStyledItemDelegate {public:EditDelegate(QTableView *view): tableView(view){}pu…

位操作符详解(C语言)

前言 C语言中的位操作符是用来对数据的二进制表示进行位级操作的运算符。这些操作符包括位与&#xff08;&&#xff09;、位或&#xff08;|&#xff09;、位异或&#xff08;^&#xff09;、位取反&#xff08;~&#xff09;&#xff0c;这些位操作符可以用来进行各种位级…

华为选择“力图生存”!国家队正式出手,外媒:鸿蒙将全面爆发

引言 在国际舞台上&#xff0c;国与国之间的关系错综复杂&#xff0c;舆论的力量也十分重要。近日&#xff0c;关于华为鸿蒙系统失去用户的预测成为热议的话题。这背后所面对的挑战和对抗也异常严峻。本文将解释鸿蒙系统的崛起与前景展望&#xff0c;揭示其中的机遇与挑战。 …

9ACL访问控制列表

为什么要有访问控制&#xff08;Access Control List&#xff09;&#xff1f; 因为我可能在局域网中提供了一些服务&#xff0c;我只希望合法的用户可以访问&#xff0c;其他非授权用户不能访问。 原理比较简单&#xff0c;通过对数据包里的信息做过滤&#xff0c;实现访问控…

《每天一分钟学习C语言·三》

1、 scanf的返回值由后面的参数决定scanf(“%d%d”,& a, &b); 如果a和b都被成功读入&#xff0c;那么scanf的返回值就是2如果只有a被成功读入&#xff0c;返回值为1如果a和b都未被成功读入&#xff0c;返回值为0 如果遇到错误或遇到end of file&#xff0c;返回值为EOF…