PHP Предотвращение выполнения функции синхронной (дросселировании пределов через PHP)

Question

У меня есть функция, которые посылают запрос HTTP на www.server.com

Моей задачу с помощью CURL, чтобы убедиться, что www.server.com получает не более один запрос каждые 2 секунды.

Возможное решение:

Создайте функцию checktime(), которая будет хранить текущее время вызова в базе данных и проверить с базой данных на каждом следующем вызове и сделать паузу системы в течение 2-х секунд:

$oldTime = $this->getTimeFromDatabase(); 
if ($oldTime < (time() - 2)) { // if its been 2 seconds 
    $this->setNewTimeInDatabase(); 
    return true; 
} else { 
    sleep(2); 
    return false; 
} 

проблемы/вопрос:

Скажем, последний запрос на www.server.com был на 1361951000. Затем 10 других пользователей попытаются выполнить запрос по телефону 1361951001 (1 секунда спустя). checktime() Функция будет называться.

Поскольку, поскольку прошло только 1 секунда, функция вернет значение false. Все 10 пользователей будут ждать 2 секунды. Означает ли это, что на 1361951003 будет отправлено 10 запросов одновременно? И возможно ли, что время последнего запроса не будет изменено в базе данных из-за пропущенного вызова $ this-> setNewTimeInDatabase() в checktime()?

Спасибо!

UPDATE:

Я только что сказали, что с помощью цикла может решить эту проблему:

for($i=0;$i<300;$i++) 
{ 
    $oldTime = $this->getTimeFromDatabase(); 
    if ($oldTime < (time() - 2)) { // if its been 2 seconds 
    $this->setNewTimeInDatabase(); 
    return true; 
    } else { 
    sleep(2); 
    return false; 
    } 
} 

Но я не вижу логики в этом.

Answer 1

Я считаю, что вам нужна реализация semaphore. База данных может работать, если вы можете гарантировать, что только один поток получит запись в db, а затем сделает запрос.

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

$oldTime = $this->getTimeFromDatabase(); 
if ($oldTime < (time() - 2) && $this->getLock()) { // if its been 2 seconds 
    $this->setNewTimeInDatabase(); 
    $this->releaseLock(); 
    return true; 
} else { 
    sleep(2); 
    return false; 
} 

function getLock() 
{ 
    return $mysqli->query('UPDATE locktable set locked = 1 WHERE locked = 0'); 
} 

function releaseLock() 
{ 
    $mysqli->query('UPDATE locktable set locked = 0'); 
} 

Я не уверен, о функциях MySQL, но я считаю, что это нормально, чтобы получить общее представление.

Answer 2

Остерегайтесь использования базы данных. Например, MySQL не всегда на 100% синхронизируется со своими сеансами, и по этой причине небезопасно полагаться на это для целей блокировки.

Вы можете использовать блокировку файлов с помощью метода flock, в котором вы должны сохранить время доступа. Тогда вы можете быть уверены, что заблокируете файл, поэтому два или более процесса никогда не будут обращаться к нему в одно и то же время.

Было бы, вероятно, пойти что-то вроде этого:

$filepath = "lockfile_for_source"; 
touch($filepath); 
$fp = fopen("lockfile_for_resource", "r") or die("Could not open file."); 

while(true){ 
    while(!flock($fp, LOCK_EX)){ 
    sleep(0.25); //wait to get file-lock. 
    } 

    $time = file_get_contents($filepath); 
    $diff = time() - $time; 
    if ($diff >= 2){ 
    break; 
    }else{ 
    flock($fp, LOCK_UN); 
    } 
} 

//Following code would never be executed simultaneously by two scripts. 
//You should access and use your resource here. 

fwrite($fp, time()); 
fflush($fp); 
flock($fp, LOCK_UN); //remove lock on file. 
fclose($fp); 

Пожалуйста, обратите внимание, что я не проверял код.