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

Redis的一些问题,解决并发的

项目通布隆过滤器:

布隆过滤器:
布隆过滤器是一种空间效率非常高的数据结构,用于快速判断一个元素是否可能存在于一个集合中。它由一个位数组(通常是长度为 m 的比特数组)和 k 个不同的哈希函数组成。当一个元素被加入集合时,通过 k 个哈希函数将该元素映射到位数组中的 k 个位置,并将这些位置的比特值设为 1。当需要查询一个元素是否在集合中时,同样通过 k 个哈希函数计算出位数组中的 k 个位置,并检查这些位置的比特值是否都为 1,如果有一个不为 1,则可以确定该元素肯定不在集合中,如果都为 1,则该元素可能存在于集合中。布隆过滤器具有以下特点:快速:查询一个元素的时间复杂度是 O(k),其中 k 是哈希函数的数量,通常很小。
空间效率高:相比于存储所有元素的集合,布隆过滤器需要的存储空间很小。
可能出现误判:当一个元素可能存在于集合中时,布隆过滤器会返回 "可能存在",但实际上可能并不存在;而当一个元素肯定不存在于集合中时,布隆过滤器会返回 "不存在",不存在误判。
布隆过滤器常用于缓存、数据库查询优化、网络爬虫的URL去重等场景,但需要注意的是,布隆过滤器一旦创建后,无法删除或修改其中的元素,因为删除或修改元素会影响其他元素的判断结果。

布隆过滤器和空值返回是两种常用的技术,用于缓解Redis的穿透问题。布隆过滤器可以用于快速检查某个键是否存在于Redis中,从而在缓存层面过滤掉一些不存在于Redis中的查询请求;而空值返回则是指在查询Redis中不存在的键时,直接返回一个空值,而不是去查询数据库,从而减少数据库压力。

基于布隆过滤器的缓解穿透问题:

在查询Redis之前,先使用布隆过滤器检查查询的键是否可能存在于Redis中。
如果布隆过滤器认为键不存在于Redis中,则直接返回一个预先设定的空值,而不进行实际的Redis查询。
如果布隆过滤器认为键可能存在于Redis中,则继续向Redis发起查询请求。
如果Redis返回的确实是空值,则在布隆过滤器中将该键标记为不存在,以便下一次查询时可以直接返回空值。
基于Redis构造分布式锁缓解优惠券秒杀问题:

使用Redis的SETNX命令来实现分布式锁,即尝试设置一个特定的键,如果该键不存在,则设置成功并获得锁,否则设置失败表示锁已被其他客户端获取。
在秒杀开始时,客户端请求获取优惠券时,先尝试获取分布式锁。
获取锁成功后,执行秒杀操作,即将优惠券数量减一,并将优惠券分发给用户。
执行完秒杀操作后,释放锁。
如果获取锁失败,则表示已经有其他客户端正在执行秒杀操作,当前客户端需要等待或放弃秒杀。
通过以上两种方法,可以在Redis中缓解穿透问题和秒杀问题,提高系统的稳定性和性能。

使用Redis+lua脚本构造分布式锁,缓解高并发缓解下的优惠卷超卖问题。

下面是一个使用Redis和Lua脚本构造分布式锁来缓解高并发下优惠券超卖问题的示例:

首先,在Redis中设置一个键来表示优惠券的库存数量。
当用户请求优惠券时,通过Lua脚本来进行原子性操作:
获取当前库存数量。
如果库存数量大于0,则将库存数量减1,并返回成功。
如果库存数量已经为0,则返回失败。
如果Lua脚本执行成功,则用户可以获得优惠券;否则,说明优惠券
已经售罄。
以下是一个Java代码示例:

java
import redis.clients.jedis.Jedis;

public class CouponService {
private static final String COUPON_KEY = “coupon_stock”;
private static final String LOCK_KEY = “coupon_lock”;
private static final String SCRIPT = "if redis.call(‘GET’, KEYS[1]) > ‘0’ then " +
"redis.call(‘DECR’, KEYS[1]) " +
"return 1 " +
"else " +
"return 0 " +
“end”;

public static void main(String[] args) {// 连接Redis数据库Jedis jedis = new Jedis("localhost");// 初始化优惠券库存jedis.set(COUPON_KEY, "100");// 模拟多个用户请求优惠券for (int i = 0; i < 150; i++) {new Thread(() -> {// 加锁String lock = jedis.set(LOCK_KEY, "LOCK", "NX", "EX", 5);if ("OK".equals(lock)) {// 执行Lua脚本Object result = jedis.eval(SCRIPT, 1, COUPON_KEY);if (result instanceof Long && (Long) result == 1) {System.out.println("Success: User " + Thread.currentThread().getId() + " got the coupon.");} else {System.out.println("Failed: Coupon sold out for user " + Thread.currentThread().getId());}// 释放锁jedis.del(LOCK_KEY);} else {System.out.println("Failed to acquire lock for user " + Thread.currentThread().getId());}}).start();}// 等待所有线程执行完毕try {Thread.sleep(6000);} catch (InterruptedException e) {e.printStackTrace();}// 打印最终库存数量System.out.println("Final coupon stock: " + jedis.get(COUPON_KEY));// 关闭Redis连接jedis.close();
}

}
在这个示例中,我们通过Redis的SET命令来尝试获取分布式锁,确保Lua脚本的原子性执行。如果获取锁成功,就执行Lua脚本,如果库存数量大于0,则将库存数量减1,并返回成功;否则返回失败。如果获取锁失败,则说明有其他线程正在执行优惠券领取操作,当前用户需要重试或放弃领取。

这样可以保证在高并发下,多个用户同时请求优惠券时,只有一个用户能够成功领取,避免了优惠券超卖问题。

相关文章:

Redis的一些问题,解决并发的

项目通布隆过滤器&#xff1a; 布隆过滤器&#xff1a; 布隆过滤器是一种空间效率非常高的数据结构&#xff0c;用于快速判断一个元素是否可能存在于一个集合中。它由一个位数组&#xff08;通常是长度为 m 的比特数组&#xff09;和 k 个不同的哈希函数组成。当一个元素被加入…...

郭炜老师mooc第十一章数据分析和展示(numpy,pandas, matplotlib)

多维数组库numpy numpy创建数组的常用函数 # numpy数组import numpy as np #以后numpy简写为np print(np.array([1,2,3])) #>>[1 2 3] print(np.arange(1,9,2)) #>>[1 3 5 7] 不包括9 print(np.linspace(1,10,4)) #>>[ 1. 4. 7. 10.] # linespace(x,y,n)&…...

Redis主从架构和管道Lua(一)

Redis主从架构 架构 Redis主从工作原理 如果为master配置了一个slave,不管这个slave是否是第一次连接上Master,它都会发送一个PSYNC命令给master请求复制数据。master受到PSYNC命令&#xff0c;会在后台进行数据持久化通过bgsave生成最新的 RDB快照文件&#xff0c;持久化期间…...

GTH手册学习注解

CPLL的动态配置 终于看到有这个复位功能了 QPLL SWITCHing需要复位 器件级RESET没发现有管脚引出来 两种复位方式&#xff0c;对应全复位和器件级复位 对应的复位功能管脚 改那个2分频的寄存器说明段&#xff0c;复位是自动发生的&#xff1f;说明可能起效了&#xff0c;但是分…...

html5cssjs代码 002 50以内的加法算式

html5&css&js代码 002 一些基本概念 50以内的加法算式 一、代码二、解释 50以内的加法算式。 一、代码 <!DOCTYPE html> <html lang"en"> <head><title>50以内的加法算式</title><meta charset"UTF-8"><m…...

[React 进阶系列] React Context 案例学习:使用 TS 及 HOC 封装 Context

[React 进阶系列] React Context 案例学习&#xff1a;使用 TS 及 HOC 封装 Context 具体 context 的实现在这里&#xff1a;[React 进阶系列] React Context 案例学习&#xff1a;子组件内更新父组件的状态。 根据项目经验是这样的&#xff0c;自从换了 TS 之后&#xff0c;…...

网络编程:网络编程基础

一、网络发展 1.TCP/IP两个协议阶段 TCP/IP协议已分成了两个不同的协议&#xff1a; 用来检测网络传输中差错的传输控制协议TCP 专门负责对不同网络进行2互联的互联网协议IP 2.网络体系结构 OSI体系口诀&#xff1a;物链网输会示用 2.1网络体系结构概念 每一层都有自己独…...

力扣热题100_矩阵_73_矩阵置零

文章目录 题目链接解题思路解题代码 题目链接 73.矩阵置零 给定一个 m x n 的矩阵&#xff0c;如果一个元素为 0 &#xff0c;则将其所在行和列的所有元素都设为 0 。请使用 原地 算法。 示例 1&#xff1a; 输入&#xff1a;matrix [[1,1,1],[1,0,1],[1,1,1]] 输出&…...

C++程序设计-第四/五章 函数和类和对象【期末复习|考研复习】

前言 总结整理不易&#xff0c;希望大家点赞收藏。 给大家整理了一下C程序设计中的重点概念&#xff0c;以供大家期末复习和考研复习的时候使用。 C程序设计系列文章传送门&#xff1a; 第一章 面向对象基础 第四/五章 函数和类和对象 第六/七/八章 运算符重载/包含与继承/虚函…...

C#快速入门基础

本篇文章从最基础的C#编程开始学习&#xff0c;经过非常优秀的面向对象编程思想和方法的学习&#xff0c;为C#编程打下基础。 第 01 章 C#开发环境之VS使用和.NET平台基础 1.1 Visual Studio 开发环境 1.1.1 硬件环境 i5CPUi5CPU&#xff08;建议 4核 4线程或以上 &#xff0…...

UnityShader常用算法笔记(颜色叠加混合、RGB-HSV-HSL的转换、重映射、UV序列帧动画采样等,持续更新中)

一.颜色叠加混合 1.Blend混合 // 正常&#xff0c;透明度混合 Normal Blend SrcAlpha OneMinusSrcAlpha //柔和叠加 Soft Additive Blend OneMinusDstColor One //正片叠底 相乘 Multiply Blend DstColor Zero //两倍叠加 相加 2x Multiply Blend DstColor SrcColor //变暗…...

Vue3调用钉钉api,内嵌H5微应用单点登录对接

钉钉内嵌H5微应用单点登录对接 https://open.dingtalk.com/document/isvapp/obtain-the-userid-of-a-user-by-using-the-log-free 前端需要的代码 1、安装 dingtalk-jsapi npm install dingtalk-jsapi2、在所需页面引入 import * as dd from dingtalk-jsapi; // 引入钉钉a…...

UE5 局域网联机,寻找会话失败。

目录 参考资料&#xff1a; 尝试解决办法 1.1在【项目名.Build.cs】脚本中添加该行&#xff0c;添加后关闭编辑器&#xff0c;重新生成解决方案。​编辑 2.检查是否在同一个C类子网 参考资料&#xff1a; 1.Cant find session in LAN - Programming & Scripting / Mul…...

Windows系统安装MongoDB并结合内网穿透实现公网访问本地数据库

文章目录 前言1. 安装数据库2. 内网穿透2.1 安装cpolar内网穿透2.2 创建隧道映射2.3 测试随机公网地址远程连接 3. 配置固定TCP端口地址3.1 保留一个固定的公网TCP端口地址3.2 配置固定公网TCP端口地址3.3 测试固定地址公网远程访问 前言 MongoDB是一个基于分布式文件存储的数…...

Hadoop伪分布式配置--没有DataNode或NameNode

一、原因分析 重复格式化NameNode 二、解决方法 1、输入格式化NameNode命令&#xff0c;找到data和name存放位置 ./bin/hdfs namenode -format 2、删除data或name&#xff08;没有哪个删哪个&#xff09; sudo rm -rf data 3、重新格式化NameNode 4、重新启动即可。...

柚见第十期(后端队伍接口详细设计)

创建队伍 用户可以 创建 一个队伍&#xff0c;设置队伍的人数、队伍名称&#xff08;标题&#xff09;、描述、超时时间 P0 队长、剩余的人数 聊天&#xff1f; 公开 或 private 或加密 信息流中不展示已过期的队伍 请求参数是否为空&#xff1f;是否登录&#xff0c;未登录不…...

【李沐论文精读】GPT、GPT-2和GPT-3论文精读

论文&#xff1a; GPT&#xff1a;Improving Language Understanding by Generative Pre-Training GTP-2&#xff1a;Language Models are Unsupervised Multitask Learners GPT-3&#xff1a;Language Models are Few-Shot Learners 参考&#xff1a;GPT、GPT-2、GPT-3论文精读…...

新版Android Studio火烈鸟 在新建项目工程时 无法选java的语言模板解决方法

前言 最近下载最新版androidstudio时 发现不能勾选java语言模板了 如果快速点击下一步 新建项目 默认是kotlin语言模板 这可能和google主推kt语言有关 勾选1 如图所示 如果勾选 No Activity 这个模板 是可以选java语言模板的 但是里面没有默认的Activity 勾选2 和以前的用法…...

github(不是git啊)操作记录(踩坑)

专栏介绍与文章目录-CSDN博客 github是程序员绕不开的东西。 网站打不开&#xff1f; 向雇主或有关部门申请合法信道连接互联网。 明明账号密码都对却登录失败&#xff1f; 向雇主或有关部门申请合法信道连接互联网。 重置密码失败&#xff1f; 向雇主或有关部门申请合法信道…...

【SpringCloud微服务实战01】Eureka 注册中心

前言 在 Eureka 架构中&#xff0c;微服务角色有两类&#xff1a; EurekaServer &#xff1a;服务端&#xff0c;注册中心 记录服务信息 心跳监控 EurekaClient &#xff1a;客户端 Provider &#xff1a;服务提供者&#xff0c;例如案例中的 user-service …...

java_网络服务相关_gateway_nacos_feign区别联系

1. spring-cloud-starter-gateway 作用&#xff1a;作为微服务架构的网关&#xff0c;统一入口&#xff0c;处理所有外部请求。 核心能力&#xff1a; 路由转发&#xff08;基于路径、服务名等&#xff09;过滤器&#xff08;鉴权、限流、日志、Header 处理&#xff09;支持负…...

阿里云ACP云计算备考笔记 (5)——弹性伸缩

目录 第一章 概述 第二章 弹性伸缩简介 1、弹性伸缩 2、垂直伸缩 3、优势 4、应用场景 ① 无规律的业务量波动 ② 有规律的业务量波动 ③ 无明显业务量波动 ④ 混合型业务 ⑤ 消息通知 ⑥ 生命周期挂钩 ⑦ 自定义方式 ⑧ 滚的升级 5、使用限制 第三章 主要定义 …...

【Redis技术进阶之路】「原理分析系列开篇」分析客户端和服务端网络诵信交互实现(服务端执行命令请求的过程 - 初始化服务器)

服务端执行命令请求的过程 【专栏简介】【技术大纲】【专栏目标】【目标人群】1. Redis爱好者与社区成员2. 后端开发和系统架构师3. 计算机专业的本科生及研究生 初始化服务器1. 初始化服务器状态结构初始化RedisServer变量 2. 加载相关系统配置和用户配置参数定制化配置参数案…...

P3 QT项目----记事本(3.8)

3.8 记事本项目总结 项目源码 1.main.cpp #include "widget.h" #include <QApplication> int main(int argc, char *argv[]) {QApplication a(argc, argv);Widget w;w.show();return a.exec(); } 2.widget.cpp #include "widget.h" #include &q…...

跨链模式:多链互操作架构与性能扩展方案

跨链模式&#xff1a;多链互操作架构与性能扩展方案 ——构建下一代区块链互联网的技术基石 一、跨链架构的核心范式演进 1. 分层协议栈&#xff1a;模块化解耦设计 现代跨链系统采用分层协议栈实现灵活扩展&#xff08;H2Cross架构&#xff09;&#xff1a; 适配层&#xf…...

[10-3]软件I2C读写MPU6050 江协科技学习笔记(16个知识点)

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16...

论文解读:交大港大上海AI Lab开源论文 | 宇树机器人多姿态起立控制强化学习框架(一)

宇树机器人多姿态起立控制强化学习框架论文解析 论文解读&#xff1a;交大&港大&上海AI Lab开源论文 | 宇树机器人多姿态起立控制强化学习框架&#xff08;一&#xff09; 论文解读&#xff1a;交大&港大&上海AI Lab开源论文 | 宇树机器人多姿态起立控制强化…...

解决本地部署 SmolVLM2 大语言模型运行 flash-attn 报错

出现的问题 安装 flash-attn 会一直卡在 build 那一步或者运行报错 解决办法 是因为你安装的 flash-attn 版本没有对应上&#xff0c;所以报错&#xff0c;到 https://github.com/Dao-AILab/flash-attention/releases 下载对应版本&#xff0c;cu、torch、cp 的版本一定要对…...

unix/linux,sudo,其发展历程详细时间线、由来、历史背景

sudo 的诞生和演化,本身就是一部 Unix/Linux 系统管理哲学变迁的微缩史。来,让我们拨开时间的迷雾,一同探寻 sudo 那波澜壮阔(也颇为实用主义)的发展历程。 历史背景:su的时代与困境 ( 20 世纪 70 年代 - 80 年代初) 在 sudo 出现之前,Unix 系统管理员和需要特权操作的…...

OpenPrompt 和直接对提示词的嵌入向量进行训练有什么区别

OpenPrompt 和直接对提示词的嵌入向量进行训练有什么区别 直接训练提示词嵌入向量的核心区别 您提到的代码: prompt_embedding = initial_embedding.clone().requires_grad_(True) optimizer = torch.optim.Adam([prompt_embedding...