重复请求（并发访问）解决方案

Posted 2020-11-26 1994july

对于查询这些幂等性的请求重复请求其实影响不大，但是对于插入操作的请求，如果有短时间内有重复请求，再加上有事务操作，那么就很有可能造成插入重复数据的问题。对于这种情况首先想到就是数据库添加唯一约束，但是这种方案并不是很推荐而且有很大的局限性。

这块提出一个大致简单的解决方案，对每个用户终端颁发一个唯一标识，在前端请求时带上唯一标识，服务器可以加一个过滤器来处理，每收到一个请求都判断该请求的唯一标识和请求路径是否已经在处理中，如果没有就放入内存中并标识这次请求正在处理，当上次请求还在处理中，又来了一次相同唯一标识和路径的请求，那么第二次（n次）的请求可以直接返回或者等待上次请求完成后一起返回给前端。

import com.mew.kittyapi.util.Objects;
import com.mew.kittyapi.util.Strings;
import lombok.extern.slf4j.Slf4j;

import javax.servlet.*;
import javax.servlet.http.HttpServletRequest;
import java.io.IOException;
import java.util.HashMap;
import java.util.concurrent.locks.ReentrantLock;

@Slf4j
public class PathFilter implements Filter {

    private static HashMap<String, Boolean> keyCache = new HashMap<>();

    private static ReentrantLock LOCK = new ReentrantLock(true);

    @Override
    public void init(FilterConfig filterConfig) {
        System.out.println(filterConfig);
    }

    @Override
    public void doFilter(ServletRequest req, ServletResponse response, FilterChain chain) throws IOException, ServletException {
        HttpServletRequest request = (HttpServletRequest) req;
        String key = request.getHeader("key") + request.getServletPath();
        if (Strings.isNotEmpty(key)) {
            LOCK.lock();
            try {
                Boolean val = keyCache.get(key);
                if (Objects.isNotNull(val) && val) {
                    log.debug("重复请求 key:{}", key);
                    // todo 自定义返回结果
                    return;
                }
                keyCache.put(key, true);
            } finally {
                LOCK.unlock();
            }
        }
        chain.doFilter(request, response);
        keyCache.remove(key);
    }

}

这里的HashMap可以用redis替代，并且这块忽略了同一时间同一接口相同用户的不同参数的请求，这里也可以对其额外处理，比如对参数计算一个签名等待，这里就可以根据实际需求各自发挥了。

来源：http://www.1994july.club/