Ограничение количества запросов CFHTTP, отправленных каждые x секунд

Question

Я делаю приложение, которое будет постоянно отправлять запросы CFHTTP на сервер для поиска элементов, а также отправлять дополнительные запросы CFHTTP для выполнения действий по любым возвращенным результатам.

Проблема, с которой я сталкиваюсь, заключается в том, что сервер имеет максимальный порог в 3 запроса в секунду, и даже когда я пытаюсь реализовать вызов сна каждые 4 миллисекунды, он работает неправильно, хотя он и задерживает, CFHTTP запросы могут стоять в очереди, если для возврата требуется несколько секунд, чтобы затем попытаться отправить несколько в тот же самый второй триггер, чтобы превысить порог.

Есть ли способ, которым я могу гарантировать, что не более 3 активных запросов CFHTTP?

Answer 1

Я думаю, вам понадобится реализовать какой-то виджет ведения журнала как часть вашего процесса. Журнал будет отслеживать частоту запроса. Если порог не выполняется, вы просто пропустите эту итерацию своего вызова CFHTTP. Я не имею в виду журнал файлов или журнал базы данных, но что-то реализовано в приложении или даже запрашивает область действия в зависимости от вашей реализации. Невозможно дросселировать сам CFHTTP. Это в основном упрощенная оболочка Java-библиотеки Java, которая затем переходит прямо в базовую операционную систему.

Answer 2

Если вы ограничиваете одновременными запросами, тогда применяется первая часть этого ответа. Если вы хотите ограничить количество запросов в секунду, то бит в конце применяется. Вопрос типа спрашивает обе вещи.

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

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

Действительно, у вас есть resource poo l (разрешенных HTTP-соединений), и я предполагаю, что вы хотите, чтобы ваш код дождался, пока соединение будет бесплатным. CF делает это уже для соединений с базой данных.

В вашем случае нет необходимости хранить что-либо в пуле (поскольку HTTP-соединения не долговечны), за исключением разрешения на использование ресурса. Java предоставляет класс, который должен предоставить то, что вам нужно, Semaphore.

Я не пробовал, но в теории, что-то вроде сниппета ниже должно работать:

//Application.cfc:onApplicationStart() 
application.http_pool = CreateObject("java","java.util.concurrent.Semaphore").init(3) 

//Meanwhile, elsewhere in your code 
application.http_pool.acquire() 
//Make my HTTP call 
application.http_pool.release() 

Вы можете даже обернуть объект HTTP, чтобы обеспечить эту функциональность без использования приобретаемой/релиз каждый времени, что сделает его более надежным.

EDIT Это вы хотите ограничить тарифы, посмотрите на guava, который имеет тот же общий интерфейс, что и Семафор, но реализует ограничение скорости для вас. Вам нужно будет добавить guava в classpath ColdFusion или использовать JavaLoader или использовать CF10, который имеет встроенные средства загрузки классов.