Как пользоваться flock()?

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

Представим себе, что есть разные программные потоки, одни из которых читают данные — «читатели», а другие их меняют — «писари». Ясно, что «читатель» должен дождаться пока операции записи завершатся. При этом несколько «читателей» не мешают друг другу.

Семафор

Чтобы блокировка работала, необходимо использовать один и тот же способ блокировки. Иными словами, flock() нужно вызывать как при чтении, так и при записи.

В случае с «семафорным» файлом код может выглядеть вот так:

//поток читателя
$semHandler = fopen($filename, 'r');
if (flock($semHandler, LOCK_SH)) {
   //выполняем операции чтения
}
flock($semHandler, LOCK_UN);
fclose($semHandler);

//поток писаря
$semHandler = fopen($filename, 'r');
if (flock($semHandler, LOCK_EX)) {
   //выполняем операции записи
}
flock($semHandler, LOCK_UN);
fclose($semHandler);

//поток читателя

$semHandler = fopen($filename, 'r');

if (flock($semHandler, LOCK_SH)) {

//выполняем операции чтения

}

flock($semHandler, LOCK_UN);

fclose($semHandler);

//поток писаря

$semHandler = fopen($filename, 'r');

if (flock($semHandler, LOCK_EX)) {

//выполняем операции записи

}

flock($semHandler, LOCK_UN);

fclose($semHandler);

Т.е. мы проводим блокировку некого файла-семафора, а запись и чтение проводится с другими объектами.

Блокировка

Если нужно провести блокировку объекта, с которым проводятся непосредственные операции чтения-записи, то открывать файл «писарем» потребуется в специальном режиме. Режимы ‘w’ и ‘w+’ тут не подходят, т.к. до получения блокировки, содержимое файла менять нельзя.

//поток писаря
$fh = fopen($filename, 'c');
if (flock($fh, LOCK_EX)) {
   //блокировка получена, теперь можно менять файл
   //удалили данные
   ftruncate($fh, 0); 
   //перезаписали
   fwrite($fh, $data);
}
//сняли блокировку
flock($fh, LOCK_UN);
fclose($fh);

//поток писаря

$fh = fopen($filename, 'c');

if (flock($fh, LOCK_EX)) {

//блокировка получена, теперь можно менять файл

//удалили данные

ftruncate($fh, 0);

//перезаписали

fwrite($fh, $data);

}

//сняли блокировку

flock($fh, LOCK_UN);

fclose($fh);

Для полноты примера, приведу код потока-читателя:

//поток читателя
$fh = fopen($filename, 'r');
if (flock($fh, LOCK_SH)) {
   //блокировка получена, теперь можно читать данные
   $data = @fread($fh, filesize($filename)); 
}
//сняли блокировку
flock($fh, LOCK_UN);
fclose($fh);

//поток читателя

$fh = fopen($filename, 'r');

if (flock($fh, LOCK_SH)) {

//блокировка получена, теперь можно читать данные

$data = @fread($fh, filesize($filename));

}

//сняли блокировку

flock($fh, LOCK_UN);

fclose($fh);

Блокировка с тайм-аутом

По умолчанию flock() ждет получения блокировки. Сколько продлится ожидание не известно, но можно использовать флаг LOCK_NB, чтобы не ждать, а самим решать, что делать дальше.

В данном примере ожидание продлится не более 50 мсек.

//поток читателя
$fh = fopen($filename, 'r');
$timeout_secs = 50; 
$got_lock = true;

while (!flock($fh, LOCK_SH | LOCK_NB, $wouldblock)) {
   if ($wouldblock && --$timeout_secs > 0) {
      sleep(1);
   } else {
      $got_lock = false;
      break;
   }
} 
if ($got_lock) {
   //дождались блокировки, читаем данные
   $data = @fread($fh, filesize($filename)); 
   flock($fh, LOCK_UN);
} else {
   //доступ не удалось получить за отведенное время 
   ...  
}
fclose($fh);

//поток читателя

$fh = fopen($filename, 'r');

$timeout_secs = 50;

$got_lock = true;

while (!flock($fh, LOCK_SH | LOCK_NB, $wouldblock)) {

if ($wouldblock && --$timeout_secs > 0) {

sleep(1);

} else {

$got_lock = false;

break;

}

if ($got_lock) {

//дождались блокировки, читаем данные

$data = @fread($fh, filesize($filename));

flock($fh, LOCK_UN);

} else {

//доступ не удалось получить за отведенное время

...

}

fclose($fh);

Если еще остались вопросы — пишите в комментариях. :)

Написать комментарий

Данная запись опубликована в 24.03.2017 06:28 и размещена в рубрике PHP. Вы можете перейти в конец страницы и оставить ваш комментарий.

Мало букафф? Читайте есчо !

Обращение к свойству объекта/класса в PHP, если имя св-ва хранится в переменной

Декабрь 12, 2013 г.

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

Читать

Замена первого/последнего значения в строке на PHP

Октябрь 28, 2022 г.

Задача - заменить первое/последнее искомое значение в заданной строке. В PHP много уделяется внимания работы со строками, но вот оптимального решения для этой задачи нет. Функция str_replace, заменяет все значения, но может посчитать вам сколько ...

Читать

Отправить PUT запрос через cUrl в PHP

Май 19, 2021 г.

Делюсь примером кода, который отправляет PUT запрос через CURL. Все работает точно также как для POST запроса, с небольшими отличиями в настройках: [crayon-69a82465640ab892519800/] Надеюсь, этот пример сэкономит вам время :)

Читать

Urlencode расширенная практика применения

Февраль 8, 2017 г.

UrlEncode - php-функция, которая подготавливает значение для использования его как часть html ссылки, заменяя спец. символы, кириллицу и т.п. на закодированные ...

Читать

Комментарии к «Как пользоваться flock()?»

Понравилась статья? Есть вопросы? - пишите в комментариях.

Имя (обязательно)	Е-майл (не будет опубликован на сайте, обязательно для заполнения)
Комментарий: