Spring Cloud 中防止重放攻击 完整示例代码

下面是一个基于Spring Cloud的防止重放攻击的完整示例代码：

首先，我们需要定义一个拦截器来拦截请求，并检查请求是否已经被处理过。

@Component
public class ReplayAttackInterceptor implements HandlerInterceptor {

    private static final Map<String, Long> REQUEST_MAP = new ConcurrentHashMap<>();

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        String requestId = request.getHeader("X-Request-Id");
        if (StringUtils.isBlank(requestId)) {
            response.sendError(HttpStatus.BAD_REQUEST.value(), "Missing X-Request-Id header");
            return false;
        }
        Long requestTimestamp = Long.valueOf(request.getHeader("X-Request-Timestamp"));
        if (requestTimestamp == null) {
            response.sendError(HttpStatus.BAD_REQUEST.value(), "Missing X-Request-Timestamp header");
            return false;
        }
        Long previousTimestamp = REQUEST_MAP.putIfAbsent(requestId, requestTimestamp);
        if (previousTimestamp != null && previousTimestamp >= requestTimestamp) {
            response.sendError(HttpStatus.CONFLICT.value(), "Replay attack detected");
            return false;
        }
        return true;
    }

    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        String requestId = request.getHeader("X-Request-Id");
        REQUEST_MAP.remove(requestId);
    }
}

在这个拦截器中，我们首先检查请求中是否包含了X-Request-Id和X-Request-Timestamp这两个必要的头部信息。如果没有，我们就返回一个400错误。

接着，我们检查请求是否已经被处理过。我们使用一个ConcurrentHashMap来存储每个请求的ID和时间戳。如果请求已经被处理过，我们就返回一个409错误。

最后，我们在请求处理完成后从存储中删除请求ID。

接下来，我们需要将这个拦截器注册到Spring MVC中：

@Configuration
public class WebConfig implements WebMvcConfigurer {

    @Autowired
    private ReplayAttackInterceptor replayAttackInterceptor;

    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(replayAttackInterceptor);
    }
}

现在，我们已经完成了防止重放攻击的代码。我们可以在任何需要防止重放攻击的地方使用这个拦截器。

注意：这个示例代码中使用了内存存储来存储已处理的请求。在实际应用中，我们应该使用分布式存储来存储这些请求，以便在多个实例之间共享。