PHP: полный мануал с примерами, функциями и ООП

<?php
declare(strict_types=1);

$memory = shm_attach(0, 16384, 0600);
if ($memory === false) throw new RuntimeException('Нет общей памяти');
try {
    if (!shm_put_var($memory, 101, 7)) throw new RuntimeException('Запись не удалась');
    echo shm_get_var($memory, 101), "\n";
} finally { shm_remove($memory); shm_detach($memory); }

7

0 — приватный новый сегмент, 16384 — байты всего хранилища, 0600 — восьмеричные права владельца на Unix. Размер включает служебные данные и сериализацию. Код исполняется последовательно, конкурентных авторов нет.

<?php
declare(strict_types=1);

try { shm_attach(0, 0, 0600); }
catch (ValueError $error) { echo "Размер должен быть положительным\n"; }

Размер должен быть положительным

Нулевая ёмкость запрещена ещё до создания сегмента. Положительный размер тоже может быть недостаточен для заголовка либо превышать системный лимит.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-memory.php';
$memory = lessonMemory();
try {
$stock = ['A42' => 7, 'B17' => 3];
if (!shm_put_var($memory, 101, $stock)) throw new RuntimeException('Не сохранено');
$stock['A42'] = 99;
echo shm_get_var($memory, 101)['A42'], "\n";
} finally { shm_remove($memory); shm_detach($memory); }

7

Запись — снимок, не привязка к $stock. Для публикации 99 требуется новая запись. Нет необходимости вручную serialize перед shm_put_var.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-memory.php';
$memory = lessonMemory(4096);
try {
    if (!shm_put_var($memory, 101, 'старый снимок')) throw new RuntimeException('Нет места');
    set_error_handler(static fn() => true, E_WARNING);
    try { $saved = shm_put_var($memory, 101, str_repeat('x', 20000)); }
    finally { restore_error_handler(); }
    echo $saved ? "Записано\n" : "Новый снимок не записан\n";
    echo shm_has_var($memory, 101) ? "Старый остался\n" : "Старого тоже нет\n";
} finally { shm_remove($memory); shm_detach($memory); }

Новый снимок не записан
Старого тоже нет

В PHP 8.5.11 реализация удаляет старую запись перед проверкой места для новой. Это не транзакционная замена: нельзя обещать читателю сохранение старого снимка при false. Warning подавлен только вокруг намеренного отказа и результат всё равно проверен.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-memory.php';
$memory = lessonMemory();
try {
shm_put_var($memory, 101, ['A42' => 7]);
$stock = shm_get_var($memory, 101);
$stock['A42']--;
echo $stock['A42'], ' / ', shm_get_var($memory, 101)['A42'], "\n";
} finally { shm_remove($memory); shm_detach($memory); }

6 / 7

6 осталось в локальном массиве, 7 — в общей памяти. Прочитать → изменить → записать при нескольких авторах нужно под одним семафором на всём участке.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-memory.php';
$memory = lessonMemory();
try {
shm_put_var($memory, 102, false);
foreach ([102, 103] as $key) {
    if (!shm_has_var($memory, $key)) { echo "$key: отсутствует\n"; continue; }
    $value = shm_get_var($memory, $key);
    echo "$key: ", $value === false ? 'сохранён false' : 'другое', "\n";
}
} finally { shm_remove($memory); shm_detach($memory); }

102: сохранён false
103: отсутствует

Один процесс, поэтому между has/get никто не меняет состояние. При конкуренции эта пара нуждается в общей блокировке. Сравнение результата с false в одиночку неоднозначно.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-memory.php';
$memory = lessonMemory();
try {
shm_put_var($memory, 101, null);
echo shm_has_var($memory, 101) ? "101 существует\n" : "101 нет\n";
echo shm_has_var($memory, 102) ? "102 существует\n" : "102 нет\n";
} finally { shm_remove($memory); shm_detach($memory); }

101 существует
102 нет

В отличие от isset обычного массива, shm_has_var видит существующую запись с null.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-memory.php';
$memory = lessonMemory();
try {
foreach ([1, 2] as $attempt) {
    if (!shm_has_var($memory, 101)) {
        shm_put_var($memory, 101, 0);
        echo "Создан счётчик\n";
    } else { echo "Счётчик уже есть\n"; }
}
} finally { shm_remove($memory); shm_detach($memory); }

Создан счётчик
Счётчик уже есть

Два последовательных прохода показывают условие. Это ещё не конкурентный create-if-absent. Для реальных workers весь if и put защищаются одним общим семафором.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-memory.php';
$memory = lessonMemory();
try {
shm_put_var($memory, 101, 'импорт A');
shm_put_var($memory, 102, 'импорт B');
if (!shm_remove_var($memory, 101)) throw new RuntimeException('Не удалено');
echo shm_has_var($memory, 101) ? "A есть\n" : "A удалён\n";
echo shm_get_var($memory, 102), "\n";
} finally { shm_remove($memory); shm_detach($memory); }

A удалён
импорт B

Сегмент продолжает работать. shm_remove_var не удаляет IPC ресурс целиком.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-memory.php';
$memory = lessonMemory();
try {
shm_put_var($memory, 101, 'готово');
foreach ([1, 2] as $attempt) {
    if (!shm_has_var($memory, 101)) { echo "Уже очищено\n"; continue; }
    if (!shm_remove_var($memory, 101)) throw new RuntimeException('Очистка не удалась');
    echo "Очищено\n";
}
} finally { shm_remove($memory); shm_detach($memory); }

Очищено
Уже очищено

Для отсутствующего ключа remove_var сам выдаёт warning и false. Здесь guard делает повторную последовательную очистку понятной; конкурентная проверка/удаление требует lock.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-memory.php';
$memory = lessonMemory();
try { shm_put_var($memory, 101, 7); }
finally {
    if (!shm_remove($memory)) throw new RuntimeException('Не отмечен к удалению');
    echo shm_detach($memory) ? "Подключение закрыто\n" : "Отказ\n";
}

Подключение закрыто

Владелец сначала помечает ресурс к удалению, пока ручка ещё действительна, затем отсоединяется. В обычном читателе общего Unix сегмента нужен только detach, удаление поручено владельцу.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-memory.php';
$memory = lessonMemory();
shm_remove($memory);
shm_detach($memory);
try { shm_has_var($memory, 101); }
catch (Error $error) { echo "Подключение уже закрыто\n"; }

Подключение уже закрыто

Сам объект переменной существует, но доступа к памяти уже нет. Это не проверяется через isset($memory).

<?php
declare(strict_types=1);

$memory = shm_attach(0, 16384, 0600);
if ($memory === false) throw new RuntimeException('Не создано');
try {
    echo shm_remove($memory) ? "Удаление запрошено\n" : "Удаление не удалось\n";
} finally { shm_detach($memory); }

Удаление запрошено

На Unix IPC_RMID помечает сегмент; фактическое освобождение после последнего detach. Пример не перебирает системные ключи и не затрагивает чужую память.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-memory.php';
$memory = lessonMemory();
try {
shm_put_var($memory, 101, 'черновик');
shm_put_var($memory, 102, 'итог');
shm_remove_var($memory, 101);
echo shm_get_var($memory, 102), "\n";
echo "После чтения владелец завершит весь сегмент\n";
} finally { shm_remove($memory); shm_detach($memory); }

итог
После чтения владелец завершит весь сегмент

В finally helper-примера вызываются remove и detach. До него запись 102 доступна; remove_var(101) не равнозначен remove($memory).

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-memory.php';
$memory = lessonMemory();
try {
echo $memory instanceof SysvSharedMemory ? "Это ручка общей памяти\n" : "Другой тип\n";
} finally { shm_remove($memory); shm_detach($memory); }

Это ручка общей памяти

Проверять is_resource после обновления до PHP 8 неправильно. Объект передают в shm_* функции.

<?php
declare(strict_types=1);

try { new SysvSharedMemory(); }
catch (Error $error) { echo "Используйте shm_attach\n"; }

Используйте shm_attach

new не знает ни key, ни size, ни правил ОС. Фабричная функция создаёт действительное подключение.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
$info = msg_stat_queue($queue);
if ($info === false) throw new RuntimeException('Нет состояния');
echo 'Заданий: ', $info['msg_qnum'], "\n";
} finally { msg_remove_queue($queue); }

Заданий: 0

Файл ipc-queue.php входит в пример. Он создаёт key=0 и явно назначает права 0600. Особенность текущей реализации: первый msgget(0,0) уже создаёт приватную очередь без указанных прав; поэтому helper вызывает msg_set_queue до отправки. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

$key = ftok(__DIR__ . '/app.ipc', 'Q');
if ($key === -1 || $key === 0) throw new RuntimeException('Не получен общий ключ');
$queue = msg_get_queue($key, 0600);
if ($queue === false) throw new RuntimeException('Очередь недоступна');
echo $queue instanceof SysvMessageQueue ? "Очередь подключена\n" : "Ошибка\n";
// Worker does NOT remove the application's shared queue here.

Очередь подключена

Контекст: выделенный Unix IPC namespace приложения, файл app.ipc заранее создал владелец; владелец также отвечает за удаление очереди после остановки workers. Пример worker не вызывает remove при каждом завершении. Существующий ключ может обозначать чужой объект: ftok не даёт гарантии уникальности. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
$error = 0;
if (!msg_send($queue, 1, 'заказ 42', false, false, $error)) {
    throw new RuntimeException('Не отправлено, errno=' . $error);
}
$type = 0; $message = ''; $error = 0;
if (!msg_receive($queue, 1, $type, 1024, $message, false, MSG_IPC_NOWAIT, $error)) {
    throw new RuntimeException('Не получено');
}
echo $type, ': ', $message, "\n";
} finally { msg_remove_queue($queue); }

1: заказ 42

Первое false отключает PHP сериализацию, второе запрещает ждать заполненную очередь. $error — выходной аргумент по ссылке: функция сама записывает системный errno при отказе. Получатель использует соответствующее unserialize=false. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
$job = ['orderId' => 42, 'action' => 'reserve'];
$json = json_encode($job, JSON_THROW_ON_ERROR);
$error = 0;
if (!msg_send($queue, 2, $json, false, false, $error)) {
    throw new RuntimeException($error === MSG_EAGAIN ? 'Очередь заполнена' : 'Ошибка отправки');
}
$type = 0; $payload = '';
if (!msg_receive($queue, 2, $type, 4096, $payload, false, MSG_IPC_NOWAIT, $error)) {
    throw new RuntimeException('Нет задания');
}
$received = json_decode($payload, true, 512, JSON_THROW_ON_ERROR);
if (!is_array($received) || !is_int($received['orderId'] ?? null)) {
    throw new RuntimeException('Неверный контракт');
}
echo 'Обработать заказ ', $received['orderId'], "\n";
} finally { msg_remove_queue($queue); }

Обработать заказ 42

JSON кодирует структуру в строку; msg_send передаёт байты, а не HTTP. Получатель проверяет поля после JSON разбора. При MSG_EAGAIN приложение сохраняет задание для контролируемого повтора либо честно возвращает занятость. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
$error = 0;
if (!msg_send($queue, 1, ['orderId' => 42, 'quantity' => 2], true, false, $error)) {
    throw new RuntimeException('Массив не отправлен');
}
$type = 0; $job = null;
if (!msg_receive($queue, 1, $type, 4096, $job, true, MSG_IPC_NOWAIT, $error)) {
    throw new RuntimeException('Массив не получен');
}
if (!is_array($job) || !is_int($job['quantity'] ?? null)) throw new RuntimeException('Неверный контракт');
echo 'Количество: ', $job['quantity'], "\n";
} finally { msg_remove_queue($queue); }

Количество: 2

Обе стороны согласовали PHP serialize/unserialize, поэтому ручного JSON разбора нет. Формат подходит только доверенным PHP участникам; разрешение посторонним писать сериализованные объекты недопустимо. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
$error = 0;
foreach ([3 => 'обычное', 1 => 'срочное', 2 => 'среднее'] as $type => $text) {
    if (!msg_send($queue, $type, $text, false, false, $error)) throw new RuntimeException('Не отправлено');
}
$type = 0; $message = '';
if (!msg_receive($queue, -3, $type, 1024, $message, false, MSG_IPC_NOWAIT, $error)) {
    throw new RuntimeException('Нет подходящего сообщения');
}
echo $type, ': ', $message, "\n";
} finally { msg_remove_queue($queue); }

1: срочное

На Unix отрицательный selector -3 выбирает первый элемент наименьшего типа ≤ 3. Это не первое по времени сообщение любого типа ≤ 3. Частые приоритетные задания могут оттеснять обычные; нужна политика справедливости. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
$type = 0; $message = null; $error = 0;
$received = msg_receive($queue, 0, $type, 4096, $message, false, MSG_IPC_NOWAIT, $error);
if (!$received && $error === MSG_ENOMSG) {
    echo "Сейчас нет заданий\n";
} elseif (!$received) { throw new RuntimeException('Ошибка очереди: ' . $error); }
else { echo "Получено задание\n"; }
} finally { msg_remove_queue($queue); }

Сейчас нет заданий

MSG_ENOMSG находится в $error, возвращаемое значение функции — false. Не читайте старое значение $message после отказа и не крутите безостановочный busy loop. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
$error = 0;
msg_send($queue, 1, 'ORDER-42', false, false, $error);
$type = 0; $message = '';
$short = msg_receive($queue, 1, $type, 3, $message, false, MSG_IPC_NOWAIT, $error);
echo $short ? "Прочитано\n" : "Буфер мал, сообщение остаётся\n";
if (!msg_receive($queue, 1, $type, 32, $message, false, MSG_IPC_NOWAIT, $error)) {
    throw new RuntimeException('Повторное чтение не удалось');
}
echo $message, "\n";
} finally { msg_remove_queue($queue); }

Буфер мал, сообщение остаётся
ORDER-42

Без MSG_NOERROR слишком длинное сообщение не извлекается (E2BIG). Повтор с тем же малым буфером не поможет. С MSG_NOERROR хвост был бы отброшен навсегда: для JSON заказа такой режим неприемлем. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

$key = ftok(__DIR__ . '/app.ipc', 'Q');
if ($key === -1 || $key === 0) throw new RuntimeException('Ключ не получен');
echo msg_queue_exists($key) ? "Очередь уже есть\n" : "Очередь пока не найдена\n";

Очередь уже есть ИЛИ Очередь пока не найдена (зависит от стенда).

Только проверка согласованного ключа, без создания и удаления. false не доказывает, что у процесса достаточно прав, чтобы создать очередь. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

$key = ftok(__DIR__ . '/app.ipc', 'Q');
if ($key === -1 || $key === 0) throw new RuntimeException('Ключ не получен');
if (!msg_queue_exists($key)) { echo "Попросите владельца запустить сервис\n"; }
else {
    // An external shutdown may happen after the condition.
    echo "Нужны ещё проверки результатов get/send/receive\n";
}

Одна из двух диагностических строк в зависимости от состояния стенда.

В production выбранный supervisor управляет жизнью очереди; worker всё равно проверяет каждый вызов. Нельзя удалять очередь только потому, что она «уже существует». Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
$error = 0;
msg_send($queue, 1, 'заказ 42', false, false, $error);
$before = msg_stat_queue($queue);
$type = 0; $message = '';
msg_receive($queue, 1, $type, 1024, $message, false, MSG_IPC_NOWAIT, $error);
$after = msg_stat_queue($queue);
if ($before === false || $after === false) throw new RuntimeException('Нет статистики');
echo $before['msg_qnum'], ' → ', $after['msg_qnum'], "\n";
} finally { msg_remove_queue($queue); }

1 → 0

При активных других workers счётчик может измениться сразу после чтения. Он не гарантирует успешность следующего receive. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
$info = msg_stat_queue($queue);
if ($info === false) throw new RuntimeException('Нет состояния');
printf("Права: %04o\n", $info['msg_perm.mode'] & 0777);
echo $info['msg_qbytes'] > 0 ? "Ёмкость назначена ОС\n" : "Проверьте лимит\n";
} finally { msg_remove_queue($queue); }

Права: 0600
Ёмкость назначена ОС

msg_qbytes — ёмкость очереди в байтах, не длина текущего сообщения и не число элементов. Не зашиваем системный лимит в ожидаемый результат. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
if (!msg_set_queue($queue, ['msg_perm.mode' => 0600])) throw new RuntimeException('Нет прав');
$state = msg_stat_queue($queue);
if ($state === false) throw new RuntimeException('Нет состояния');
printf("Доступ %04o\n", $state['msg_perm.mode'] & 0777);
} finally { msg_remove_queue($queue); }

Доступ 0600

0600 — запись в восьмеричной системе. Передача десятичного 600 означает другие биты. Разрешения регулируют доступ локальных пользователей, не сетевую авторизацию. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
$state = msg_stat_queue($queue);
if ($state === false || $state['msg_qbytes'] < 1) throw new RuntimeException('Нет лимита');
$budget = min(1024, $state['msg_qbytes']);
if (!msg_set_queue($queue, ['msg_qbytes' => $budget])) throw new RuntimeException('Лимит не изменён');
$changed = msg_stat_queue($queue);
if ($changed === false) throw new RuntimeException('Нет состояния');
echo $changed['msg_qbytes'] === $budget ? "Бюджет применён\n" : "Проверьте ОС\n";
} finally { msg_remove_queue($queue); }

Бюджет применён

Пример не повышает системные лимиты и не требует root. Ограничение создаёт обратное давление; оно не исправляет медленный worker и не увеличивает лимит одного сообщения. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try { echo "Эксперимент закончен\n"; }
finally {
    if (!msg_remove_queue($queue)) throw new RuntimeException('Очередь не удалена');
    echo "Очередь удалена владельцем\n";
}

Эксперимент закончен
Очередь удалена владельцем

В finally удаляется только очередь, созданная этим запуском с приватным ключом. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
    $error = 0;
    if (!msg_send($queue, 1, 'учебное задание', false, false, $error)) throw new RuntimeException('Не отправлено');
    $state = msg_stat_queue($queue);
    if ($state === false) throw new RuntimeException('Нет состояния');
    echo 'Будет потеряно сообщений: ', $state['msg_qnum'], "\n";
} finally { msg_remove_queue($queue); }

Будет потеряно сообщений: 1

Это специально созданное учебное сообщение. Для настоящей остановки решите заранее: дождаться обработки, сохранить задания или отменить их по явному договору; remove не сохраняет их автоматически. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-queue.php';
$queue = lessonQueue();
try {
echo $queue instanceof SysvMessageQueue ? "Ручка очереди\n" : "Другой тип\n";
} finally { msg_remove_queue($queue); }

Ручка очереди

До PHP 8 использовался resource. Обновляйте проверки вместе с версией PHP. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

try { new SysvMessageQueue(); }
catch (Error $error) { echo "Создавайте очередь через msg_get_queue\n"; }

Создавайте очередь через msg_get_queue

Здесь системный ресурс не создаётся. Получение валидной ручки требует ключа и проверки системного результата. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-semaphore.php';
$semaphore = lessonSemaphore(1);
try {
if (!sem_acquire($semaphore, true)) throw new RuntimeException('Пропуск недоступен');
try { echo "Внутри защищённого участка\n"; }
finally { sem_release($semaphore); }
} finally { sem_remove($semaphore); }

Внутри защищённого участка

key=0 даёт новый приватный семафор; max_acquire=1, 0600 и auto_release=true переданы в helper. Один вызов get ещё ничего не блокирует: пропуск запрашивается через acquire. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-semaphore.php';
$semaphore = lessonSemaphore(2);
try {
$held = 0;
try {
    for ($attempt = 1; $attempt <= 3; $attempt++) {
        if (sem_acquire($semaphore, true)) { $held++; echo "$attempt: пропуск\n"; }
        else { echo "$attempt: пока нет места\n"; }
    }
} finally {
    while ($held > 0) { sem_release($semaphore); $held--; }
}
} finally { sem_remove($semaphore); }

1: пропуск
2: пропуск
3: пока нет места

Один процесс последовательно занимает два доступных слота, чтобы показать счётчик без fork. Это ограничитель параллельности, не ограничитель запросов в секунду: для временного rate limit нужна другая логика. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-semaphore.php';
$semaphore = lessonSemaphore(1);
try {
if (!sem_acquire($semaphore, true)) throw new RuntimeException('Первый захват не удался');
try {
    if (!sem_acquire($semaphore, true)) echo "Занято: отложить действие\n";
    else { sem_release($semaphore); throw new RuntimeException('Неожиданный второй пропуск'); }
} finally { sem_release($semaphore); }
} finally { sem_remove($semaphore); }

Занято: отложить действие

При max=1 повторный блокирующий acquire этим же кодом ждал бы разрешения, которое сам код не успеет вернуть. Семафор не является рекурсивной блокировкой. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-semaphore.php';
$semaphore = lessonSemaphore(1);
try {
if (!sem_acquire($semaphore, true)) throw new RuntimeException('Занято');
try {
    try { throw new RuntimeException('Неверная строка импорта'); }
    finally { sem_release($semaphore); }
} catch (RuntimeException $error) { echo "Ошибка разобрана\n"; }
if (!sem_acquire($semaphore, true)) throw new RuntimeException('Пропуск потерян');
try { echo "Следующий импорт может работать\n"; }
finally { sem_release($semaphore); }
} finally { sem_remove($semaphore); }

Ошибка разобрана
Следующий импорт может работать

Внешний catch отвечает за смысл ошибки, внутренний finally — за освобождение. Не удерживайте lock во время долгого HTTP запроса, если можно подготовить данные заранее и кратко опубликовать результат. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-semaphore.php';
$semaphore = lessonSemaphore(1);
try {
foreach (['импорт', 'отчёт'] as $operation) {
    if (!sem_acquire($semaphore, true)) throw new RuntimeException('Занято');
    try { echo $operation, "\n"; }
    finally {
        if (!sem_release($semaphore)) throw new RuntimeException('Пропуск не возвращён');
    }
}
} finally { sem_remove($semaphore); }

импорт
отчёт

Обе операции используют один набор. Они выполняются последовательно и не требуют создать новый семафор после release. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-semaphore.php';
$semaphore = lessonSemaphore(1);
try {
set_error_handler(static fn() => true, E_WARNING);
try { $released = sem_release($semaphore); }
finally { restore_error_handler(); }
echo $released ? "Освобождён\n" : "Нечего освобождать\n";
} finally { sem_remove($semaphore); }

Нечего освобождать

Намеренно не было acquire. Функция сообщает warning и false; перехватывается только ожидаемый warning в этом эксперименте. Release не является способом «на всякий случай разблокировать чужой процесс». Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-semaphore.php';
$semaphore = lessonSemaphore();
try { echo "Участников больше нет\n"; }
finally {
    if (!sem_remove($semaphore)) throw new RuntimeException('Набор не удалён');
    echo "Набор удалён\n";
}

Участников больше нет
Набор удалён

Приватный key=0 гарантирует, что это ресурс текущего примера. Согласованный ненулевой key production удаляет только владелец после координации. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-semaphore.php';
$semaphore = lessonSemaphore();
try {
    if (!sem_acquire($semaphore, true)) throw new RuntimeException('Не захвачен');
    try { echo "Работа выполнена\n"; }
    finally { sem_release($semaphore); echo "Пропуск возвращён\n"; }
} finally { sem_remove($semaphore); echo "Учебный набор удалён\n"; }

Работа выполнена
Пропуск возвращён
Учебный набор удалён

В реальном сервисе владелец отдельно знает, что других workers больше нет. Только факт вашего release этого не доказывает. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

require __DIR__ . '/ipc-semaphore.php';
$semaphore = lessonSemaphore(1);
try {
echo $semaphore instanceof SysvSemaphore ? "Объект системного семафора\n" : "Другой тип\n";
echo "Сам факт существования объекта не означает захват\n";
} finally { sem_remove($semaphore); }

Объект системного семафора
Сам факт существования объекта не означает захват

Переменная true в обычном массиве процесса не заменяет согласованный межпроцессный semaphore. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

try { new SysvSemaphore(); }
catch (Error $error) { echo "Используйте sem_get\n"; }

Используйте sem_get

Нет публичного конструктора, сериализации, клонирования и динамических полей. Для собственного класса сервиса храните эту ручку в обычном свойстве и явно управляйте доступом. Контекстный пример для Unix CLI с указанными расширениями и разрешённым SysV IPC. Здесь проверен синтаксис; выполнение Unix IPC не заявляется.

<?php
declare(strict_types=1);

$first = ftok(__DIR__ . '/app.ipc', 'Q');
$second = ftok(__DIR__ . '/app.ipc', 'Q');
if ($first === -1 || $second === -1) throw new RuntimeException('Ключ не получен');
echo $first === $second ? "Участники получили один ключ\n" : "Файл изменился\n";

Участники получили один ключ

Файл app.ipc приложен к примеру. Числовое значение зависит от ОС и файла, поэтому оно намеренно не зафиксировано. Замена файла новым может поменять key.

<?php
declare(strict_types=1);

try { ftok(__DIR__ . '/app.ipc', 'QUEUE'); }
catch (ValueError $error) { echo "Нужна однобайтовая метка, например Q\n"; }

Нужна однобайтовая метка, например Q

В современном PHP project_id должен состоять ровно из одного байта. Буква кириллицы в UTF-8 занимает несколько байтов, поэтому используйте ASCII метку.