Каков правильный способ написать метод, который нельзя назвать слишком часто?

Question

Предположим, у меня есть класс с методом, который я не хочу вызывать более одного раза в пять секунд (например, он запрашивает веб-сервер, который черным списком приложений, которые слишком часто отправляют запросы). Каков наилучший способ реализации этого?

Решение, которое я придумал, заключается в том, чтобы метод хранил временную метку в статической переменной-члене каждый раз, когда она выполнялась по вызову System.currentTimeMillis(), и проверяйте эту отметку времени перед выполнением секретного кода. Но я нервничаю, что есть непредвиденные обстоятельства, которые я не предвидел, поэтому я хотел посмотреть, есть ли стандартный способ справиться с этой проблемой.

Answer 1

Поскольку вы упомянули, что это веб-приложение, ваш метод будет делиться переменной timestamp среди всех вызовов, то есть из всех активных сеансов. Это не похоже на то, что вы хотели бы достичь.

Стандартным подходом «веб-приложения» является помещение объекта таймера в сеанс и запись фильтра, который будет управлять таймером.

Answer 2

Я не слышал о стандартном способе, но я решил эту проблему, так как я хотел слишком часто получать ntp-время, а сервер NTP блокировал мои запросы. Таким образом, следующий код сделал это для меня:

public static long getTime() { 
    // check whether a update should be done 
    if (System.currentTimeMillis() - updateTime > CLOCK_SYNC_INTERVAL_MS) { 
     // perform the update in a new thread 
     new Thread(new Runnable() { 
      @Override 
      public void run() { 
       updateClock(); 
      } 
     }).start(); 
    } 
    return System.currentTimeMillis() - updateTime + nts; 
} 

Answer 3

Используйте Guava RateLimiter. Простой пример:

public static void main(String[] args) { 
    callForeverWithRateLimited(); 
} 

public static void callForeverWithRateLimited() { 
    RateLimiter rateLimiter = RateLimiter.create(1); // 1 QPS (query per second) 
    while (true) { 
    if (rateLimiter.tryAcquire()) { 
     System.out.println("my rate was limited!"); 
    } 
    } 
}