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客户端连接机制的实现方案

Redis客户端连接机制的实现方案

《Redis客户端连接机制的实现方案》本文主要介绍了Redis客户端连接机制的实现方案,包括事件驱动模型、非阻塞I/O处理、连接池应用及配置优化,具有一定的参考价值,感兴趣的可以了解一下... 目录1. Redis连接模型概述2. 连接建立过程详解2.1 连php接初始化流程2.2 关键配置参数3. 最大连
阅读更多...
Python操作PDF文档的主流库使用指南

Python操作PDF文档的主流库使用指南

《Python操作PDF文档的主流库使用指南》PDF因其跨平台、格式固定的特性成为文档交换的标准,然而,由于其复杂的内部结构,程序化操作PDF一直是个挑战,本文主要为大家整理了Python操作PD... 目录一、 基础操作1.PyPDF2 (及其继任者 pypdf)2.PyMuPDF / fitz3.Fre
阅读更多...
解密SQL查询语句执行的过程

解密SQL查询语句执行的过程

《解密SQL查询语句执行的过程》文章讲解了SQL语句的执行流程,涵盖解析、优化、执行三个核心阶段,并介绍执行计划查看方法EXPLAIN,同时提出性能优化技巧如合理使用索引、避免SELECT*、JOIN... 目录1. SQL语句的基本结构2. SQL语句的执行过程3. SQL语句的执行计划4. 常见的性能优
阅读更多...
最新Spring Security的基于内存用户认证方式

最新Spring Security的基于内存用户认证方式

《最新SpringSecurity的基于内存用户认证方式》本文讲解SpringSecurity内存认证配置,适用于开发、测试等场景,通过代码创建用户及权限管理,支持密码加密,虽简单但不持久化,生产环... 目录1. 前言2. 因何选择内存认证？3. 基础配置实战❶ 创建Spring Security配置文件
阅读更多...
Python对接支付宝支付之使用AliPay实现的详细操作指南

Python对接支付宝支付之使用AliPay实现的详细操作指南

《Python对接支付宝支付之使用AliPay实现的详细操作指南》支付宝没有提供PythonSDK,但是强大的github就有提供python-alipay-sdk,封装里很多复杂操作,使用这个我们就... 目录一、引言二、准备工作2.1 支付宝开放平台入驻与应用创建2.2 密钥生成与配置2.3 安装ali
阅读更多...
MySQL 强制使用特定索引的操作

MySQL 强制使用特定索引的操作

《MySQL强制使用特定索引的操作》MySQL可通过FORCEINDEX、USEINDEX等语法强制查询使用特定索引,但优化器可能不采纳,需结合EXPLAIN分析执行计划,避免性能下降,注意版本差异... 目录1. 使用FORCE INDEX语法2. 使用USE INDEX语法3. 使用IGNORE IND
阅读更多...
Redis MCP 安装与配置指南

Redis MCP 安装与配置指南

《RedisMCP安装与配置指南》本文将详细介绍如何安装和配置RedisMCP,包括快速启动、源码安装、Docker安装、以及相关的配置参数和环境变量设置,感兴趣的朋友一起看看吧... 目录一、Redis MCP 简介二、安www.chinasem.cn装 Redis MCP 服务2.1 快速启动（推荐）2.
阅读更多...
go动态限制并发数量的实现示例

go动态限制并发数量的实现示例

《go动态限制并发数量的实现示例》本文主要介绍了Go并发控制方法,通过带缓冲通道和第三方库实现并发数量限制,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录带有缓冲大小的通道使用第三方库其他控制并发的方法因为go从语言层面支持并发，所以面试百分百会问到
阅读更多...
Go语言并发之通知退出机制的实现

Go语言并发之通知退出机制的实现

《Go语言并发之通知退出机制的实现》本文主要介绍了Go语言并发之通知退出机制的实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1、通知退出机制1.1 进程/main函数退出1.2 通过channel退出1.3 通过cont
阅读更多...
Spring Bean初始化及@PostConstruc执行顺序示例详解

Spring Bean初始化及@PostConstruc执行顺序示例详解

《SpringBean初始化及@PostConstruc执行顺序示例详解》本文给大家介绍SpringBean初始化及@PostConstruc执行顺序,本文通过实例代码给大家介绍的非常详细,对大家的... 目录1. Bean初始化执行顺序2. 成员变量初始化顺序2.1 普通Java类（非Spring环境）(
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2