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

Z时代
2024-01-10
分类：综合

这块提出一个大致简单的解决方案，对每个用户终端颁发一个唯一标识，在前端请求时带上唯一标识，服务器可以加一个过滤器来处理，每收到一个请求都判断该请求的唯一标识和请求路径是否已经在处理中，如果没有就放入内存中并标识这次请求正在处理，当上次请求还在处理中，又来了一次相同唯一标识和路径的请求，那么第二次（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);
    }
}