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。

相关文章

使用Java将各种数据写入Excel表格的操作示例

使用Java将各种数据写入Excel表格的操作示例

《使用Java将各种数据写入Excel表格的操作示例》在数据处理与管理领域,Excel凭借其强大的功能和广泛的应用,成为了数据存储与展示的重要工具,在Java开发过程中,常常需要将不同类型的数据,本文... 目录前言安装免费Java库1. 写入文本、或数值到 Excel单元格2. 写入数组到 Excel表格
阅读更多...
redis中使用lua脚本的原理与基本使用详解

redis中使用lua脚本的原理与基本使用详解

《redis中使用lua脚本的原理与基本使用详解》在Redis中使用Lua脚本可以实现原子性操作、减少网络开销以及提高执行效率,下面小编就来和大家详细介绍一下在redis中使用lua脚本的原理... 目录Redis 执行 Lua 脚本的原理基本使用方法使用EVAL命令执行 Lua 脚本使用EVALSHA命令
阅读更多...
Java并发编程之如何优雅关闭钩子Shutdown Hook

Java并发编程之如何优雅关闭钩子Shutdown Hook

《Java并发编程之如何优雅关闭钩子ShutdownHook》这篇文章主要为大家详细介绍了Java如何实现优雅关闭钩子ShutdownHook,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起... 目录关闭钩子简介关闭钩子应用场景数据库连接实战演示使用关闭钩子的注意事项开源框架中的关闭钩子机制1.
阅读更多...
Python中pywin32 常用窗口操作的实现

Python中pywin32 常用窗口操作的实现

《Python中pywin32常用窗口操作的实现》本文主要介绍了Python中pywin32常用窗口操作的实现,pywin32主要的作用是供Python开发者快速调用WindowsAPI的一个... 目录获取窗口句柄获取最前端窗口句柄获取指定坐标处的窗口根据窗口的完整标题匹配获取句柄根据窗口的类别匹配获取句
阅读更多...
Python位移操作和位运算的实现示例

Python位移操作和位运算的实现示例

《Python位移操作和位运算的实现示例》本文主要介绍了Python位移操作和位运算的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一... 目录1. 位移操作1.1 左移操作 (<<)1.2 右移操作 (>>)注意事项：2. 位运算2.1
阅读更多...
Redis 热 key 和大 key 问题小结

Redis 热 key 和大 key 问题小结

《Redis热key和大key问题小结》：本文主要介绍Redis热key和大key问题小结,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录一、什么是 Redis 热 key？热 key（Hot Key）定义： 热 key 常见表现：热 key 的风险：二、
阅读更多...
C#使用StackExchange.Redis实现分布式锁的两种方式介绍

C#使用StackExchange.Redis实现分布式锁的两种方式介绍

《C#使用StackExchange.Redis实现分布式锁的两种方式介绍》分布式锁在集群的架构中发挥着重要的作用,：本文主要介绍C#使用StackExchange.Redis实现分布式锁的... 目录自定义分布式锁获取锁释放锁自动续期StackExchange.Redis分布式锁获取锁释放锁自动续期分布式
阅读更多...
SpringBoot UserAgentUtils获取用户浏览器的用法

SpringBoot UserAgentUtils获取用户浏览器的用法

《SpringBootUserAgentUtils获取用户浏览器的用法》UserAgentUtils是于处理用户代理（User-Agent）字符串的工具类,一般用于解析和处理浏览器、操作系统以及设备... 目录介绍效果图依赖封装客户端工具封装IP工具实体类获取设备信息入库介绍UserAgentUtils
阅读更多...
Python ZIP文件操作技巧详解

Python ZIP文件操作技巧详解

《PythonZIP文件操作技巧详解》在数据处理和系统开发中,ZIP文件操作是开发者必须掌握的核心技能,Python标准库提供的zipfile模块以简洁的API和跨平台特性,成为处理ZIP文件的首选... 目录一、ZIP文件操作基础三板斧1.1 创建压缩包1.2 解压操作1.3 文件遍历与信息获取二、进阶技
阅读更多...
Java中字符串转时间与时间转字符串的操作详解

Java中字符串转时间与时间转字符串的操作详解

《Java中字符串转时间与时间转字符串的操作详解》Java的java.time包提供了强大的日期和时间处理功能,通过DateTimeFormatter可以轻松地在日期时间对象和字符串之间进行转换,下面... 目录一、字符串转时间（一）使用预定义格式（二）自定义格式二、时间转字符串（一）使用预定义格式（二）自
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2