Redis原子计数器incr,防止并发请求

一、前言

在一些对高并发请求有限制的系统或者功能里,比如说秒杀活动,或者一些网站返回的当前用户过多,请稍后尝试。这些都是通过对同一时刻请求数量进行了限制,一般用作对后台系统的保护,防止系统因为过大的流量冲击而崩溃。对于系统崩溃带来的后果,显然还是拒绝一部分请求更能被维护者所接受。  而在各种限流中,除了系统自身设计的带锁机制的计数器外,利用Redis实现显然是一种既高效安全又便捷方便的方式。

二、incr命令

Redis Incr 命令将 key 中储存的数字值增一。  如果 key 不存在,那么 key 的值会先被初始化为 0 ,然后再执行 INCR 操作。  如果值包含错误的类型,或字符串类型的值不能表示为数字,那么返回一个错误。  本操作的值限制在 64 位(bit)有符号数字表示之内。  示例:

代码语言:javascript

复制

127.0.0.1:6379> set num 10
OK
127.0.0.1:6379> incr num
(integer) 11
127.0.0.1:6379> get num    # 数字值在 Redis 中以字符串的形式保存
"11"

注意: 由于redis并没有一个明确的类型来表示整型数据,所以这个操作是一个字符串操作。  执行这个操作的时候,key对应存储的字符串被解析为10进制的64位有符号整型数据。  事实上,Redis 内部采用整数形式(Integer representation)来存储对应的整数值,所以对该类字符串值实际上是用整数保存,也就不存在存储整数的字符串表示(String representation)所带来的额外消耗。

三、使用场景

1.计数器 使用思路是:每次有相关操作的时候,就向Redis服务器发送一个incr命令。  例如这样一个场景:我们有一个web应用,我们想记录每个用户每天访问这个网站的次数。  web应用只需要通过拼接用户id和代表当前时间的字符串作为key,每次用户访问这个页面的时候对这个key执行一下incr命令。

这个场景可以有很多种扩展方法:  通过结合使用INCR和EXPIRE命令,可以实现一个只记录用户在指定间隔时间内的访问次数的计数器  客户端可以通过GETSET命令获取当前计数器的值并且重置为0  通过类似于DECR或者INCRBY等原子递增/递减的命令,可以根据用户的操作来增加或者减少某些值 比如在线游戏,需要对用户的游戏分数进行实时控制,分数可能增加也可能减少。

2.限速器 限速器是一种可以限制某些操作执行速率的特殊场景。  传统的例子就是限制某个公共api的请求数目。  假设我们要解决如下问题:限制某个api每秒每个ip的请求次数不超过10次。  我们可以通过incr命令来实现两种方法解决这个问题。

四、流量控制之java实现

这里我们将在java中使用redis-incr的特性来构建一个1分钟内只允许 请求100次的控制代码,key代表在redis内存放的被控制的键值。

代码语言:javascript

复制

public static boolean flowControl(String key){//最大允许100int max = 100;long total = 1L;try {if (jedisInstance.get(key) == null) {//jedisInstance是Jedis连接实例,可以使单链接也可以使用链接池获取,实现方式请参考之前的blog内容//如果redis目前没有这个key,创建并赋予0,有效时间为60sjedisInstance.setex(key, 60, "0");} else {//获取加1后的值total = jedisInstance.incr(redisKey).longValue();//Redis TTL命令以秒为单位返回key的剩余过期时间。当key不存在时,返回-2。当key存在但没有设置剩余生存时间时,返回-1。否则,以秒为单位,返回key的剩余生存时间。if (jedisInstance.ttl(redisKey).longValue() == -1L){//为给定key设置生存时间,当key过期时(生存时间为0),它会被自动删除。jedisInstance.expire(redisKey, 60);}}} catch (Exception e) {logger.error("流量控制组件:执行计数操作失败,无法执行计数");}long keytotaltransations = max;//判断是否已超过最大值,超过则返回falseif (total > keytotaltransations) {return false;}return true;}

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

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

相关文章

Twitter API 使用教程:入门到实践

Twitter API为开发者提供了丰富的接口,用于访问Twitter上的公开数据和实现特定功能。从获取推文到用户认证,Twitter API在数据挖掘、社交分析和应用开发中扮演着重要角色。 关键词 Twitter API, 开发者指南,社交媒体,数据访问 …

elementary os 8 2024年07月新动态

具体信息请登录官网查询 **OS 7更新** Photos 8已经作为Flatpak应用发布到AppCenter。这意味着你可以通过从AppCenter安装Flatpak版本来继续接收Photos的更新,即使在旧版本的elementary OS上,而且Photos现在也很容易为那些运行除elementary OS之外的Lin…

Java中的Set系列集合超详解

Set List是有序集合的根接口,Set是无序集合的根接口,无序也就意味着元素不重复。更严格地说,Set集合不包含一对元素e1和e2 ,使得e1.equals(e2) ,并且最多一个空元素。   使用Set存储的特点与List相反:元素…

腾讯云如何设置二级域名?

什么是二级域名? 例如我已申请的域名为: test.com //顶级域名 现在我开发的应用要部署到二级域名: blog.test.com 1、打开腾讯云控制台的我的域名,然后点击解析 2、在我的解析页面点击添加记录,然后需注意红色方框处…

生物素标记的柚皮苷探针;Biotin-Naringin

生物素标记的柚皮苷探针(Biotin-Naringin)是一种结合了生物素(Biotin)和柚皮苷(Naringin)特性的化合物,它在有机合成及药物化学技术领域具有重要意义。以下是对该探针的详细解析: 一…

秋招Java后端开发冲刺——Mybatis

一、基本知识 1. 介绍 MyBatis 是 Apache 的一个开源项目,它封装了 JDBC,使开发者只需要关注 SQL 语句本身,而不需要再进行繁琐的 JDBC 编码。MyBatis 可以使用简单的 XML 或注解来配置和映射原生类型、接口和 Java POJO(Plain …

设计模式Base

设计模式是在软件开发过程中总结出来的一些经验,它们大多数都遵循一些基本原则: 单一职责原则(SRP):一个类应该只有一个引起它变化的原因。也就是说,一个类应该只有一个职责。开放封闭原则(OCP…

Everything搜索无法搜索到桌面的文件(无法检索C盘 或 特定路径的文件)

现象描述 在Everything搜索框中输入桌面已存在的文件或随便已知位置的文件,无法找到。 搜索时检索结果中明显缺少部分磁盘位置的,例如无法检索C盘,任意关键字搜索时结果中没有位于C盘的,无论怎样都搜不到C盘文件。 解决方法 在…

CentOS搭建FTP服务器教程

CentOS搭建FTP服务器教程 在互联网时代,文件传输是日常工作中不可或缺的一部分。FTP(文件传输协议)作为一种标准的网络协议,被广泛用于在互联网上传输文件。本文将详细介绍如何在CentOS系统上搭建FTP服务器,以便您能轻…

L1 Simple_ReAct_Agent

参考自https://www.deeplearning.ai/short-courses/ai-agents-in-langgraph,以下为代码的实现。 Basic ReAct Agent(manual action) import openai import re import httpx import os from dotenv import load_dotenv, find_dotenvOPENAI_API_KEY os.getenv(OPEN…

pip install .自己构建工程文件报错error: subprocess-exited-with-error解决办法

有时我们直接使用pip install xxx安装某个三方文件时候会发现安装不了,会报各种问题。 这时候我们只能通过下载源码自己手动编译。 等我们下好源码开始编译的时候又会出现很多问题。 下面就举一个栗子作为解决问题的思路: 比如我我想要安装diff-gaussian-rasterization,直…

python 66 个冷知识 0712

66个有趣的Python冷知识 字典合并 从Python 3.9开始,可以使用 | 操作符合并字典。 多继承 Python支持多继承,类可以继承多个父类。 ABC模块 abc 模块提供了定义抽象基类的工具。 泛型 typing 模块提供了泛型支持。 类型别名 使用 typing 模块可以创建…

DP讨论——设计模式怎么来的?

眼中没有设计模式,代码里就找不到设计模式 几年前还在搞c开发,觉得设计模式离我太遥远,而且觉得设计模式太复杂太高大上,比较恐惧。 后来接触了oopc(接触了rtthread整个都是oopc实现的rtos),再…

LTE系统OFDM符号持续时间计算

LTE系统OFDM符号持续时间计算 给定等式:7个OFDM符号的持续时间 0.5ms(1个slot) - 160Ts - 6144*Ts 其中: 1个slot 0.5msTs是LTE系统的基本时间单位 步骤分解 理解时间资源结构: 1个无线帧 10ms1个子帧 1ms 2个slot1个slot 0.5ms1个…

Spring Boot Vue 毕设系统讲解 9 【Spark】

SuppressWarnings("serial") Configuration ConfigurationProperties(prefix"spark") public class SparkConfig implements Serializable {//spark的安装地址private String sparkHome ".";//应用的名称private String appName "mySpar…

图像识别和目标检测在超市电子秤上的应用

目录 前言深度学习的目标检测图像识别技术视觉秤的优势其他应用场景中的技术应用未来展望 前言 随着科技的不断发展,电子秤在生鲜超市中的应用也在不断升级。传统的电子秤需要打秤人员手动输入秤码,这不仅耗时费力,还需要大量的培训以记住各…

Rust编程-泛型、Trait和生命周期

泛型: 泛型是类型编程中的一种工具。本质上是类型的变量,目的是提高代码的复用。泛型是 具体类型或其他属性的抽象替代。 为了复用,我们会使用函数将功能封装,同样,泛型也是为了复用,只不过是为了类型的复用…

工业大数据是什么?应用工业大数据时面临哪些挑战?

在当今快速发展的工业领域,大数据已成为推动企业转型升级的核心动力。工业大数据,以其独特的价值和潜力,正逐渐改变着传统的生产、管理和决策模式。然而,伴随着大数据的快速发展,一系列挑战也随之浮现。本文将深入探讨…

算法日常练习

对于这个题&#xff0c;如何处理同一个方向的问题&#xff0c;且对于同一组的如果间隔太大如何实现离散化 #include<bits/stdc.h> using namespace std;#define int long long typedef long long ll; map<pair<int,int>,vector<pair<ll,ll>>> mp…

关于机械键盘的购买,该怎么选择?

一.关于轴体的选择。 1.青轴&#xff1a;青轴是机械键盘最有段落感的轴&#xff0c;声音比较大&#xff0c;以吵死人别人著称。有人将其比喻为Cherry的春天&#xff0c;爽快清脆的段落感如春天般舒畅。适合在宿舍、咖啡厅&#xff0c;图书馆使用。&#xff08;我装的 &#xf…