当前位置: 首页 > news >正文

使用redis中的zset实现滑动窗口限流

使用redis和zset实现滑动窗口限流

文章目录

  • 使用redis和zset实现滑动窗口限流
    • Zset
      • **初始化一个ZSet**:其中包含所有用户的ID和时间戳。
      • **添加元素到ZSet**:当用户发起请求时,将当前时间戳和用户ID作为元素添加到ZSet中。
      • **删除过期的元素**:为了保持滑动窗口的大小,需要删除超出时间窗口范围的元素。例如,如果滑动窗口的大小为60秒,那么需要删除60秒之前添加的元素。
      • **检查是否超过限制**:在添加新元素后,检查ZSet的大小是否超过限制。如果超过限制,则拒绝请求。
      • 拓展补充

Zset

Redis的ZSet(有序集合)可以很好地用来实现滑动窗口限流。滑动窗口限流是一种常见的流量控制方法,它限制了在一定时间窗口内的请求数量。下面是使用Redis ZSet实现滑动窗口限流的一个简单示例:

初始化一个ZSet:其中包含所有用户的ID和时间戳。

ZSet<String> zset = redisTemplate.opsForZSet().create("rateLimiter");

添加元素到ZSet:当用户发起请求时,将当前时间戳和用户ID作为元素添加到ZSet中。

long currentTimeMillis = System.currentTimeMillis();
String userId = "user1";
redisTemplate.opsForZSet().add("rateLimiter", userId, currentTimeMillis);

删除过期的元素:为了保持滑动窗口的大小,需要删除超出时间窗口范围的元素。例如,如果滑动窗口的大小为60秒,那么需要删除60秒之前添加的元素。

long windowSizeInSeconds = 60;
long currentTimeMillis = System.currentTimeMillis();
// 获取ZSet中所有元素
List<ZSetElement<String>> elements = redisTemplate.opsForZSet().reverseRangeWithScores("rateLimiter", 0, -1);
for (ZSetElement<String> element : elements) {long elementTimestamp = element.getScore();if (currentTimeMillis - elementTimestamp > windowSizeInSeconds * 1000) {redisTemplate.opsForZSet().remove("rateLimiter", element.getValue());}
}

检查是否超过限制:在添加新元素后,检查ZSet的大小是否超过限制。如果超过限制,则拒绝请求。

int limit = 100; // 每分钟的请求限制
long size = redisTemplate.opsForZSet().size("rateLimiter");
if (size >= limit) {// 超过限制,拒绝请求...
}

注意,以上代码是基于Java的Spring Data Redis实现,如果你使用其他语言的Redis客户端,代码可能会有所不同,但基本的思路是相同的。此外,这个简单的实现没有考虑分布式环境下的限流,这需要额外的同步机制。

拓展补充

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;@Component
public class ApiCallCounter {private static final String API_CALLS = "api_calls:";@Autowiredprivate RedisTemplate<String, String> redisTemplate;public void incrementApiCallCount(String apiName) {String key = API_CALLS + apiName + ":current";redisTemplate.opsForValue().increment(key);}
}

在上述代码中,我们定义了一个ApiCallCounter类,用于计数接口调用量。当接口被调用时,我们使用incrementApiCallCount方法增加计数。该方法使用RedisTemplateopsForValue().increment方法对指定键进行递增操作。我们使用一个包含API名称和时间戳的键来存储每分钟的调用量。例如,如果API名称为exampleApi并且当前时间是2023年7月19日10点05分,则键将是api_calls:exampleApi:current:202307191005

相关文章:

使用redis中的zset实现滑动窗口限流

使用redis和zset实现滑动窗口限流 文章目录 使用redis和zset实现滑动窗口限流Zset**初始化一个ZSet**&#xff1a;其中包含所有用户的ID和时间戳。**添加元素到ZSet**&#xff1a;当用户发起请求时&#xff0c;将当前时间戳和用户ID作为元素添加到ZSet中。**删除过期的元素**&a…...

Linux下C语言使用 netlink sockets与内核模块通信

netlink简介 Netlink套接字是用以实现用户进程与内核进程通信的一种特殊的进程间通信(IPC) ,也是网络应用程序与内核通信的最常用的接口。在Linux标准内核中&#xff0c;系统默认集成了很多netlink实例&#xff0c;比如日志上报、路由系统等&#xff0c;netlink消息是双向的&a…...

excel中的引用与查找函数篇3

1、INDEX(array,row_num,[col_num])&#xff1a;获取指定范围中指定行号和列号对应的数据 index(查询范围,行号,列号) 行号和列号是相对选中查询范围来写的&#xff1a;分别把第二行第三列的数据和第四行第二列的数据查找出来。 数据是单行或单列&#xff0c;后面只需要给一个参…...

【Linux学习笔记】 - 常用指令学习及其验证(下)

前言&#xff1a;本文延续上一篇文章【Linux学习笔记】 - 常用指令学习及其验证&#xff08;上&#xff09;对常用的指令进行介绍和验证。 一、mv指令 &#xff08;1&#xff09;功能&#xff1a;用来移动文件或者将文件改名 &#xff08;2&#xff09;语法及验证&#xff1a…...

面试官:请说说flex布局_番茄出品.md

面试官&#xff1a;请说说flex布局_番茄出品.md start 依然记得当初学习 flex 布局时&#xff0c;用 flex 布局&#xff1a;画麻将。一筒到九筒&#xff0c;应有尽有。但是光和面试官说&#xff0c;我用 flex 布局画过麻将&#xff0c;并没有什么用。面试官问你一个语法&…...

ChatGLM DeepSpeed/P-Tuning v2 调参

之前尝试了基于ChatGLM-6B使用LoRA进行参数高效微调,本文给大家分享使用DeepSpeed和P-Tuning v2对ChatGLM-6B进行微调,相关代码放置在GitHub上面:llm-action。 ChatGLM-6B简介 ChatGLM-6B相关的简介请查看之前的文章,这里不再赘述。 P-Tuning v2简介 P-Tuning是一种较新…...

Leetcode每日一题:打家劫舍系列Ⅰ、Ⅱ、Ⅲ、Ⅳ(2023.9.16~2023.9.19 C++)

由于之前写过打家劫舍系列&#xff0c;这里直接弄个合集&#xff0c;后面应该还有个iv。 目录 198. 打家劫舍 213. 打家劫舍 II 337. 打家劫舍 III 2560. 打家劫舍 IV 198. 打家劫舍 题目描述&#xff1a; 你是一个专业的小偷&#xff0c;计划偷窃沿街的房屋。每间房内都…...

容易对一个异性产生依赖感怎么办?

歌词&#xff1a;爱总让人伤心&#xff0c;但你要学会去明白~ &#x1f442; Photograph - Ed Sheeran - 单曲 - 网易云音乐 目录 &#x1f33c;前言 &#x1f61f;一、对另一个人的依赖感&#xff0c;本质是什么&#xff1f; &#x1f60a;二、如何减少对伴侣的依赖感&am…...

Windows10/11无线网卡WIFI驱动详细下载安装教程

官网下载WIFI驱动 《intel官网》 找到下载Windows 10 and Windows 11* WiFi package drivers 查看详细信息 下载对应操作系统的WIFI驱动 安装驱动&#xff0c;然后重启电脑即可。...

面向面试知识--Lottery项目

面向面试知识–Lottery项目 1.设计模式 为什么需要设计模式&#xff1f; &#xff08;设计模式是什么&#xff1f;优点有哪些&#xff1f;&#xff09; 设计模式是一套经过验证的有效的软件开发指导思想/解决方案&#xff1b;提高代码的可重用性和可维护性&#xff1b;提高团…...

SpringBoot接口中如何直接返回图片数据

SpringBoot接口中如何直接返回图片数据 目录 接口直接返回图片数据 起因 类似这种 根据个人经验 优雅的实现图片返回 接口直接返回图片数据 起因 最近在做涉及到分享推广的业务&#xff0c;需要由业务员分享二维码进入推广页面&#xff0c;由于是新项目&#xff0c;前期…...

c语言进阶部分详解(指针进阶1)

大家好&#xff01;指针的初阶内容我已经写好&#xff0c;可移步至我的文章&#xff1a;c语言进阶部分详解&#xff08;指针初阶&#xff09;_总之就是非常唔姆的博客-CSDN博客 基本内容我便不再赘述&#xff0c;直接带大家进入进阶内容&#xff1a; 目录 一.字符指针 1.讲解…...

计算机竞赛 大数据商城人流数据分析与可视化 - python 大数据分析

0 前言 &#x1f525; 优质竞赛项目系列&#xff0c;今天要分享的是 &#x1f6a9; 基于大数据的基站数据分析与可视化 该项目较为新颖&#xff0c;适合作为竞赛课题方向&#xff0c;学长非常推荐&#xff01; &#x1f947;学长这里给一个题目综合评分(每项满分5分) 难度…...

各种电机驱动原理

步进电机 步进电机参考资料 野火官方文档 步进电机驱动原理 上面参考文档中有的内容就不写了&#xff0c;写一下我自己的总结吧。 说明&#xff1a; 电机驱动器输入信号有电机转动方向信号DIR&#xff0c;电机转速信号PWM&#xff0c;电机使能信号EN&#xff1b;电机驱动器…...

人脸图像数据增强

为什么要做数据增强 在计算机视觉相关任务中&#xff0c;数据增强&#xff08;Data Augmentation&#xff09;是一种常用的技术&#xff0c;用于扩展训练数据集的多样性。它包括对原始图像进行一系列随机或有规律的变换&#xff0c;以生成新的训练样本。数据增强的主要目的是增…...

Android 查看按键信息的常用命令详解

Android 查看按键信息的常用命令详解 文章目录 Android 查看按键信息的常用命令详解一、主要命令&#xff1a;二、命令详解1、getevent2、getevent -l3、dumsys input4、cat XXX.kl4、cat /dev/input/eventX5、getevent 其他命令6、input keyevent XX 三、简单示例修改四、总结…...

【Java 基础篇】Properties 结合集合类的使用详解

Java 中的 Properties 类是一个常见的用于管理配置信息的工具&#xff0c;它可以被看作是一种键值对的集合。虽然 Properties 通常用于处理配置文件&#xff0c;但它实际上也可以作为通用的 Map 集合来使用。在本文中&#xff0c;我们将详细探讨如何使用 Properties 作为 Map 集…...

数字孪生体标准编程

数字孪生体标准 括ISO TC184/SC4正在制定数字孪生制造标准ISO 23247、ISO/IEC JTC1/AG11正在推动数字孪生体标准、IEEE P2806正在做有关“数字表达”的标准。赢家通吃的标准战 卡尔夏皮罗和哈尔范里安撰写了《信息规则&#xff1a;网络经济战略指南》&#xff08;Information R…...

力扣 -- 394. 字符串解码

解题方法&#xff1a; 参考代码&#xff1a; class Solution{ public:string decodeString(string s){stack<string> sst;stack<int> dst;//防止字符串栈为空的时候再追加字符串到栈顶元素sst.push("");int n s.size();int i 0;while(i<n)//最好不…...

面试官:什么是虚拟DOM?如何实现一个虚拟DOM?说说你的思路

&#x1f3ac; 岸边的风&#xff1a;个人主页 &#x1f525; 个人专栏 :《 VUE 》 《 javaScript 》 ⛺️ 生活的理想&#xff0c;就是为了理想的生活 ! 目录 一、什么是虚拟DOM 二、为什么需要虚拟DOM 三、如何实现虚拟DOM 小结 一、什么是虚拟DOM 虚拟 DOM &#xff08…...

从源码细节看muduo为何比libevent2快70%:一次4096字节读取限制引发的性能思考

从缓冲区设计揭秘高性能网络库的优化哲学 在构建高并发服务器时&#xff0c;网络库的性能差异往往源于看似微小的设计决策。当两个知名网络库在相同硬件条件下出现70%的吞吐量差距时&#xff0c;这个数字背后隐藏的是对系统调用、内存管理和数据流控制的深刻理解差异。本文将从…...

手把手复现1G通话:用Python模拟FM调制、FSK信令与FDMA多用户通信

手把手复现1G通话&#xff1a;用Python模拟FM调制、FSK信令与FDMA多用户通信 在移动通信的演进史中&#xff0c;1G系统如同数字时代的罗塞塔石碑&#xff0c;用模拟信号承载了人类首次无线对话的自由。今天我们将穿越回1983年摩托罗拉DynaTAC 8000X面世的年代&#xff0c;用Py…...

电子设备散热风扇控制技术详解与应用

1. 电子设备散热风扇控制技术概述现代电子设备正朝着小型化、高性能方向发展&#xff0c;随之而来的散热问题日益突出。以笔记本电脑为例&#xff0c;其厚度从十年前的30mm缩减到如今的15mm以下&#xff0c;但CPU功耗却从15W提升到45W甚至更高。这种"体积缩小、功耗增加&q…...

从DRM驱动看mmap:图解内存分配与映射的‘时机’与‘方式’如何影响性能

从DRM驱动看mmap&#xff1a;图解内存分配与映射的‘时机’与‘方式’如何影响性能 在图形驱动开发领域&#xff0c;内存管理始终是性能优化的关键战场。当你在调试一块高端显卡的DRM&#xff08;Direct Rendering Manager&#xff09;驱动时&#xff0c;是否曾遇到过这样的困惑…...

FanControl终极指南:如何5分钟掌控Windows电脑风扇噪音与散热

FanControl终极指南&#xff1a;如何5分钟掌控Windows电脑风扇噪音与散热 【免费下载链接】FanControl.Releases This is the release repository for Fan Control, a highly customizable fan controlling software for Windows. 项目地址: https://gitcode.com/GitHub_Tren…...

从皮肤色素基因到育种选择:Fst值在动植物研究中的实战解读指南

从皮肤色素基因到育种选择&#xff1a;Fst值在动植物研究中的实战解读指南 当我们在玉米田里观察不同品种的株高差异&#xff0c;或比较藏猪与大白猪的肉质特性时&#xff0c;本质上都在探索同一个问题&#xff1a;群体间的遗传分化如何塑造了这些表型多样性&#xff1f;Fst值作…...

排查华为USG防火墙上不了网?先检查这5个配置点(附真实配置案例)

华为USG防火墙上网故障排查实战指南 当内网用户突然无法访问互联网时&#xff0c;作为运维人员往往会面临巨大的压力。华为USG防火墙作为企业网络的核心安全设备&#xff0c;其配置的每一个细节都可能成为网络连通性的关键。本文将从一个真实的故障排查案例出发&#xff0c;带您…...

《线性代数思维》:以代码和案例开启线性代数实用学习之旅!

《线性代数思维》介绍《线性代数思维》以代码为先导、以案例为基础&#xff0c;介绍了线性代数中最常用的概念&#xff0c;专为那些想理解并应用这些概念&#xff0c;而非仅抽象学习的读者设计。每一章都围绕一个现实世界的问题展开&#xff0c;如模拟网络流量、仿真鸟群飞行或…...

Zutilo:为Zotero研究者量身打造的高效文献管理增强插件

Zutilo&#xff1a;为Zotero研究者量身打造的高效文献管理增强插件 【免费下载链接】Zutilo Zotero plugin providing some additional editing features 项目地址: https://gitcode.com/gh_mirrors/zu/Zutilo 作为一名Zotero用户&#xff0c;你是否曾为批量管理标签而烦…...

用STM32F103C8点亮你的第一块LED点阵屏:HUB08接口F3.75单元板保姆级驱动教程

从零玩转STM32驱动LED点阵屏&#xff1a;HUB08接口实战指南 第一次拿到LED点阵屏时&#xff0c;看着密密麻麻的引脚和陌生的HUB08接口&#xff0c;确实容易让人望而生畏。但别担心&#xff0c;本文将带你用最常见的STM32F103C8T6开发板&#xff0c;一步步点亮这块32x64双色点阵…...