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防止用户并发执行某一操作的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---