Nguyên Nhân Nút Bị Spam Nhấp: Hướng Dẫn Spring Boot Chống Nhập Lặp

@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
public @interface NoRepeatSubmit {int lockTime() default 3; // Thời gian khóa mặc định là 3 giây; nên dài hơn thời gian vô hiệu hóa nút ở frontend
}

@Aspect
@Component
public class RepeatSubmitAspect { // Sử dụng ConcurrentHashMap làm bộ nhớ khóa cục bộ (LƯU Ý: Không hoạt động trong môi trường phân tán!)
    private static final ConcurrentHashMap<String, Object> LOCKS = new ConcurrentHashMap<>();

    @Around("@annotation(noRepeatSubmit)")
    public Object around(ProceedingJoinPoint point, NoRepeatSubmit noRepeatSubmit) throws Throwable {HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.currentRequestAttributes()).getRequest();

        // Tạo một khóa duy nhất: ID người dùng + đường dẫn API (sử dụng các quy tắc phức tạp hơn trong sản xuất)
        String lockKey = getUserId(request) + "-" + request.getServletPath();

        // Nếu khóa đã tồn tại, ném ra một ngoại lệ (khuyến nghị sử dụng các ngoại lệ kinh doanh tùy chỉnh)
        if (LOCKS.putIfAbsent(lockKey, Boolean.TRUE) != null) {throw new RuntimeException("Quá nhanh! Chậm lại một chút."); // Thông điệp thân thiện với người dùng
        }

        try {return point.proceed(); // Thực thi phương thức kinh doanh thực tế
        } finally { // Giải phóng khóa với độ trễ (LUÔN luôn sử dụng finally để đảm bảo giải phóng!)
            Thread.sleep(noRepeatSubmit.lockTime() * 1000);
            LOCKS.remove(lockKey);
        }
    }

    // Trong sản xuất, phân tích ID người dùng từ token; ví dụ đơn giản ở đây
    private String getUserId(HttpServletRequest request) {return Optional.ofNullable(request.getHeader("Authorization"))
                .orElse("anonymous");
    }
}

@RestController
public class OrderController {@NoRepeatSubmit(lockTime = 5) // Chặn các cuộc gọi lặp lại trong 5 giây
    @PostMapping("/createOrder")
    public ResponseEntity createOrder(@RequestBody OrderDTO order) { // Logic thực tế để tạo đơn hàng (thường cần quản lý giao dịch)
        orderService.create(order);
        return ResponseEntity.ok("Đơn hàng đã được tạo thành công");
    }
}

import redis.clients.jedis.Jedis;

public class RedisLock { 
    private Jedis jedis;

    public RedisLock(Jedis jedis) {
        this.jedis = jedis;
    }

    public boolean tryLock(String lockKey, int lockTime) {
        String result = jedis.set(lockKey, "locked", "NX", "EX", lockTime);
        return "OK".equals(result);
    }

    public void unlock(String lockKey) {
        jedis.del(lockKey);
    }
}

@RestController
public class DistributedOrderController {@PostMapping("/createOrder")
    public ResponseEntity createOrder(@RequestBody OrderDTO order) {
        RedisLock redisLock = new RedisLock(new Jedis());
        String lockKey = "orderLock";

        if (redisLock.tryLock(lockKey, 10)) { // Thử khóa trong 10 giây
            try {
                orderService.create(order);
                return ResponseEntity.ok("Đơn hàng đã được tạo thành công");
            } finally {
                redisLock.unlock(lockKey);
            }
        } else {
            return ResponseEntity.status(HttpStatus.TOO_MANY_REQUESTS).body("Vui lòng thử lại");
        }
    }
}