Redis防止用户并发执行某一操作

2024-05-28 00:18
文章标签 操作 redis 并发 用户 执行 防止 某一

本文主要是介绍Redis防止用户并发执行某一操作，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

背景

在实际的开发过程中，会遇到某些接口因处理过慢或者用户重复点击操作，导致相同的操作执行多遍的情况，那么如何有效的防止同一用户同一时刻执行多次相同的操作，就是本文的重点啦！

处理方法

废话不多说，此处采用Redis Incr实现。

Redis incr 可以实现原子性的递增，可应用于高并发的秒杀活动、分布式序列号生成等场景。这里我使用它来计数实现过滤用户请求，同一时刻只允许同一用户执行一次操作，任务执行超过一分钟可以执行下一次操作。

  • 过滤用户请求，同一时刻只允许同一用户执行一次操作，任务执行超过一分钟可以执行下一次操作。
/*** Redis Incr 过滤用户请求，同一时刻只允许同一用户执行一次操作，任务执行超过一分钟可以执行下一次操作** @return*/@GetMapping("/testRedisIncrement3")public Response testRedisIncrement3(){Integer userId = 10086;String redisKey = "test_redis_increment_" + userId;long count = redisTemplate.opsForValue().increment(redisKey, 1);if (count == 1) {/******设置有效期一分钟******/log.info(Thread.currentThread().getName()+"设置Redis increment值失效时间，count = {}...", count);redisTemplate.expire(redisKey, 60, TimeUnit.SECONDS);}if (count > 1) {/******默认一分钟内只允许操作一次******/log.info(Thread.currentThread().getName()+"请求过于频繁...");return Response.errorResponse("请求过于频繁，请稍后重试");}try {/******具体执行的业务******/Thread.sleep(1000);  //更换睡眠时间查看效果 120*1000log.info(Thread.currentThread().getName()+"正在执行任务计算...");DingDingMsgSendUtils.sendDingDingGroupMsg(DingTokenEnum.SEND_SMS_BY_DEVELOPER_TOKEN.getToken(), "【测试消息】Redis Incr 过滤用户请求，同一用户同一时刻只允许一个操作执行，by:songfayuan...");} catch (Exception e) {log.info(Thread.currentThread().getName()+"请求异常，errMsg = {}", e);return Response.successResponse("请求异常");} finally {/******如果任务一分钟内执行完毕，则允许下一个任务继续执行******/log.info(Thread.currentThread().getName()+"请求操作删除...");redisTemplate.delete(redisKey);}return Response.successResponse("操作成功");}
  • 过滤用户请求，5s内只允许同一用户请求一次
	/*** Redis Incr 过滤用户请求，5s内只允许同一用户请求一次** @return*/@GetMapping("/testRedisIncrement2")public Response testRedisIncrement2(){Integer userId = 1;String redisKey = "test_redis_increment_" + userId;long count = redisTemplate.opsForValue().increment(redisKey, 1);log.info("{}, redis key = {}, count = {}", Thread.currentThread().getName(), redisKey, count);if (count == 1) {/******设置有效期一分钟******/log.info(Thread.currentThread().getName()+"设置Redis increment值失效时间...");redisTemplate.expire(redisKey, 5, TimeUnit.SECONDS);}if (count > 1) {/******一分钟内只允许操作一次******/log.info(Thread.currentThread().getName()+"请求过于频繁...");return Response.errorResponse("请求过于频繁，请稍后重试");}/******具体执行的业务******/log.info(Thread.currentThread().getName()+"正在执行任务计算...");DingDingMsgSendUtils.sendDingDingGroupMsg(DingTokenEnum.SEND_SMS_BY_DEVELOPER_TOKEN.getToken(), "【测试消息】Redis Incr 过滤用户请求，5s内只允许同一用户请求一次测试，by:songfayuan...");return Response.successResponse("操作成功");}
  • 仿多线程版
package com.github.collection.admin.controller.demo;import com.github.collection.common.constant.Constants;
import com.github.collection.common.constant.enums.DingMsgPhoneEnum;
import com.github.collection.common.constant.enums.DingTokenEnum;
import com.github.collection.common.distributelock.DistributeLock;
import com.github.collection.common.distributelock.DistributeLockFactory;
import com.github.collection.common.util.DingDingMsgSendUtils;
import com.github.collection.common.util.Response;
import com.github.collection.common.util.concurrent.Executors;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.DisposableBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.support.atomic.RedisAtomicInteger;
import org.springframework.web.bind.annotation.*;import java.util.*;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.TimeUnit;/*** 描述：demo* @author songfayuan* 2017年8月31日下午2:07:19*/
@Slf4j
@RestController
@RequestMapping("/demo")
public class DemoController implements DisposableBean {private ExecutorService executor = Executors.newFixedThreadPool(10, "测试多线程操作");  //newFixedThreadPool 创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。@Autowiredprivate RedisTemplate redisTemplate;/*** Redis Incr 实现原子性的递增测试** 		Redis incr 可以实现原子性的递增，可应用于高并发的秒杀活动、分布式序列号生成等场景。这里我使用它来计数实现一分钟内只接受一次请求。** @return*/@GetMapping("/testRedisIncrement")public Response testRedisIncrement(){for (int i = 0; i<=200; i++) {   //模拟200个请求executor.execute(new Runnable() {@Overridepublic void run() {String redisKey = "test_redis_increment";long count = redisTemplate.opsForValue().increment(redisKey, 1);log.info("{}, redis key = {}, count = {}", Thread.currentThread().getName(), redisKey, count);if (count == 1) {/******设置有效期一分钟******/log.info(Thread.currentThread().getName()+"设置Redis increment值失效时间...");redisTemplate.expire(redisKey, 60, TimeUnit.SECONDS);}if (count > 1) {/******一分钟内只允许操作一次******/log.info(Thread.currentThread().getName()+"请求过于频繁...");return;}//具体执行的业务log.info(Thread.currentThread().getName()+"正在执行任务计算...");DingDingMsgSendUtils.sendDingDingGroupMsg(DingTokenEnum.SEND_SMS_BY_DEVELOPER_TOKEN.getToken(), "【测试消息】Redis Incr 实现原子性的递增测试，by:songfayuan...");}});}return Response.successResponse("操作成功");}@Overridepublic void destroy() throws Exception {executor.shutdown();}
}
  • 文中用到的Response类
package com.github.collection.common.util;import com.fasterxml.jackson.annotation.JsonInclude;import java.io.Serializable;/*** 响应信息主体** @param <T>* @author songfayuan*/
//@JsonInclude(JsonInclude.Include.NON_NULL)
public class Response<T> implements Serializable {private static final long serialVersionUID = 1L;private static final int SUCCESS_CODE = 200;private static final String SUCCESS_MSG = "success";private static final int ERROR_CODE = 500;private static final String ERROR_MSG = "服务器内部异常，请联系技术人员"; //将error改成了内容信息public static final int NO_LOGIN = -1;public static final int SUCCESS = 200;public static final int FAIL = 500;public static final int NO_PERMISSION = 2;private String msg = "success";private int code = SUCCESS;private T data;public Response() {super();}public Response(T data) {super();this.data = data;}public Response(T data, String msg) {super();this.data = data;this.msg = msg;}public Response(int code, T data, String msg) {super();this.code = code;this.data = data;this.msg = msg;}public Response(int code, String msg) {super();this.code = code;this.msg = msg;}public Response(Throwable e) {super();this.msg = e.getMessage();this.code = FAIL;}public static Response success() {Response resp = new Response();resp.code = (SUCCESS_CODE);resp.msg = (SUCCESS_MSG);return resp;}public static Response successResponse(String msg) {Response resp = new Response();resp.code = SUCCESS_CODE;resp.msg = msg;return resp;}public static Response error() {Response resp = new Response();resp.code = (ERROR_CODE);resp.msg = (ERROR_MSG);return resp;}public static Response errorResponse(String msg) {Response resp = new Response();resp.code = ERROR_CODE;resp.msg = msg;return resp;}public static Response response(int code, String msg) {Response resp = new Response();resp.code = (code);resp.msg = (msg);return resp;}public static Response response(int code, String msg, Object data) {Response resp = new Response();resp.code = (code);resp.msg = (msg);resp.data = data;return resp;}public static Response success(Object data) {Response resp = new Response();resp.code = (SUCCESS_CODE);resp.msg = (SUCCESS_MSG);resp.data = data;return resp;}public static Response error(Object data) {Response resp = new Response();resp.code = (ERROR_CODE);resp.msg = (ERROR_MSG);resp.data = data;return resp;}public String getMsg() {return msg;}public void setMsg(String msg) {this.msg = msg;}public int getCode() {return code;}public void setCode(int code) {this.code = code;}public T getData() {return data;}public void setData(T data) {this.data = data;}
}

文中用到的钉钉消息发送方法DingDingMsgSendUtils，移步到教程：https://blog.csdn.net/u011019141/article/details/94222443

这篇关于Redis防止用户并发执行某一操作的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1008999。

相关文章

Redis Cluster模式配置

Redis Cluster模式配置

《RedisCluster模式配置》：本文主要介绍RedisCluster模式配置,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录分片 一、分片的本质与核心价值二、分片实现方案对比 ‌三、分片算法详解1. ‌范围分片（顺序分片）‌2. ‌哈希分片3. ‌虚
阅读更多...
SQL中JOIN操作的条件使用总结与实践

SQL中JOIN操作的条件使用总结与实践

《SQL中JOIN操作的条件使用总结与实践》在SQL查询中,JOIN操作是多表关联的核心工具,本文将从原理,场景和最佳实践三个方面总结JOIN条件的使用规则,希望可以帮助开发者精准控制查询逻辑... 目录一、ON与WHERE的本质区别二、场景化条件使用规则三、最佳实践建议1.优先使用ON条件2.WHERE用
阅读更多...
Springboot整合Redis主从实践

Springboot整合Redis主从实践

《Springboot整合Redis主从实践》：本文主要介绍Springboot整合Redis主从的实例,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录前言原配置现配置测试LettuceConnectionFactory.setShareNativeConnect
阅读更多...
Redis过期删除机制与内存淘汰策略的解析指南

Redis过期删除机制与内存淘汰策略的解析指南

《Redis过期删除机制与内存淘汰策略的解析指南》在使用Redis构建缓存系统时,很多开发者只设置了EXPIRE但却忽略了背后Redis的过期删除机制与内存淘汰策略,下面小编就来和大家详细介绍一下... 目录1、简述2、Redis http://www.chinasem.cn的过期删除策略（Key Expir
阅读更多...
Linux链表操作方式

Linux链表操作方式

《Linux链表操作方式》：本文主要介绍Linux链表操作方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、链表基础概念与内核链表优势二、内核链表结构与宏解析三、内核链表的优点四、用户态链表示例五、双向循环链表在内核中的实现优势六、典型应用场景七、调试技巧与
阅读更多...
Java Multimap实现类与操作的具体示例

Java Multimap实现类与操作的具体示例

《JavaMultimap实现类与操作的具体示例》Multimap出现在Google的Guava库中,它为Java提供了更加灵活的集合操作,：本文主要介绍JavaMultimap实现类与操作的... 目录一、Multimap 概述Multimap 主要特点：二、Multimap 实现类1. ListMult
阅读更多...
Python中文件读取操作漏洞深度解析与防护指南

Python中文件读取操作漏洞深度解析与防护指南

《Python中文件读取操作漏洞深度解析与防护指南》在Web应用开发中,文件操作是最基础也最危险的功能之一,这篇文章将全面剖析Python环境中常见的文件读取漏洞类型,成因及防护方案,感兴趣的小伙伴可... 目录引言一、静态资源处理中的路径穿越漏洞1.1 典型漏洞场景1.2 os.path.join()的陷
阅读更多...
Python使用Code2flow将代码转化为流程图的操作教程

Python使用Code2flow将代码转化为流程图的操作教程

《Python使用Code2flow将代码转化为流程图的操作教程》Code2flow是一款开源工具,能够将代码自动转换为流程图,该工具对于代码审查、调试和理解大型代码库非常有用,在这篇博客中,我们将深... 目录引言1nVflRA、为什么选择 Code2flow？2、安装 Code2flow3、基本功能演示
阅读更多...
Python中OpenCV与Matplotlib的图像操作入门指南

Python中OpenCV与Matplotlib的图像操作入门指南

《Python中OpenCV与Matplotlib的图像操作入门指南》：本文主要介绍Python中OpenCV与Matplotlib的图像操作指南,本文通过实例代码给大家介绍的非常详细,对大家的学... 目录一、环境准备二、图像的基本操作1. 图像读取、显示与保存 使用OpenCV操作2. 像素级操作3.
阅读更多...
Redis指南及6.2.x版本安装过程

Redis指南及6.2.x版本安装过程

《Redis指南及6.2.x版本安装过程》Redis是完全开源免费的,遵守BSD协议,是一个高性能(NOSQL)的key-value数据库,Redis是一个开源的使用ANSIC语言编写、支持网络、... 目录概述Redis特点Redis应用场景缓存缓存分布式会话分布式锁社交网络最新列表Redis各版本介绍旧
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2