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

PHP 4.1.0+ · sockets

socket_create(int $domain, int $type, int $protocol): Socket|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$listener = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($listener === false) { throw new RuntimeException('Не создан слушатель'); }
if (!socket_bind($listener, '127.0.0.1', 0)) { throw new RuntimeException('Адрес не привязан'); }
if (!socket_listen($listener, 2)) { throw new RuntimeException('Очередь не создана'); }
if (!socket_getsockname($listener, $address, $port)) { throw new RuntimeException('Адрес не прочитан'); }
$client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($client === false || !socket_connect($client, $address, $port)) { throw new RuntimeException('Клиент не подключён'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Клиент не принят'); }
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Подготовить конечную точку, через которую программа будет обмениваться байтами или сообщениями.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. AF_INET выбирает семейство IPv4, SOCK_STREAM — упорядоченный поток байтов, SOL_TCP — TCP. Создание endpoint само не делает его сервером и не подключает к адресу. instanceof проверяет класс, socket_close освобождает endpoint.

<?php
declare(strict_types=1);

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket === false) throw new RuntimeException(socket_strerror(socket_last_error()));
echo $socket instanceof Socket ? "Создан Socket для IPv4 TCP\n" : "Неожиданный результат\n";
socket_close($socket);

Создан Socket для IPv4 TCP

Этот вариант. Функция возвращает открытый объект, которым теперь владеет вызывающий код. UDP сохраняет границы сообщений, но не гарантирует доставку/порядок. Создание не отправило показание.

<?php
declare(strict_types=1);

function createTelemetrySocket(): Socket {
    $socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
    if ($socket === false) throw new RuntimeException(socket_strerror(socket_last_error()));
    return $socket;
}
$socket = createTelemetrySocket();
try {
    echo socket_get_option($socket, SOL_SOCKET, SO_TYPE) === SOCK_DGRAM
        ? "Готов endpoint для отдельных UDP сообщений\n" : "Неверный тип\n";
} finally { socket_close($socket); }

Готов endpoint для отдельных UDP сообщений

Доступные типы: STREAM — надёжный двусторонний поток (обычно TCP); DGRAM — сообщения без гарантии доставки (обычно UDP); SEQPACKET — надёжные сообщения с границами; RAW — низкоуровневые пакеты с правами ОС; RDM — надёжные datagrams без гарантии порядка, часто не реализованы. AF_UNIX служит локальному IPC, AF_INET6 — IPv6. AF_PACKET поддержан PHP 8.5 на Linux для уровня 2 и обычно требует специальных прав; он не является переносимой заменой TCP.

Протокол 0 просит подходящий default ОС для выбранного сочетания; для TCP/UDP понятнее SOL_TCP/SOL_UDP. Номер иного протокола можно получить getprotobyname. Биты SOCK_NONBLOCK/SOCK_CLOEXEC с PHP 8.4 доступны только где их предоставляет ОС. В актуальном PHP 8.5 неверное семейство и явно недопустимый тип могут дать ValueError: старое описание PHP.net о warning и молчаливой подстановке AF_INET/SOCK_STREAM не следует применять к этой версии. Остальные неподдержанные сочетания обычно дают warning + false.

Связанные действия: socket_bind, socket_connect, socket_close.

• PHP: socket_create

PHP 4.1.0+ · sockets

socket_bind(Socket $socket, string $address, int $port = 0): bool

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$listener = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($listener === false) { throw new RuntimeException('Не создан слушатель'); }
if (!socket_bind($listener, '127.0.0.1', 0)) { throw new RuntimeException('Адрес не привязан'); }
if (!socket_listen($listener, 2)) { throw new RuntimeException('Очередь не создана'); }
if (!socket_getsockname($listener, $address, $port)) { throw new RuntimeException('Адрес не прочитан'); }
$client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($client === false || !socket_connect($client, $address, $port)) { throw new RuntimeException('Клиент не подключён'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Клиент не принят'); }
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Назначить собственный адрес endpoint: где принимать данные или с какого интерфейса подключаться.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Порт 0 при bind означает «выбрать свободный», не порт удалённого сервиса. Точное число меняется, поэтому проверяем свойство. 127.0.0.1 разрешает локальный обмен; 0.0.0.0 имело бы другую область доступа.

<?php
declare(strict_types=1);

$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($socket === false) throw new RuntimeException('Нет UDP endpoint');
try {
    if (!socket_bind($socket, '127.0.0.1', 0)) throw new RuntimeException(socket_strerror(socket_last_error($socket)));
    if (!socket_getsockname($socket, $address, $port)) throw new RuntimeException('Нет адреса');
    echo $address, "\n", $port > 0 ? "Свободный порт назначен ОС\n" : "Порт не назначен\n";
} finally { socket_close($socket); }

127.0.0.1
Свободный порт назначен ОС

Этот вариант. Граница проверяется как ValueError с PHP 8.5. Для порта из формы сначала нужна прикладная валидация; этот catch показывает защиту API, а не полноценную обработку HTTP-ввода.

<?php
declare(strict_types=1);

$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($socket === false) throw new RuntimeException('Нет сокета');
try {
    try { socket_bind($socket, '127.0.0.1', 65536); }
    catch (ValueError $error) { echo "Порт должен помещаться в 0…65535\n"; }
} finally { socket_close($socket); }

Порт должен помещаться в 0…65535

bind выбирает местную сторону, а connect — удалённую. Клиенту обычно не нужен явный bind: ОС выбирает исходящий адрес/порт. Если он нужен для определённого интерфейса, вызовите bind до connect. Для AF_UNIX address — путь сокета, port не применяется; существующий путь, права каталога и уборка файла требуют отдельного решения. Не удаляйте чужой socket-файл перед bind. Для AF_INET6 адрес задаётся без квадратных скобок URL.

Связанные действия: socket_getsockname, socket_listen, socket_connect.

• PHP: socket_bind

PHP 4.1.0+ · sockets

socket_listen(Socket $socket, int $backlog = 0): bool

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$listener = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($listener === false) { throw new RuntimeException('Не создан слушатель'); }
if (!socket_bind($listener, '127.0.0.1', 0)) { throw new RuntimeException('Адрес не привязан'); }
if (!socket_listen($listener, 2)) { throw new RuntimeException('Очередь не создана'); }
if (!socket_getsockname($listener, $address, $port)) { throw new RuntimeException('Адрес не прочитан'); }
$client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($client === false || !socket_connect($client, $address, $port)) { throw new RuntimeException('Клиент не подключён'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Клиент не принят'); }
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Разрешить входящие соединения на привязанном endpoint и подготовить очередь до accept.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. listen возвращает управление сразу: он включает пассивный режим, а не выполняет бесконечный цикл. backlog=2 относится к очереди ещё не принятых соединений.

<?php
declare(strict_types=1);

$listener = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($listener === false) throw new RuntimeException('Нет endpoint');
try {
    if (!socket_bind($listener, '127.0.0.1', 0)) throw new RuntimeException('Не удалось привязать адрес');
    if (!socket_listen($listener, 2)) throw new RuntimeException('Не удалось открыть очередь');
    echo "Локальный listener готов; клиентов ещё не принимали\n";
} finally { socket_close($listener); }

Локальный listener готов; клиентов ещё не принимали

Этот вариант. Два client endpoint созданы локально. После accept соединение выходит из очереди ожидания; backlog не является пределом общего числа обслуженных клиентов. Распаковка ... передаёт элементы массива отдельными аргументами. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
$listener = labListener();
socket_getsockname($listener, $address, $port);
$clients = []; $accepted = [];
try {
    for ($i = 0; $i < 2; $i++) {
        $client = labSocket(AF_INET, SOCK_STREAM, SOL_TCP);
        if (!socket_connect($client, $address, $port)) throw new RuntimeException('Нет подключения');
        $clients[] = $client;
    }
    for ($i = 0; $i < 2; $i++) {
        $peer = socket_accept($listener);
        if ($peer === false) throw new RuntimeException('Нет клиента в очереди');
        $accepted[] = $peer;
    }
    echo 'Принято клиентов: ', count($accepted), "\n";
} finally { labClose(...[...$accepted, ...$clients, $listener]); }

Принято клиентов: 2

Применяется к STREAM/SEQPACKET, а не к обычному UDP. ОС ограничивает очередь своей политикой: Linux ограничивает системным максимумом, Windows при SOMAXCONN выбирает разумный предел provider. Реальный размер нельзя переносимо прочитать обратно. Переполненная очередь может дать отказ или ожидание/повтор SYN, а не ровно одинаковую ошибку на всех ОС.

Связанные действия: socket_accept, socket_bind, socket_create_listen.

• PHP: socket_listen

PHP 4.1.0+ · sockets

socket_accept(Socket $socket): Socket|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$listener = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($listener === false) { throw new RuntimeException('Не создан слушатель'); }
if (!socket_bind($listener, '127.0.0.1', 0)) { throw new RuntimeException('Адрес не привязан'); }
if (!socket_listen($listener, 2)) { throw new RuntimeException('Очередь не создана'); }
if (!socket_getsockname($listener, $address, $port)) { throw new RuntimeException('Адрес не прочитан'); }
$client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($client === false || !socket_connect($client, $address, $port)) { throw new RuntimeException('Клиент не подключён'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Клиент не принят'); }
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Получить отдельный endpoint для одного клиента, сохранив listener для следующих подключений.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. socket_accept работает с очередью listener. Отдельный $peer получает данные одного клиента; из него нельзя принимать другие соединения. Listener остаётся доступен до отдельного close. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
$listener = labListener();
socket_getsockname($listener, $address, $port);
$client = labSocket(AF_INET, SOCK_STREAM, SOL_TCP);
if (!socket_connect($client, $address, $port)) throw new RuntimeException('Нет подключения');
$peer = socket_accept($listener);
if ($peer === false) throw new RuntimeException('Нет принятого соединения');
try {
    echo $peer !== $listener ? "Listener и принятый клиент — разные Socket\n" : "Ошибка\n";
    labWriteAll($client, 'A42');
    echo labReadExact($peer, 3), "\n";
} finally { labClose($peer, $client, $listener); }

Listener и принятый клиент — разные Socket
A42

Этот вариант. @ подавляет только ожидаемое предупреждение этого вызова, после него код немедленно проверяется. Для accept читаем глобальный socket_last_error() без listener: ошибка относится к попытке создать новый endpoint. false не всегда означает аварию: EWOULDBLOCK/EAGAIN сообщает отсутствие готового клиента. Вместо busy loop используйте select. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
$listener = labListener();
try {
    if (!socket_set_nonblock($listener)) throw new RuntimeException('Нет неблокирующего режима');
    $peer = @socket_accept($listener);
    if ($peer !== false) { socket_close($peer); throw new RuntimeException('Неожиданный клиент'); }
    $error = socket_last_error();
    $wouldBlock = $error === SOCKET_EWOULDBLOCK
        || (defined('SOCKET_EAGAIN') && $error === constant('SOCKET_EAGAIN'));
    echo $wouldBlock ? "Очередь пока пуста; можно ждать готовности\n" : "Другой отказ\n";
} finally { socket_close($listener); }

Очередь пока пуста; можно ждать готовности

По умолчанию accept блокируется при пустой очереди. В неблокирующем режиме подготовьте listener через socket_set_nonblock; для объекта Socket используйте именно функции этой книги. Упоминание socket_set_blocking в старом тексте относится к stream alias и не подходит для Socket. Режим принятого endpoint лучше задавать явно: наследование режима зависит от ОС.

Связанные действия: socket_listen, socket_set_nonblock, socket_select.

• PHP: socket_accept

PHP 4.1.0+ · sockets

socket_connect(Socket $socket, string $address, ?int $port = null): bool

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$listener = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($listener === false) { throw new RuntimeException('Не создан слушатель'); }
if (!socket_bind($listener, '127.0.0.1', 0)) { throw new RuntimeException('Адрес не привязан'); }
if (!socket_listen($listener, 2)) { throw new RuntimeException('Очередь не создана'); }
if (!socket_getsockname($listener, $address, $port)) { throw new RuntimeException('Адрес не прочитан'); }
$client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($client === false || !socket_connect($client, $address, $port)) { throw new RuntimeException('Клиент не подключён'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Клиент не принят'); }
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Назначить удалённую сторону и установить TCP-соединение либо выбрать peer для UDP.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Порт не задан заранее: он прочитан у собственного listener. connect устанавливает TCP-соединение, но не доказывает готовность прикладного протокола. Строка ready — отдельный договор нашего учебного сервиса. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
$listener = labListener();
socket_getsockname($listener, $address, $port);
$client = labSocket(AF_INET, SOCK_STREAM, SOL_TCP);
if (!socket_connect($client, $address, $port)) throw new RuntimeException('Подключение не удалось');
$peer = socket_accept($listener);
if ($peer === false) throw new RuntimeException('Клиент не принят');
try {
    labWriteAll($peer, "ready\n");
    echo labReadExact($client, 6);
} finally { labClose($peer, $client, $listener); }

ready

Этот вариант. UDP connect не делает handshake TCP и не доказывает, что сервер существует. Он задаёт peer для send/recv и влияет на фильтрацию входящих datagrams. Один вызов send остаётся одним сообщением, а не надёжной очередью. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$receiver, $sender, $port] = labUdp();
try {
    if (!socket_connect($sender, '127.0.0.1', $port)) throw new RuntimeException('Нет UDP peer');
    if (socket_send($sender, 'T=21', 4, 0) !== 4) throw new RuntimeException('Сообщение не передано целиком');
    $data = '';
    if (socket_recvfrom($receiver, $data, 64, 0, $from, $fromPort) === false) throw new RuntimeException('Нет сообщения');
    echo $data, "\n";
} finally { labClose($sender, $receiver); }

T=21

У non-blocking TCP connect возврат false с EINPROGRESS/EWOULDBLOCK может означать начало соединения. Дождитесь готовности записи через select и затем проверьте SO_ERROR; сама готовность записи не доказывает успех. Ограничивайте ожидание общим deadline. Для AF_INET/AF_INET6 порт обязателен даже при nullable-сигнатуре; для AF_UNIX адрес — путь и порт не используется.

Связанные действия: socket_getpeername, socket_select, socket_get_option.

• PHP: socket_connect

PHP 4.1.0+ · sockets

socket_create_pair(int $domain, int $type, int $protocol, array &$pair): bool

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$pair = [];
$family = PHP_OS_FAMILY === 'Windows' ? AF_INET : AF_UNIX;
if (!socket_create_pair($family, SOCK_STREAM, 0, $pair)) { throw new RuntimeException('Пара не создана'); }
[$client, $peer] = $pair;
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($client);
socket_close($peer);

Молоток — 8 шт.

Получить два уже соединённых локальных endpoint для обмена внутри программы или IPC.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. &$pair в сигнатуре означает выход через переданную переменную: return сообщает bool, а два Socket помещаются в массив. Для Windows используется AF_INET, для Unix — AF_UNIX. Маленький первый опыт явно проверяет полноту; универсальный код использует циклы.

<?php
declare(strict_types=1);

$pair = [];
$family = PHP_OS_FAMILY === 'Windows' ? AF_INET : AF_UNIX;
if (!socket_create_pair($family, SOCK_STREAM, 0, $pair)) throw new RuntimeException('Нет пары');
try {
    $written = socket_write($pair[0], 'OK');
    if ($written !== 2) throw new RuntimeException('Неполная учебная запись');
    $reply = socket_read($pair[1], 2, PHP_BINARY_READ);
    if ($reply !== 'OK') throw new RuntimeException('Неполное чтение');
    echo $reply, "\n";
} finally { socket_close($pair[0]); socket_close($pair[1]); }

OK

Этот вариант. Оба конца равноправны и двунаправленны. В этом примере роли producer/worker выполняются последовательно в одном процессе; это не демонстрация параллельного выполнения. Для разных процессов требуется отдельная модель наследования/передачи endpoint. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$producer, $worker] = labPair();
try {
    labWriteAll($producer, 'order:42');
    echo 'Задание: ', labReadExact($worker, 8), "\n";
    labWriteAll($worker, 'accepted');
    echo 'Ответ: ', labReadExact($producer, 8), "\n";
} finally { labClose($producer, $worker); }

Задание: order:42
Ответ: accepted

Официальный IPC-пример с pcntl_fork относится к Unix и требует расширение PCNTL; он не переносится на Windows. В Windows существуют отдельные WSAPROTOCOL_INFO функции. После fork каждый процесс закрывает ненужную копию endpoint, иначе ожидаемый EOF может не прийти. Не заменяйте это сериализацией Socket.

Связанные действия: socket_write, socket_read, socket_wsaprotocol_info_export.

• PHP: socket_create_pair

PHP 4.1.0+ · sockets

socket_create_listen(int $port, int $backlog = SOMAXCONN): Socket|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$listener = socket_create_listen(0, 2);
if ($listener === false) { throw new RuntimeException('Слушатель не создан'); }
if (!socket_getsockname($listener, $address, $port)) { throw new RuntimeException('Адрес не прочитан'); }
$client = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($client === false || !socket_connect($client, '127.0.0.1', $port)) { throw new RuntimeException('Клиент не подключён'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Клиент не принят'); }
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Сократить создание IPv4 listener, когда осознанно нужно слушать все местные интерфейсы.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. PHP 8.5 проверяет диапазон до открытия listener. Этот самостоятельный пример не создаёт endpoint на всех интерфейсах.

<?php
declare(strict_types=1);

try {
    socket_create_listen(-1);
} catch (ValueError $error) {
    echo "Listener не создан: порт вне диапазона\n";
}

Listener не создан: порт вне диапазона

Этот вариант. Контекстный пример: только заранее изолированная учебная машина с согласованной сетевой политикой. В общей проверке выполняется lint, не создание такого listener. Для обычной локальной лаборатории используйте create + bind(127.0.0.1, 0) + listen: create_listen не принимает параметр адреса.

<?php
declare(strict_types=1);

$listener = socket_create_listen(0, SOMAXCONN);
if ($listener === false) throw new RuntimeException(socket_strerror(socket_last_error()));
try {
    if (!socket_getsockname($listener, $address, $port)) throw new RuntimeException('Нет адреса');
    echo $address === '0.0.0.0' ? "Слушаются все IPv4 интерфейсы\n" : "Проверьте привязку\n";
} finally { socket_close($listener); }

Слушаются все IPv4 интерфейсы

Связанные действия: socket_create, socket_bind, socket_listen.

• PHP: socket_create_listen

PHP 4.1.0+ · sockets

socket_close(Socket $socket): void

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
writeBytes($client, "product:1\n");
serveProduct($peer);
$json = readCatalogLine($client);
socket_close($peer);
socket_close($client);
socket_close($listener);
showProduct($json);

Молоток — 8 шт.

Завершить владение системным endpoint и освободить его после запроса/обмена.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. void означает отсутствие полезного возвращаемого значения, а не bool успеха. Переменная всё ещё может ссылаться на объект Socket, но его системный endpoint уже закрыт.

<?php
declare(strict_types=1);

$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($socket === false) throw new RuntimeException('Нет endpoint');
$result = socket_close($socket);
echo $result === null ? "Endpoint закрыт; возвращаемого результата нет\n" : "Ошибка\n";

Endpoint закрыт; возвращаемого результата нет

Этот вариант. Присваивание объекта не дублирует системный сокет. После close не вызывайте close второй раз и не проверяйте пригодность через instanceof: класс объекта от закрытия не меняется.

<?php
declare(strict_types=1);

$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($socket === false) throw new RuntimeException('Нет endpoint');
$anotherName = $socket;
socket_close($socket);
try { socket_get_option($anotherName, SOL_SOCKET, SO_TYPE); }
catch (Error $error) { echo "Обе переменные ссылались на закрытый endpoint\n"; }

Обе переменные ссылались на закрытый endpoint

Ресурс обычно освобождается и при уничтожении последней ссылки, но явный finally делает владение понятным. SO_LINGER может влиять на завершение и отправку буферов; close не доказывает, что прикладной сервер обработал данные. Для обмена «я закончил отправлять, но ещё жду ответ» сначала нужен shutdown записи, а не полный close.

Связанные действия: socket_shutdown, Socket.

• PHP: socket_close

PHP 4.1.0+ · sockets

socket_shutdown(Socket $socket, int $mode = 2): bool

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
writeBytes($client, "product:1\n");
if (!socket_shutdown($client, 1)) { throw new RuntimeException('Запись не завершена'); }
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Остановить одну или обе стороны обмена, сохранив endpoint до последующего close.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. mode=1 закрывает отправку клиента, оставляя его приём. После уже посланных байтов peer видит EOF потока. Это пример собственного протокола «запрос до EOF», не правило HTTP persistent connection. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$client, $worker] = labPair();
try {
    labWriteAll($client, 'A42');
    if (!socket_shutdown($client, 1)) throw new RuntimeException('Не удалось закончить отправку');
    echo 'Запрос: ', labReadExact($worker, 3), "\n";
    echo socket_read($worker, 1) === '' ? "Получен конец ввода\n" : "Нет EOF\n";
    labWriteAll($worker, '7');
    echo 'Остаток: ', labReadExact($client, 1), "\n";
} finally { labClose($client, $worker); }

Запрос: A42
Получен конец ввода
Остаток: 7

Этот вариант. SHUT_RD/WR/RDWR добавлены как PHP-константы в 8.5 и соответствуют режимам 0/1/2. Shutdown не заменяет освобождение объекта через close и не гарантирует, что все буферы приложения уже обработаны. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$left, $right] = labPair();
try {
    try { socket_shutdown($left, 9); }
    catch (ValueError $error) { echo "Недопустимый режим отклонён\n"; }
    if (!socket_shutdown($left, SHUT_RDWR)) throw new RuntimeException('Shutdown не выполнен');
    echo "Оба направления остановлены; close ещё нужен\n";
} finally { labClose($left, $right); }

Недопустимый режим отклонён
Оба направления остановлены; close ещё нужен

Связанные действия: socket_close, socket_read, socket_write.

• PHP: socket_shutdown

PHP 4.1.0+ · sockets

socket_getsockname(Socket $socket, string &$address, int &$port = null): bool

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
socket_getsockname($listener, $localHost, $localPort);
socket_getpeername($client, $remoteHost, $remotePort);
if ($localPort !== $remotePort || $remoteHost !== '127.0.0.1') { throw new RuntimeException('Клиент связан с другим узлом'); }
echo 'Сервер клиента: ', $remoteHost, "\n";
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Сервер клиента: 127.0.0.1
Молоток — 8 шт.

Узнать адрес местной стороны для диагностики и сопоставления соединений.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. address и port — выходные переменные по ссылке. Функция возвращает bool, а не строку адреса. Числа ephemeral ports намеренно не зафиксированы. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$listener, $client, $peer] = labTcp();
try {
    if (!socket_getsockname($client, $address, $port)) throw new RuntimeException('Нет адреса');
    echo $address, "\n", $port > 0 ? "IP-порт назначен\n" : "Нет порта\n";
} finally { labClose($peer, $client, $listener); }

127.0.0.1
IP-порт назначен

Этот вариант. Слова local/peer относительны к объекту: адрес клиента местный для клиента и удалённый для принятого сервером endpoint. За proxy это адрес непосредственного соседа, не обязательно исходного пользователя. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$listener, $client, $peer] = labTcp();
try {
    socket_getsockname($client, $localIp, $localPort);
    socket_getpeername($peer, $remoteIp, $remotePort);
    echo $localIp === $remoteIp && $localPort === $remotePort
        ? "Местный адрес клиента совпадает с peer сервера\n" : "Адреса различаются\n";
} finally { labClose($peer, $client, $listener); }

Местный адрес клиента совпадает с peer сервера

Для AF_UNIX возвращается путь, port не имеет обычного IP-смысла. У безымянного конца пары/непривязанного клиента имя может отсутствовать; не требуйте непустой путь для любого IPC. Для getsockname PHP 8.5 также описывает AF_PACKET: индекс интерфейса и строковое представление. Неизвестное семейство может дать false, не обновив last_error, поэтому не приписывайте старый код ошибки новой операции.

Связанные действия: socket_getpeername, socket_bind.

• PHP: socket_getsockname

PHP 4.1.0+ · sockets

socket_getpeername(Socket $socket, string &$address, int &$port = null): bool

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
socket_getsockname($listener, $localHost, $localPort);
socket_getpeername($client, $remoteHost, $remotePort);
if ($localPort !== $remotePort || $remoteHost !== '127.0.0.1') { throw new RuntimeException('Клиент связан с другим узлом'); }
echo 'Сервер клиента: ', $remoteHost, "\n";
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Сервер клиента: 127.0.0.1
Молоток — 8 шт.

Узнать адрес удалённой стороны для диагностики и сопоставления соединений.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. address и port — выходные переменные по ссылке. Функция возвращает bool, а не строку адреса. Числа ephemeral ports намеренно не зафиксированы. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$listener, $client, $peer] = labTcp();
try {
    if (!socket_getpeername($client, $address, $port)) throw new RuntimeException('Нет адреса');
    echo $address, "\n", $port > 0 ? "IP-порт назначен\n" : "Нет порта\n";
} finally { labClose($peer, $client, $listener); }

127.0.0.1
IP-порт назначен

Этот вариант. Слова local/peer относительны к объекту: адрес клиента местный для клиента и удалённый для принятого сервером endpoint. За proxy это адрес непосредственного соседа, не обязательно исходного пользователя. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$listener, $client, $peer] = labTcp();
try {
    socket_getsockname($client, $localIp, $localPort);
    socket_getpeername($peer, $remoteIp, $remotePort);
    echo $localIp === $remoteIp && $localPort === $remotePort
        ? "Местный адрес клиента совпадает с peer сервера\n" : "Адреса различаются\n";
} finally { labClose($peer, $client, $listener); }

Местный адрес клиента совпадает с peer сервера

Для AF_UNIX возвращается путь, port не имеет обычного IP-смысла. У безымянного конца пары/непривязанного клиента имя может отсутствовать; не требуйте непустой путь для любого IPC. Для getsockname PHP 8.5 также описывает AF_PACKET: индекс интерфейса и строковое представление. Неизвестное семейство может дать false, не обновив last_error, поэтому не приписывайте старый код ошибки новой операции.

Связанные действия: socket_getsockname, socket_bind.

• PHP: socket_getpeername

PHP 4.1.0+ · sockets

socket_read(Socket $socket, int $length, int $mode = PHP_BINARY_READ): string|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
$request = "product:1\n";
$sent = socket_write($client, $request);
if ($sent !== strlen($request)) { throw new RuntimeException('Короткий запрос не записан полностью'); }
$received = '';
while (strlen($received) < strlen($request)) {
    $part = socket_read($peer, strlen($request) - strlen($received));
    if ($part === false || $part === '') { throw new RuntimeException('Запрос оборвался'); }
    $received .= $part;
}
echo 'Сервер получил: ', trim($received), "\n";
$catalog = ["product:1\n"=>['name'=>'Молоток','stock'=>8]];
$row = $catalog[$received] ?? ['error'=>'Команда неизвестна'];
writeBytes($peer, json_encode($row, JSON_UNESCAPED_UNICODE | JSON_THROW_ON_ERROR)."\n");
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Сервер получил: product:1
Молоток — 8 шт.

Получить очередную часть входящих байтов либо прочитать до строкового разделителя.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. PHP_NORMAL_READ останавливается на или либо пределе длины; завершающий байт входит в результат. rtrim здесь удаляет только окончания строк. Для CRLF отдельный может закончить один вызов, оставив следующему; полноценный line parser должен учитывать это. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    labWriteAll($sender, "status\n");
    $line = socket_read($receiver, 64, PHP_NORMAL_READ);
    if ($line === false) throw new RuntimeException(socket_strerror(socket_last_error($receiver)));
    echo 'Команда: ', rtrim($line, "\r\n"), "\n";
} finally { labClose($sender, $receiver); }

Команда: status

Этот вариант. Бинарный режим не считает NUL концом строки: это обычный байт. Цикл собирает известные три байта и не предполагает, что один write соответствует одному read. bin2hex делает невидимый байт видимым. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    labWriteAll($sender, "A\0B");
    $data = '';
    while (strlen($data) < 3) {
        $chunk = socket_read($receiver, 3 - strlen($data), PHP_BINARY_READ);
        if ($chunk === false || $chunk === '') throw new RuntimeException('Неполное значение');
        $data .= $chunk;
    }
    echo bin2hex($data), "\n";
} finally { labClose($sender, $receiver); }

410042

length — максимум, а не обещание получить столько. В бинарном режиме пустая строка означает EOF потока; false — отказ, в том числе временный EWOULDBLOCK в non-blocking режиме. Разрыв с ошибкой и нормальное закрытие различаются. На странице PHP.net рядом встречаются формулировки о false при закрытии и о пустой строке: в рабочем коде обработайте обе ситуации, но не считайте EOF транспортной ошибкой автоматически. Для нормального режима также учитывайте его построчное поведение; для собственных протоколов обычно проще бинарный буфер.

Связанные действия: socket_recv, socket_write, socket_select.

• PHP: socket_read

PHP 4.1.0+ · sockets

socket_recv(Socket $socket, ?string &$data, int $length, int $flags): int|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
$request = "product:1\n";
$sent = socket_write($client, $request);
if ($sent !== strlen($request)) { throw new RuntimeException('Короткий запрос не записан полностью'); }
$size = socket_recv($peer, $received, strlen($request), MSG_WAITALL);
if ($size !== strlen($request)) { throw new RuntimeException('Запрос получен не целиком'); }
echo 'Сервер получил: ', trim($received), "\n";
$catalog = ["product:1\n"=>['name'=>'Молоток','stock'=>8]];
$row = $catalog[$received] ?? ['error'=>'Команда неизвестна'];
writeBytes($peer, json_encode($row, JSON_UNESCAPED_UNICODE | JSON_THROW_ON_ERROR)."\n");
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Сервер получил: product:1
Молоток — 8 шт.

Получить данные с управляющими флагами и отдельным числом принятых байтов.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. MSG_PEEK не удаляет просмотренные байты: обычное следующее чтение всё ещё видит A42. Возвращаемое число и выходная переменная $peek — разные результаты. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    labWriteAll($sender, 'A42');
    $peek = null;
    if (socket_recv($receiver, $peek, 1, MSG_PEEK) !== 1) throw new RuntimeException('Нет первого байта');
    echo 'Первый байт: ', $peek, "\n";
    echo 'Полные данные: ', labReadExact($receiver, 3), "\n";
} finally { labClose($sender, $receiver); }

Первый байт: A
Полные данные: A42

Этот вариант. Для TCP 0 означает упорядоченный конец потока, а не false. PHP очищает data в null, когда recv не вернул положительное количество байтов. Для UDP нулевая длина может быть настоящим пустым datagram, поэтому смысл зависит от типа сокета. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    socket_shutdown($sender, 1);
    $data = 'старое значение';
    $count = socket_recv($receiver, $data, 32, 0);
    echo $count === 0 ? "Конец TCP потока\n" : "Неожиданный результат\n";
    echo $data === null ? "Выходной буфер очищен\n" : "В буфере остались данные\n";
} finally { labClose($sender, $receiver); }

Конец TCP потока
Выходной буфер очищен

flags=0 — обычное чтение. MSG_OOB читает срочные данные, MSG_PEEK не удаляет байты, MSG_WAITALL старается дождаться length, но сигнал/EOF/отказ может вернуть меньше. MSG_DONTWAIT делает один вызов неблокирующим там, где этот флаг доступен. Не используйте WAITALL для неизвестной длины ответа: можно ждать данных, которые по протоколу никогда не придут. Флаги объединяются | только при совместимом назначении.

Связанные действия: socket_read, socket_recvfrom, socket_recvmsg.

• PHP: socket_recv

PHP 4.1.0+ · sockets

socket_write(Socket $socket, string $data, ?int $length = null): int|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
$request = "product:1\n";
$sent = socket_write($client, $request);
if ($sent !== strlen($request)) { throw new RuntimeException('Короткий запрос не записан полностью'); }
$received = readCatalogLine($peer);
echo 'Сервер получил: ', trim($received), "\n";
$catalog = ["product:1\n"=>['name'=>'Молоток','stock'=>8]];
$row = $catalog[$received] ?? ['error'=>'Команда неизвестна'];
writeBytes($peer, json_encode($row, JSON_UNESCAPED_UNICODE | JSON_THROW_ON_ERROR)."\n");
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Сервер получил: product:1
Молоток — 8 шт.

Передать байты в соединённый поток и узнать, сколько из них принято системой.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Явный length=0 ограничивает первую операцию нулём; она не отправляет A42. Во второй записи используется helper с циклом. Проверка if (!$count) потеряла бы различие 0/false. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    $count = socket_write($sender, 'A42', 0);
    echo $count === 0 ? "Ноль байтов записано; это не false\n" : "Неожиданный результат\n";
    labWriteAll($sender, 'A42');
    echo labReadExact($receiver, 3), "\n";
} finally { labClose($sender, $receiver); }

Ноль байтов записано; это не false
A42

Этот вариант. offset — уже принятые системой байты. Следующий вызов получает только остаток. Здесь малая команда и blocking socket с timeout; в event loop вместо немедленного отказа на EWOULDBLOCK сохраняют offset и ждут writable. Не повторяйте весь payload после частичной записи. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    $command = "reserve A42 2\n";
    $offset = 0;
    while ($offset < strlen($command)) {
        $count = socket_write($sender, substr($command, $offset));
        if ($count === false || $count === 0) throw new RuntimeException('Не удалось продвинуть запись');
        $offset += $count;
    }
    echo labReadExact($receiver, strlen($command));
} finally { labClose($sender, $receiver); }

reserve A42 2

Необязательный length=null (PHP 8+) означает длину строки; больше strlen PHP ограничивает фактической длиной. Возвращаемое число описывает принятые системой байты, а не подтверждение бизнес-действия сервером. Большую двустороннюю передачу нельзя бездумно организовать «сначала всё записать, затем всё прочитать»: обе стороны могут заполнить буферы и ждать друг друга.

Связанные действия: socket_send, socket_read, socket_select.

• PHP: socket_write

PHP 4.1.0+ · sockets

socket_send(Socket $socket, string $data, int $length, int $flags): int|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
$request = "product:1\n";
$sent = socket_send($client, $request, strlen($request), 0);
if ($sent !== strlen($request)) { throw new RuntimeException('Короткий запрос не записан полностью'); }
$received = readCatalogLine($peer);
echo 'Сервер получил: ', trim($received), "\n";
$catalog = ["product:1\n"=>['name'=>'Молоток','stock'=>8]];
$row = $catalog[$received] ?? ['error'=>'Команда неизвестна'];
writeBytes($peer, json_encode($row, JSON_UNESCAPED_UNICODE | JSON_THROW_ON_ERROR)."\n");
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Сервер получил: product:1
Молоток — 8 шт.

Отправить данные в соединённый endpoint с явно выбранными флагами.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. length=3 ограничивает отправку первыми тремя байтами; flags=0 — обычная отправка. TCP всё равно может принять меньше, что первый короткий опыт явно проверяет. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    $count = socket_send($sender, 'A42-rest', 3, 0);
    if ($count !== 3) throw new RuntimeException('Неполная учебная отправка');
    echo labReadExact($receiver, 3), "\n";
} finally { labClose($sender, $receiver); }

A42

Этот вариант. Функция пригодна для небольшой blocking-команды с настроенными таймаутами. Для UDP не переносите цикл остатков автоматически: повторные вызовы означали бы разные datagrams, а не продолжение одного сообщения. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
function sendCommand(Socket $socket, string $command): void {
    $offset = 0;
    while ($offset < strlen($command)) {
        $part = substr($command, $offset);
        $count = socket_send($socket, $part, strlen($part), 0);
        if ($count === false || $count === 0) throw new RuntimeException('Команда не отправлена полностью');
        $offset += $count;
    }
}
[$sender, $receiver] = labPair();
try {
    sendCommand($sender, "stock A42\n");
    echo labReadExact($receiver, 10);
} finally { labClose($sender, $receiver); }

stock A42

MSG_OOB относится к срочным данным поддержанного протокола, MSG_EOR — концу записи, MSG_EOF — специализированному завершению отправки, MSG_DONTROUTE — обходу обычной маршрутизации. Они не универсальны: EOR/EOF отсутствуют на Windows. На Unix MSG_NOSIGNAL может предотвращать SIGPIPE для отдельной отправки; доступность нужно проверить. Бинарный 0-флаг не означает «отключить ошибки».

Связанные действия: socket_write, socket_sendto, socket_sendmsg.

• PHP: socket_send

PHP 4.1.0+ · sockets

socket_sendto(Socket $socket, string $data, int $length, int $flags, string $address, ?int $port = null): int|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$receiver = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
$sender = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
if (!socket_bind($receiver, '127.0.0.1', 0) || !socket_bind($sender, '127.0.0.1', 0)) { throw new RuntimeException('UDP не привязан'); }
localTimeout($receiver);
localTimeout($sender);
socket_getsockname($receiver, $host, $port);
$payload = "Молоток;8\n";
$sent = socket_sendto($sender, $payload, strlen($payload), 0, '127.0.0.1', $port);
if ($sent !== strlen($payload)) { throw new RuntimeException('Датаграмма не отправлена полностью'); }
$received = socket_recvfrom($receiver, $data, 1024, 0, $from, $fromPort);
if ($received === false || $data !== $payload) { throw new RuntimeException('Датаграмма не получена целиком'); }
echo "Получена строка инвентаризации:\n", $data;
socket_close($sender);
socket_close($receiver);

Получена строка инвентаризации:
Молоток;8

Отправить отдельное сообщение указанному адресату, например UDP-показание и ответ на него.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. sendto указывает адрес именно для этой datagram. Наличие локального receiver делает опыт воспроизводимым; обычная успешная UDP-отправка не гарантирует существования получателя или доставки. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$receiver, $sender, $port] = labUdp();
try {
    $message = 'T=21';
    if (socket_sendto($sender, $message, strlen($message), 0, '127.0.0.1', $port) !== 4) throw new RuntimeException('Неполная отправка');
    $data = '';
    if (socket_recvfrom($receiver, $data, 64, 0, $from, $fromPort) === false) throw new RuntimeException('Нет сообщения');
    echo $data, "\n";
} finally { labClose($sender, $receiver); }

T=21

Этот вариант. Ответ отправляется на $from/$fromPort, полученные recvfrom. Возврат на заранее придуманный клиентский порт часто и вызывает ситуацию «сервер получил, клиент нет». Учебный ACK не решает повторы/потери: реальному протоколу нужны ID сообщения, дедупликация и пределы ожидания. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$receiver, $sender, $port] = labUdp();
try {
    socket_sendto($sender, 'T=21', 4, 0, '127.0.0.1', $port);
    $data = '';
    if (socket_recvfrom($receiver, $data, 64, 0, $from, $fromPort) === false) throw new RuntimeException('Нет показания');
    if (socket_sendto($receiver, 'ACK', 3, 0, $from, $fromPort) !== 3) throw new RuntimeException('Нет ACK');
    $reply = '';
    if (socket_recvfrom($sender, $reply, 64, 0, $replyFrom, $replyPort) === false) throw new RuntimeException('Нет ответа');
    echo $data, ' -> ', $reply, "\n";
} finally { labClose($sender, $receiver); }

T=21 -> ACK

Связанные действия: socket_recvfrom, socket_send, socket_bind.

• PHP: socket_sendto

PHP 4.1.0+ · sockets

socket_recvfrom(Socket $socket, string &$data, int $length, int $flags, string &$address, int &$port = null): int|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$receiver = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
$sender = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
if (!socket_bind($receiver, '127.0.0.1', 0) || !socket_bind($sender, '127.0.0.1', 0)) { throw new RuntimeException('UDP не привязан'); }
localTimeout($receiver);
localTimeout($sender);
socket_getsockname($receiver, $host, $port);
$payload = "Молоток;8\n";
$sent = socket_sendto($sender, $payload, strlen($payload), 0, '127.0.0.1', $port);
if ($sent !== strlen($payload)) { throw new RuntimeException('Датаграмма не отправлена полностью'); }
$received = socket_recvfrom($receiver, $data, 1024, 0, $from, $fromPort);
if ($received === false || $data !== $payload) { throw new RuntimeException('Датаграмма не получена целиком'); }
echo "Получена строка инвентаризации:\n", $data;
socket_close($sender);
socket_close($receiver);

Получена строка инвентаризации:
Молоток;8

Принять одно сообщение и узнать, куда при необходимости отправить ответ.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Параметры data/address/port — выходы, а не заранее заданные фильтры. Адрес/порт получены от ОС; доверие прикладным данным они сами не обеспечивают. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$receiver, $sender, $port] = labUdp();
try {
    socket_sendto($sender, 'A42=7', 5, 0, '127.0.0.1', $port);
    $data = '';
    $count = socket_recvfrom($receiver, $data, 64, 0, $from, $fromPort);
    if ($count === false) throw new RuntimeException('Нет datagram');
    echo $data, ' от ', $from, "\n";
    echo $fromPort > 0 ? "Есть обратный порт\n" : "Нет порта\n";
} finally { labClose($sender, $receiver); }

A42=7 от 127.0.0.1
Есть обратный порт

Этот вариант. В UDP ноль байтов не является TCP EOF. При недостаточном буфере хвост datagram обычно теряется (поведение ошибок/MSG_TRUNC зависит от ОС), поэтому максимальный размер сообщения нужно определить в протоколе. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$receiver, $sender, $port] = labUdp();
try {
    if (socket_sendto($sender, '', 0, 0, '127.0.0.1', $port) === false) throw new RuntimeException('Не отправлено');
    $data = '';
    $count = socket_recvfrom($receiver, $data, 64, 0, $from, $fromPort);
    echo $count === 0 ? "Получена пустая datagram\n" : "Неожиданный результат\n";
    echo $fromPort > 0 ? "Отправитель всё равно известен\n" : "Нет адреса\n";
} finally { labClose($sender, $receiver); }

Получена пустая datagram
Отправитель всё равно известен

Режимы MSG_PEEK/WAITALL/DONTWAIT/OOB применимы только по правилам конкретного протокола и ОС. WAITALL не склеивает UDP-пакеты в надёжный поток. Для connected socket адресные выходы могут не иметь того же смысла/значения, что для unconnected UDP; документация допускает null. Если нужен устойчивый peer соединения, используйте getpeername. При отказе не обрабатывайте старое содержимое выходных переменных как новое сообщение.

Связанные действия: socket_sendto, socket_recv, socket_recvmsg.

• PHP: socket_recvfrom

PHP 4.1.0+ · sockets

socket_select(?array &$read, ?array &$write, ?array &$except, ?int $seconds, int $microseconds = 0): int|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
writeBytes($client, "product:1\n");
serveProduct($peer);
$read = [$client];
$write = null;
$except = null;
$ready = socket_select($read, $write, $except, 1);
if ($ready === false || $ready === 0) { throw new RuntimeException('Ответ не готов'); }
showProduct(readCatalogLine($read[0]));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Ждать готовности группы endpoint без постоянного опроса и без блокировки на одном клиенте.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. select заменяет массивы только готовыми элементами, сохраняя ключи. На каждом новом обороте готовьте копии полного набора заново. null нужно сначала положить в переменную: аргументы передаются по ссылке. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    labWriteAll($sender, '7');
    $read = ['stock' => $receiver]; $write = null; $except = null;
    $ready = socket_select($read, $write, $except, 1, 0);
    if ($ready === false) throw new RuntimeException(socket_strerror(socket_last_error()));
    if ($ready === 0) throw new RuntimeException('Истёк срок ожидания');
    echo array_key_exists('stock', $read) ? "Ключ stock сохранён\n" : "Ключ потерян\n";
    echo labReadExact($read['stock'], 1), "\n";
} finally { labClose($sender, $receiver); }

Ключ stock сохранён
7

Этот вариант. select сообщает, что операция может завершиться без ожидания; он не обещает непустой payload. Сокет на EOF надо убрать из обслуживаемого набора и закрыть по своей политике, иначе цикл будет немедленно просыпаться снова. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    socket_shutdown($sender, 1);
    $read = [$receiver]; $write = null; $except = null;
    $ready = socket_select($read, $write, $except, 1);
    if ($ready === false || $ready === 0) throw new RuntimeException('Нет готовности');
    echo socket_read($receiver, 16) === '' ? "Чтение готово: достигнут EOF\n" : "Получены данные\n";
} finally { labClose($sender, $receiver); }

Чтение готово: достигнут EOF

seconds + microseconds задают предел ожидания; null у seconds допускает бесконечное ожидание, 0/0 — только текущая проверка. Не превращайте нулевой poll в горячий цикл. Когда у сервиса нет других дел, ожидание события удобно; когда есть срок задачи/остановка, необходим конечный deadline. Часы и планировщик не обещают точного момента пробуждения. Хотя старая Notes рекомендует ждать без timeout, это не универсальная политика для web/учебного клиента.

Все три аргумента-массива обязательны, ненужные могут быть null/пустыми, хотя бы один должен содержать сокеты. write включают только при наличии ожидающих отправки данных, иначе готовый канал создаст busy loop. except обычно относится к OOB, а не ко всем возможным ошибкам. Проверяйте каждый возвращённый готовый элемент. Готовность не гарантирует завершение большого read/write целиком; для event loop используйте non-blocking и сохраняйте буферы/offset. Системный select имеет ограничения числа дескрипторов и не подходит для любой огромной нагрузки.

Связанные действия: socket_set_nonblock, socket_read, socket_write.

• PHP: socket_select

PHP 4.1.0+ · sockets

socket_set_nonblock(Socket $socket): bool

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
if (!socket_set_nonblock($client)) { throw new RuntimeException('Неблокирующий режим недоступен'); }
writeBytes($client, "product:1\n");
serveProduct($peer);
$read = [$client];
$write = null;
$except = null;
$ready = socket_select($read, $write, $except, 1);
if ($ready === false || $ready === 0) { throw new RuntimeException('Ответ не готов'); }
showProduct(readCatalogLine($read[0]));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Сделать операции быстрыми попытками, чтобы программа могла обслуживать несколько endpoint.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Non-blocking не означает, что данные появятся сами. Ожидаемое предупреждение одного вызова подавлено через @, а код немедленно проверен. Реальный отказ соединения нельзя принимать за временное отсутствие данных. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    socket_set_nonblock($receiver);
    $data = @socket_read($receiver, 16);
    $error = socket_last_error($receiver);
    $pending = $error === SOCKET_EWOULDBLOCK || (defined('SOCKET_EAGAIN') && $error === constant('SOCKET_EAGAIN'));
    echo $data === false && $pending ? "Пока нет данных; управление возвращено\n" : "Другой результат\n";
} finally { labClose($sender, $receiver); }

Пока нет данных; управление возвращено

Этот вариант. select ограничивает ожидание; non-blocking защищает саму последующую операцию от неожиданного ожидания при изменении состояния. Для нескольких клиентов сохраняют отдельные буферы и обрабатывают их готовность в одном цикле. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    socket_set_nonblock($receiver);
    labWriteAll($sender, '7');
    $read = [$receiver]; $write = null; $except = null;
    $ready = socket_select($read, $write, $except, 1);
    if ($ready === false || $ready === 0) throw new RuntimeException('Нет готовности');
    $data = socket_read($receiver, 1);
    if ($data === false || $data === '') throw new RuntimeException('Нет байта');
    echo 'Остаток: ', $data, "\n";
} finally { labClose($sender, $receiver); }

Остаток: 7

Связанные действия: socket_set_block, socket_select.

• PHP: socket_set_nonblock

PHP 4.2.0+ · sockets

socket_set_block(Socket $socket): bool

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
socket_set_nonblock($client);
if (!socket_set_block($client)) { throw new RuntimeException('Блокирующий режим не восстановлен'); }
writeBytes($client, "product:1\n");
serveProduct($peer);
$read = [$client];
$write = null;
$except = null;
$ready = socket_select($read, $write, $except, 1);
if ($ready === false || $ready === 0) { throw new RuntimeException('Ответ не готов'); }
showProduct(readCatalogLine($read[0]));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Вернуть блокирующее поведение endpoint, когда один последовательный обмен проще event loop.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Blocking возвращает ожидание внутри операции. Учебная пара уже имеет таймаут; в примере данные отправлены до чтения, поэтому ждать внешний сервис не требуется. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    socket_set_nonblock($receiver);
    if (!socket_set_block($receiver)) throw new RuntimeException('Режим не восстановлен');
    labWriteAll($sender, 'ready');
    echo labReadExact($receiver, 5), "\n";
} finally { labClose($sender, $receiver); }

ready

Этот вариант. Режим ожидания и его ограничение — разные настройки. SO_RCVTIMEO относится к поддержанным ОС операциям ввода, не является общим deadline всего приложения и не заменяет таймаут select. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
$socket = labSocket(AF_INET, SOCK_STREAM, SOL_TCP);
try {
    if (!socket_set_block($socket)) throw new RuntimeException('Нет blocking режима');
    if (!socket_set_option($socket, SOL_SOCKET, SO_RCVTIMEO, ['sec' => 1, 'usec' => 0])) throw new RuntimeException('Нет таймаута');
    echo "Blocking чтение ограничено таймаутом ввода\n";
} finally { socket_close($socket); }

Blocking чтение ограничено таймаутом ввода

Связанные действия: socket_set_nonblock, socket_set_option, socket_select.

• PHP: socket_set_block

PHP 4.1.0+ · sockets

socket_last_error(?Socket $socket = null): int

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
socket_set_nonblock($client);
set_error_handler(function (int $level): bool { return $level === E_WARNING; });
try { $empty = socket_read($client, 1); } finally { restore_error_handler(); }
$code = socket_last_error($client);
if ($empty !== false || $code === 0) { throw new RuntimeException('Ожидалось отсутствие данных сейчас'); }
$diagnostic = ['code'=>$code, 'message'=>socket_strerror($code)];
if (file_put_contents(__DIR__ . '/socket-error.json', json_encode($diagnostic, JSON_UNESCAPED_UNICODE | JSON_THROW_ON_ERROR)) === false) { throw new RuntimeException('Диагностика не записана'); }
socket_clear_error($client);
socket_set_block($client);
echo "Ответ ещё не поступил; канал остаётся открыт\n";
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Ответ ещё не поступил; канал остаётся открыт
Молоток — 8 шт.

Узнать причину отказа после проверки результата операции.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Коды ОС различаются численно, поэтому сравниваем с доступными константами. Последовательные вызовы last_error не очищают записанную ошибку. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    socket_set_nonblock($receiver);
    $data = @socket_read($receiver, 8);
    if ($data !== false) throw new RuntimeException('Ожидалось отсутствие данных');
    $code = socket_last_error($receiver);
    $pending = $code === SOCKET_EWOULDBLOCK || (defined('SOCKET_EAGAIN') && $code === constant('SOCKET_EAGAIN'));
    echo $pending ? "Данные пока не готовы\n" : "Иная ошибка\n";
    echo socket_last_error($receiver) === $code ? "Чтение кода его не очищает\n" : "Код изменился\n";
} finally { labClose($sender, $receiver); }

Данные пока не готовы
Чтение кода его не очищает

Этот вариант. Общий код нужен, например, после неудачного create, когда объекта ещё нет, и для select. Сохранённый код не является непрерывным монитором здоровья сети; прежде проверяйте результат конкретного вызова.

<?php
declare(strict_types=1);

socket_clear_error();
echo socket_last_error() === 0 ? "Общей сохранённой ошибки нет\n" : "Есть прежняя ошибка\n";
$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($socket === false) throw new RuntimeException(socket_strerror(socket_last_error()));
try { echo socket_last_error($socket) === 0 ? "У нового endpoint код 0\n" : "Есть ошибка\n"; }
finally { socket_close($socket); }

Общей сохранённой ошибки нет
У нового endpoint код 0

Связанные действия: socket_clear_error, socket_strerror, socket_select.

• PHP: socket_last_error

PHP 4.2.0+ · sockets

socket_clear_error(?Socket $socket = null): void

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
socket_set_nonblock($client);
set_error_handler(function (int $level): bool { return $level === E_WARNING; });
try { $empty = socket_read($client, 1); } finally { restore_error_handler(); }
$code = socket_last_error($client);
if ($empty !== false || $code === 0) { throw new RuntimeException('Ожидалось отсутствие данных сейчас'); }
$diagnostic = ['code'=>$code, 'message'=>socket_strerror($code)];
if (file_put_contents(__DIR__ . '/socket-error.json', json_encode($diagnostic, JSON_UNESCAPED_UNICODE | JSON_THROW_ON_ERROR)) === false) { throw new RuntimeException('Диагностика не записана'); }
socket_clear_error($client);
socket_set_block($client);
echo "Ответ ещё не поступил; канал остаётся открыт\n";
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Ответ ещё не поступил; канал остаётся открыт
Молоток — 8 шт.

Явно сбросить сохранённую ошибку после обработки, не изменяя само соединение.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Сначала причина прочитана и обработана, затем очищена. clear_error не добавляет данные в очередь и не ремонтирует соединение. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    socket_set_nonblock($receiver);
    $data = @socket_read($receiver, 8);
    if ($data !== false) throw new RuntimeException('Ожидалось отсутствие данных');
    $code = socket_last_error($receiver);
    if ($code === 0) throw new RuntimeException('Нет кода отказа');
    socket_clear_error($receiver);
    echo socket_last_error($receiver) === 0 ? "История endpoint очищена\n" : "Код не сброшен\n";
} finally { labClose($sender, $receiver); }

История endpoint очищена

Этот вариант. Без аргумента сбрасывается общий код расширения. С объектом сбрасывается его собственный код. Это два разных места хранения; выбор должен соответствовать операции, ошибку которой вы читаете. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    socket_set_nonblock($receiver);
    $data = @socket_read($receiver, 8);
    if ($data !== false) throw new RuntimeException('Ожидалось отсутствие данных');
    $specific = socket_last_error($receiver);
    socket_clear_error();
    echo socket_last_error() === 0 ? "Общий код сброшен\n" : "Не сброшен\n";
    echo socket_last_error($receiver) === $specific ? "Код endpoint сохранён\n" : "Изменён\n";
} finally { labClose($sender, $receiver); }

Общий код сброшен
Код endpoint сохранён

Связанные действия: socket_last_error, socket_strerror.

• PHP: socket_clear_error

PHP 4.1.0+ · sockets

socket_strerror(int $error_code): string

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
socket_set_nonblock($client);
set_error_handler(function (int $level): bool { return $level === E_WARNING; });
try { $empty = socket_read($client, 1); } finally { restore_error_handler(); }
$code = socket_last_error($client);
if ($empty !== false || $code === 0) { throw new RuntimeException('Ожидалось отсутствие данных сейчас'); }
$diagnostic = ['code'=>$code, 'message'=>socket_strerror($code)];
if (file_put_contents(__DIR__ . '/socket-error.json', json_encode($diagnostic, JSON_UNESCAPED_UNICODE | JSON_THROW_ON_ERROR)) === false) { throw new RuntimeException('Диагностика не записана'); }
socket_clear_error($client);
socket_set_block($client);
echo "Ответ ещё не поступил; канал остаётся открыт\n";
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Ответ ещё не поступил; канал остаётся открыт
Молоток — 8 шт.

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

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Само описание зависит от ОС и локали, поэтому одинаковую английскую/русскую фразу всем платформам не обещаем. Чтобы увидеть её на своём компьютере, выведите $description. Соединение здесь не выполняется.

<?php
declare(strict_types=1);

$description = socket_strerror(SOCKET_ECONNREFUSED);
echo is_string($description) && $description !== ''
    ? "Для отказа подключения получено описание ОС\n" : "Нет описания\n";

Для отказа подключения получено описание ОС

Этот вариант. Для решения программы используйте код и контекст операции, а не парсинг локализованной строки. В пользовательский ответ не обязательно выводить внутренние адреса/детали ОС; журнал и публичное сообщение имеют разные задачи. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    socket_set_nonblock($receiver);
    $data = @socket_read($receiver, 8);
    if ($data !== false) throw new RuntimeException('Ожидалось отсутствие данных');
    $code = socket_last_error($receiver);
    $diagnostic = ['operation' => 'read-stock', 'code' => $code, 'message' => socket_strerror($code)];
    echo $diagnostic['operation'], "\n";
    echo $diagnostic['code'] !== 0 && $diagnostic['message'] !== '' ? "Код и описание сохранены\n" : "Диагностика пуста\n";
} finally { labClose($sender, $receiver); }

read-stock
Код и описание сохранены

Связанные действия: socket_last_error, socket_clear_error.

• PHP: socket_strerror

PHP 7.2+ · sockets

socket_addrinfo_lookup(string $host, ?string $service = null, array $hints = []): array|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$items = socket_addrinfo_lookup('127.0.0.1', '0', ['ai_family'=>AF_INET, 'ai_socktype'=>SOCK_STREAM, 'ai_protocol'=>SOL_TCP, 'ai_flags'=>AI_NUMERICHOST]);
if ($items === false || $items === []) { throw new RuntimeException('Нет описания адреса'); }
$details = socket_addrinfo_explain($items[0]);
if ($details['ai_addr']['sin_addr'] !== '127.0.0.1') { throw new RuntimeException('Не локальный адрес'); }
$listener = socket_addrinfo_bind($items[0]);
if ($listener === false || !socket_listen($listener, 2)) { throw new RuntimeException('Слушатель не создан'); }
socket_getsockname($listener, $host, $port);
$targets = socket_addrinfo_lookup($host, (string)$port, ['ai_family'=>AF_INET, 'ai_socktype'=>SOCK_STREAM, 'ai_flags'=>AI_NUMERICHOST]);
if ($targets === false || $targets === []) { throw new RuntimeException('Нет адреса назначения'); }
$client = socket_addrinfo_connect($targets[0]);
if ($client === false) { throw new RuntimeException('Клиент не создан'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Клиент не принят'); }
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Получить варианты адреса для будущего bind/connect, ещё не открывая соединение.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Массив hints ограничивает поиск IPv4 и потоком. Числовые флаги запрещают разрешение имени узла/службы. Результат пока только описывает адрес; к порту 8080 никто не подключался.

<?php
declare(strict_types=1);

$items = socket_addrinfo_lookup('127.0.0.1', '8080', [
    'ai_family' => AF_INET, 'ai_socktype' => SOCK_STREAM,
    'ai_flags' => AI_NUMERICHOST | AI_NUMERICSERV,
]);
if ($items === false || $items === []) throw new RuntimeException('Нет адреса');
$view = socket_addrinfo_explain($items[0]);
echo $view['ai_addr']['sin_addr'], ':', $view['ai_addr']['sin_port'], "\n";

127.0.0.1:8080

Этот вариант. В PHP 8.5 неизвестный ключ hints — ValueError. Не передавайте сюда произвольный массив из запроса. Обычный неудачный поиск возвращает false и не обязан обновлять socket_last_error: старый код ошибки сокета не является диагнозом DNS.

<?php
declare(strict_types=1);

try {
    socket_addrinfo_lookup('127.0.0.1', '80', ['family' => AF_INET]);
} catch (ValueError $error) {
    echo "Ключ называется ai_family\n";
}

Ключ называется ai_family

service — строка номера порта либо имя службы из базы ОС, например http. Это не путь URL. null оставляет службу неуказанной. У одного имени бывают несколько IPv4/IPv6 кандидатов: первый может оказаться недоступен, поэтому прикладной клиент пробует допустимые кандидаты по политике и общему сроку. AF_UNIX не принимается этим resolver API. hints не задаёт таймаут DNS или подключения; для защищённого клиента также нужна проверка адресов и повторных разрешений, иначе возникает SSRF.

Связанные действия: socket_addrinfo_explain, socket_addrinfo_bind, socket_addrinfo_connect.

• PHP: socket_addrinfo_lookup

PHP 7.2+ · sockets

socket_addrinfo_explain(AddressInfo $address): array

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$items = socket_addrinfo_lookup('127.0.0.1', '0', ['ai_family'=>AF_INET, 'ai_socktype'=>SOCK_STREAM, 'ai_protocol'=>SOL_TCP, 'ai_flags'=>AI_NUMERICHOST]);
if ($items === false || $items === []) { throw new RuntimeException('Нет описания адреса'); }
$details = socket_addrinfo_explain($items[0]);
if ($details['ai_addr']['sin_addr'] !== '127.0.0.1') { throw new RuntimeException('Не локальный адрес'); }
$listener = socket_addrinfo_bind($items[0]);
if ($listener === false || !socket_listen($listener, 2)) { throw new RuntimeException('Слушатель не создан'); }
socket_getsockname($listener, $host, $port);
$targets = socket_addrinfo_lookup($host, (string)$port, ['ai_family'=>AF_INET, 'ai_socktype'=>SOCK_STREAM, 'ai_flags'=>AI_NUMERICHOST]);
if ($targets === false || $targets === []) { throw new RuntimeException('Нет адреса назначения'); }
$client = socket_addrinfo_connect($targets[0]);
if ($client === false) { throw new RuntimeException('Клиент не создан'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Клиент не принят'); }
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

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

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Ключи ai_* описывают договор адреса; sin_port уже целое число в привычном порядке байтов. Читать внутренние свойства AddressInfo не нужно.

<?php
declare(strict_types=1);

$items = socket_addrinfo_lookup('127.0.0.1', '9000', ['ai_family' => AF_INET, 'ai_socktype' => SOCK_DGRAM]);
if ($items === false || $items === []) throw new RuntimeException('Нет адреса');
$info = socket_addrinfo_explain($items[0]);
echo $info['ai_family'] === AF_INET ? "IPv4\n" : "Иное семейство\n";
echo $info['ai_socktype'] === SOCK_DGRAM ? "Датаграммы\n" : "Иной тип\n";
echo $info['ai_addr']['sin_port'], "\n";

IPv4
Датаграммы
9000

Этот вариант. Ветка IPv6 добавляет скобки в подпись адрес:порт. Это формат журнала, а не аргумент socket_connect: туда IPv6 передают без скобок.

<?php
declare(strict_types=1);

function candidateLabel(AddressInfo $candidate): string {
    $data = socket_addrinfo_explain($candidate);
    if ($data['ai_family'] === AF_INET) {
        return $data['ai_addr']['sin_addr'] . ':' . $data['ai_addr']['sin_port'];
    }
    return '[' . $data['ai_addr']['sin6_addr'] . ']:' . $data['ai_addr']['sin6_port'];
}
$items = socket_addrinfo_lookup('127.0.0.1', '8081', ['ai_family' => AF_INET, 'ai_socktype' => SOCK_STREAM]);
if ($items === false || $items === []) throw new RuntimeException('Нет кандидатов');
echo candidateLabel($items[0]), "\n";

127.0.0.1:8081

Результат содержит ai_flags, ai_family, ai_socktype, ai_protocol, ai_addr и при наличии ai_canonname. В IPv4 ai_addr содержит sin_addr/sin_port, в IPv6 — sin6_addr/sin6_port. Не переносите сюда автоматически поля flowinfo/scope_id из структуры sendmsg: текущий explain их не выдаёт. Изменение возвращённого массива не меняет исходный AddressInfo; он остаётся непрозрачным описанием resolver.

Связанные действия: socket_addrinfo_lookup, AddressInfo.

• PHP: socket_addrinfo_explain

PHP 7.2+ · sockets

socket_addrinfo_bind(AddressInfo $address): Socket|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$items = socket_addrinfo_lookup('127.0.0.1', '0', ['ai_family'=>AF_INET, 'ai_socktype'=>SOCK_STREAM, 'ai_protocol'=>SOL_TCP, 'ai_flags'=>AI_NUMERICHOST]);
if ($items === false || $items === []) { throw new RuntimeException('Нет описания адреса'); }
$details = socket_addrinfo_explain($items[0]);
if ($details['ai_addr']['sin_addr'] !== '127.0.0.1') { throw new RuntimeException('Не локальный адрес'); }
$listener = socket_addrinfo_bind($items[0]);
if ($listener === false || !socket_listen($listener, 2)) { throw new RuntimeException('Слушатель не создан'); }
socket_getsockname($listener, $host, $port);
$targets = socket_addrinfo_lookup($host, (string)$port, ['ai_family'=>AF_INET, 'ai_socktype'=>SOCK_STREAM, 'ai_flags'=>AI_NUMERICHOST]);
if ($targets === false || $targets === []) { throw new RuntimeException('Нет адреса назначения'); }
$client = socket_addrinfo_connect($targets[0]);
if ($client === false) { throw new RuntimeException('Клиент не создан'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Клиент не принят'); }
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Создать и привязать endpoint, используя уже найденное сочетание адреса, типа и протокола.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. bind создаёт Socket и привязывает его одним вызовом. Исходный AddressInfo с портом 0 остаётся описанием запроса; фактический порт надо читать у Socket.

<?php
declare(strict_types=1);

$items = socket_addrinfo_lookup('127.0.0.1', '0', ['ai_family' => AF_INET, 'ai_socktype' => SOCK_DGRAM]);
if ($items === false || $items === []) throw new RuntimeException('Нет адреса');
$socket = socket_addrinfo_bind($items[0]);
if ($socket === false) throw new RuntimeException('Не удалось привязать');
try {
    socket_getsockname($socket, $address, $port);
    echo $address, "\n", $port > 0 ? "Порт выбран ОС\n" : "Ошибка\n";
} finally { socket_close($socket); }

127.0.0.1
Порт выбран ОС

Этот вариант. Функция не вызывает listen. Отдельный шаг делает слушающий сервер из привязанного TCP endpoint. Здесь ни один публичный интерфейс не открывается.

<?php
declare(strict_types=1);

$items = socket_addrinfo_lookup('127.0.0.1', '0', ['ai_family' => AF_INET, 'ai_socktype' => SOCK_STREAM]);
if ($items === false || $items === []) throw new RuntimeException('Нет кандидата');
$listener = socket_addrinfo_bind($items[0]);
if ($listener === false) throw new RuntimeException('Нет endpoint');
try {
    if (!socket_listen($listener, 2)) throw new RuntimeException('Нет очереди');
    echo "TCP listener создан из AddressInfo\n";
} finally { socket_close($listener); }

TCP listener создан из AddressInfo

Связанные действия: socket_addrinfo_lookup, socket_listen, socket_getsockname.

• PHP: socket_addrinfo_bind

PHP 7.2+ · sockets

socket_addrinfo_connect(AddressInfo $address): Socket|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$items = socket_addrinfo_lookup('127.0.0.1', '0', ['ai_family'=>AF_INET, 'ai_socktype'=>SOCK_STREAM, 'ai_protocol'=>SOL_TCP, 'ai_flags'=>AI_NUMERICHOST]);
if ($items === false || $items === []) { throw new RuntimeException('Нет описания адреса'); }
$details = socket_addrinfo_explain($items[0]);
if ($details['ai_addr']['sin_addr'] !== '127.0.0.1') { throw new RuntimeException('Не локальный адрес'); }
$listener = socket_addrinfo_bind($items[0]);
if ($listener === false || !socket_listen($listener, 2)) { throw new RuntimeException('Слушатель не создан'); }
socket_getsockname($listener, $host, $port);
$targets = socket_addrinfo_lookup($host, (string)$port, ['ai_family'=>AF_INET, 'ai_socktype'=>SOCK_STREAM, 'ai_flags'=>AI_NUMERICHOST]);
if ($targets === false || $targets === []) { throw new RuntimeException('Нет адреса назначения'); }
$client = socket_addrinfo_connect($targets[0]);
if ($client === false) { throw new RuntimeException('Клиент не создан'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Клиент не принят'); }
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Создать подключённый endpoint по одному кандидату адреса.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Весь обмен остаётся в одном процессе и на loopback. Приведение порта к string нужно для service; connect создаёт новый объект, которому затем отправляют три байта. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
$listener = labListener(); socket_getsockname($listener, $address, $port);
$items = socket_addrinfo_lookup($address, (string)$port, ['ai_family' => AF_INET, 'ai_socktype' => SOCK_STREAM]);
if ($items === false || $items === []) throw new RuntimeException('Нет адреса');
$client = socket_addrinfo_connect($items[0]);
if ($client === false) throw new RuntimeException('Нет подключения');
$peer = socket_accept($listener);
if ($peer === false) throw new RuntimeException('Нет клиента');
try { labWriteAll($client, 'A42'); echo labReadExact($peer, 3), "\n"; }
finally { labClose($peer, $client, $listener); }

A42

Этот вариант. Для SOCK_DGRAM connect выбирает адрес по умолчанию и фильтрует peer, но не подтверждает наличие/доступность сервиса. Приём локального пакета доказывает лишь этот учебный обмен. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$receiver, $unused, $port] = labUdp(); socket_close($unused);
$items = socket_addrinfo_lookup('127.0.0.1', (string)$port, ['ai_family' => AF_INET, 'ai_socktype' => SOCK_DGRAM]);
if ($items === false || $items === []) throw new RuntimeException('Нет адреса');
$sender = socket_addrinfo_connect($items[0]);
if ($sender === false) throw new RuntimeException('Нет endpoint');
try {
    if (socket_send($sender, 'T=21', 4, 0) !== 4) throw new RuntimeException('Нет отправки');
    if (socket_recvfrom($receiver, $data, 32, 0, $from, $fromPort) === false) throw new RuntimeException('Нет данных');
    echo $data, "\n";
} finally { labClose($sender, $receiver); }

T=21

Это удобное сочетание create+connect, но до соединения у вас ещё нет Socket для задания non-blocking режима. Для управляемого срока подключения используйте отдельные create, set_nonblock, connect, select и проверку SO_ERROR. Не обещайте таймаут через последующий SO_RCVTIMEO: это другая стадия.

Связанные действия: socket_addrinfo_lookup, socket_connect, socket_set_nonblock.

• PHP: socket_addrinfo_connect

PHP 8.0+ · sockets

final class Socket { /* opaque */ }

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$items = socket_addrinfo_lookup('127.0.0.1', '0', ['ai_family'=>AF_INET, 'ai_socktype'=>SOCK_STREAM, 'ai_protocol'=>SOL_TCP, 'ai_flags'=>AI_NUMERICHOST]);
if ($items === false || $items === []) { throw new RuntimeException('Нет описания адреса'); }
$details = socket_addrinfo_explain($items[0]);
if ($details['ai_addr']['sin_addr'] !== '127.0.0.1') { throw new RuntimeException('Не локальный адрес'); }
$listener = socket_addrinfo_bind($items[0]);
if ($listener === false || !socket_listen($listener, 2)) { throw new RuntimeException('Слушатель не создан'); }
socket_getsockname($listener, $host, $port);
$targets = socket_addrinfo_lookup($host, (string)$port, ['ai_family'=>AF_INET, 'ai_socktype'=>SOCK_STREAM, 'ai_flags'=>AI_NUMERICHOST]);
if ($targets === false || $targets === []) { throw new RuntimeException('Нет адреса назначения'); }
$client = socket_addrinfo_connect($targets[0]);
if ($client === false) { throw new RuntimeException('Клиент не создан'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Клиент не принят'); }
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Различать конечная точка и обычный пользовательский объект с открытыми свойствами.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. instanceof проверяет объект специального класса. Его внутренний системный ресурс скрыт: взаимодействовать с ним нужно функциями sockets.

<?php
declare(strict_types=1);

$item = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($item === false) throw new RuntimeException('Нет сокета');
echo $item instanceof Socket ? "Socket: конечная точка\n" : "Ошибка\n";
socket_close($item);

Socket: конечная точка

Этот вариант. Класс final и непрозрачный: у него нет пользовательского конструктора, полей настройки или метода connect. Error здесь пойман ради демонстрации неправильного способа создания.

<?php
declare(strict_types=1);

try { $item = new Socket(); }
catch (Error $error) { echo "Используйте фабрику расширения\n"; }

Используйте фабрику расширения

Socket хранит живой endpoint; AddressInfo хранит результат поиска адреса. Присваивание объекта другой переменной не копирует системный endpoint. Для Socket нужен явный close в finally, когда обмен завершён; AddressInfo не имеет функции close и освобождается обычным временем жизни объекта. Эти внутренние объекты нельзя использовать как сериализованный транспорт между процессами.

Связанные действия: socket_create, socket_close.

• PHP: Socket

PHP 8.0+ · sockets

final class AddressInfo { /* opaque */ }

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$items = socket_addrinfo_lookup('127.0.0.1', '0', ['ai_family'=>AF_INET, 'ai_socktype'=>SOCK_STREAM, 'ai_protocol'=>SOL_TCP, 'ai_flags'=>AI_NUMERICHOST]);
if ($items === false || $items === []) { throw new RuntimeException('Нет описания адреса'); }
$details = socket_addrinfo_explain($items[0]);
if ($details['ai_addr']['sin_addr'] !== '127.0.0.1') { throw new RuntimeException('Не локальный адрес'); }
$listener = socket_addrinfo_bind($items[0]);
if ($listener === false || !socket_listen($listener, 2)) { throw new RuntimeException('Слушатель не создан'); }
socket_getsockname($listener, $host, $port);
$targets = socket_addrinfo_lookup($host, (string)$port, ['ai_family'=>AF_INET, 'ai_socktype'=>SOCK_STREAM, 'ai_flags'=>AI_NUMERICHOST]);
if ($targets === false || $targets === []) { throw new RuntimeException('Нет адреса назначения'); }
$client = socket_addrinfo_connect($targets[0]);
if ($client === false) { throw new RuntimeException('Клиент не создан'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Клиент не принят'); }
localTimeout($client);
localTimeout($peer);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Различать описание адреса и обычный пользовательский объект с открытыми свойствами.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. instanceof проверяет объект специального класса. Его внутренний системный ресурс скрыт: взаимодействовать с ним нужно функциями sockets.

<?php
declare(strict_types=1);

$items = socket_addrinfo_lookup('127.0.0.1', '80', ['ai_family' => AF_INET, 'ai_socktype' => SOCK_STREAM]);
if ($items === false || $items === []) throw new RuntimeException('Нет адреса');
$item = $items[0];
echo $item instanceof AddressInfo ? "AddressInfo: описание адреса\n" : "Ошибка\n";

AddressInfo: описание адреса

Этот вариант. Класс final и непрозрачный: у него нет пользовательского конструктора, полей настройки или метода connect. Error здесь пойман ради демонстрации неправильного способа создания.

<?php
declare(strict_types=1);

try { $item = new AddressInfo(); }
catch (Error $error) { echo "Используйте фабрику расширения\n"; }

Используйте фабрику расширения

Socket хранит живой endpoint; AddressInfo хранит результат поиска адреса. Присваивание объекта другой переменной не копирует системный endpoint. Для Socket нужен явный close в finally, когда обмен завершён; AddressInfo не имеет функции close и освобождается обычным временем жизни объекта. Эти внутренние объекты нельзя использовать как сериализованный транспорт между процессами.

Связанные действия: socket_addrinfo_lookup, socket_addrinfo_explain.

• PHP: AddressInfo

PHP 4.1.0+ · sockets

socket_get_option(Socket $socket, int $level, int $option): array|int|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
$timeout = socket_get_option($client, SOL_SOCKET, SO_RCVTIMEO);
if ($timeout === false || $timeout['sec'] !== 2) { throw new RuntimeException('Неожиданный срок чтения'); }
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Проверить фактическое свойство endpoint вместо предположения, что ОС приняла ровно запрошенное значение.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. SOL_SOCKET выбирает общий уровень; SO_TYPE — его конкретное свойство. Это свойство только для чтения; записать новый тип вместо создания другого сокета нельзя.

<?php
declare(strict_types=1);

$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($socket === false) throw new RuntimeException('Нет сокета');
try {
    $type = socket_get_option($socket, SOL_SOCKET, SO_TYPE);
    if ($type === false) throw new RuntimeException('Не прочитали тип');
    echo $type === SOCK_DGRAM ? "Endpoint передаёт датаграммы\n" : "Иной тип\n";
} finally { socket_close($socket); }

Endpoint передаёт датаграммы

Этот вариант. SO_LINGER возвращает массив, а не bool. Выключенная настройка не означает, что TCP гарантировал доставку последнего сообщения: прикладной ACK решает другую задачу.

<?php
declare(strict_types=1);

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket === false) throw new RuntimeException('Нет сокета');
try {
    if (!socket_set_option($socket, SOL_SOCKET, SO_LINGER, ['l_onoff' => 0, 'l_linger' => 0])) throw new RuntimeException('Нет настройки');
    $linger = socket_get_option($socket, SOL_SOCKET, SO_LINGER);
    if ($linger === false) throw new RuntimeException('Нет результата');
    echo $linger['l_onoff'] === 0 ? "Дополнительное ожидание close выключено\n" : "Включено\n";
    echo 'Поле срока: ', $linger['l_linger'], "\n";
} finally { socket_close($socket); }

Дополнительное ожидание close выключено
Поле срока: 0

SO_ERROR читает и очищает отложенную ошибку ядра: после готовности неблокирующего connect это решающий тест, потому что готовность к записи сама по себе не доказывает успех. socket_last_error хранит отдельную ошибку PHP и не эквивалентен SO_ERROR. Размеры SO_SNDBUF/SO_RCVBUF ограничивает и иногда удваивает ОС; не проверяйте их на точное равенство запросу. Таймауты возвращаются массивом sec/usec и могут округляться.

Связанные действия: socket_set_option, socket_last_error, socket_getopt.

• PHP: socket_get_option

PHP 4.1.0+ · sockets

socket_set_option(Socket $socket, int $level, int $option, array|string|int $value): bool

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
if (!socket_set_option($client, SOL_TCP, TCP_NODELAY, 1)) { throw new RuntimeException('TCP_NODELAY не применён'); }
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Изменить конкретное свойство сокета: таймаут, буфер, TCP поведение или разрешённую multicast-настройку.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Массив означает две секунды и ноль микросекунд. В примере никто не ждёт таймаут: мы конфигурируем endpoint и читаем его фактическую настройку. Это не общий срок всей операции и не срок DNS.

<?php
declare(strict_types=1);

$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($socket === false) throw new RuntimeException('Нет сокета');
try {
    $ok = socket_set_option($socket, SOL_SOCKET, SO_RCVTIMEO, ['sec' => 2, 'usec' => 0]);
    if (!$ok) throw new RuntimeException('Таймаут не установлен');
    $timeout = socket_get_option($socket, SOL_SOCKET, SO_RCVTIMEO);
    echo $timeout['sec'] >= 1 ? "Предел ожидания чтения задан\n" : "Ошибка\n";
} finally { socket_close($socket); }

Предел ожидания чтения задан

Этот вариант. NODELAY влияет на TCP пакетизацию, но не создаёт границы сообщений и не обещает немедленную доставку. Разделитель строки остаётся частью нашего протокола. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$listener, $client, $peer] = labTcp();
try {
    if (!socket_set_option($client, SOL_TCP, TCP_NODELAY, 1)) throw new RuntimeException('Не удалось настроить TCP');
    echo socket_get_option($client, SOL_TCP, TCP_NODELAY) === 1 ? "Nagle выключен для клиента\n" : "Ошибка\n";
    labWriteAll($client, "A42\n"); echo labReadExact($peer, 4);
} finally { labClose($peer, $client, $listener); }

Nagle выключен для клиента
A42

Опции не имеют единого универсального default: он зависит от ОС, типа, протокола и системных настроек. Для используемых значений читайте get_option и проверяйте результат set_option. Наличие константы не гарантирует, что PHP преобразует любую сложную C-структуру соответствующего setsockopt. Полный каталог констант отделяет идентификаторы от форм поддерживаемых значений.

PHP 8.5 строже проверяет некорректные multicast-структуры и неподдерживаемые семейства; ошибки формы/диапазона могут быть TypeError/ValueError, а отказ ядра — warning/false. Не подавляйте предупреждение и затем продолжайте как будто настройка применена. REUSEADDR/REUSEPORT имеют разные правила ОС и могут менять изоляцию нескольких процессов; слушатель нашего примера обходится без них.

Связанные действия: socket_get_option, socket_select, socket_setopt.

• PHP: socket_set_option

PHP 4.1.0+ · sockets

socket_getopt(Socket $socket, int $level, int $option): array|int|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
$timeout = socket_get_option($client, SOL_SOCKET, SO_RCVTIMEO);
if ($timeout === false || $timeout['sec'] !== 2) { throw new RuntimeException('Неожиданный срок чтения'); }
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Понимать краткое имя socket_get_option при чтении существующей программы.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Это alias: та же реализация, а не отдельный режим с иными единицами измерения. В новом коде полное имя яснее.

<?php
declare(strict_types=1);

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket === false) throw new RuntimeException('Нет endpoint');
try { echo socket_getopt($socket, SOL_SOCKET, SO_TYPE) === SOCK_STREAM ? "Поток байтов\n" : "Ошибка\n"; }
finally { socket_close($socket); }

Поток байтов

Этот вариант. Строгое сравнение отличает значение 0 от false. Собственная функция задаёт политику приложения, а alias сохраняет договор полной функции.

<?php
declare(strict_types=1);

$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($socket === false) throw new RuntimeException('Нет endpoint');
try {
    if (!socket_set_option($socket, SOL_SOCKET, SO_BROADCAST, 0)) throw new RuntimeException('Не установлено');
    $value = socket_getopt($socket, SOL_SOCKET, SO_BROADCAST);
    if ($value === false) throw new RuntimeException('Ошибка чтения');
    echo $value === 0 ? "Ноль — корректное значение опции\n" : "Иное значение\n";
} finally { socket_close($socket); }

Ноль — корректное значение опции

Все уровни, значения, системные ограничения, возвраты и ошибки совпадают с socket_get_option. Название не помечено PHP.net устаревшим; его можно встретить в старых библиотеках. Не путайте sockets aliases с socket_set_timeout/socket_set_blocking: последние относятся к streams.

Связанные действия: socket_get_option, socket_close.

• PHP: socket_getopt

PHP 4.1.0+ · sockets

socket_setopt(Socket $socket, int $level, int $option, array|string|int $value): bool

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
if (!socket_set_option($client, SOL_TCP, TCP_NODELAY, 1)) { throw new RuntimeException('TCP_NODELAY не применён'); }
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Понимать краткое имя socket_set_option при чтении существующей программы.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Это alias: та же реализация, а не отдельный режим с иными единицами измерения. В новом коде полное имя яснее.

<?php
declare(strict_types=1);

$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($socket === false) throw new RuntimeException('Нет endpoint');
try {
    if (!socket_setopt($socket, SOL_SOCKET, SO_BROADCAST, 0)) throw new RuntimeException('Не удалось настроить');
    echo socket_get_option($socket, SOL_SOCKET, SO_BROADCAST) === 0 ? "Broadcast не разрешён\n" : "Ошибка\n";
} finally { socket_close($socket); }

Broadcast не разрешён

Этот вариант. Строгое сравнение отличает значение 0 от false. Собственная функция задаёт политику приложения, а alias сохраняет договор полной функции.

<?php
declare(strict_types=1);

function boundRead(Socket $socket, int $seconds): void {
    if ($seconds < 1 || $seconds > 5) throw new InvalidArgumentException('Допустимо 1…5 секунд');
    if (!socket_setopt($socket, SOL_SOCKET, SO_RCVTIMEO, ['sec' => $seconds, 'usec' => 0])) throw new RuntimeException('Не установлено');
}
$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($socket === false) throw new RuntimeException('Нет endpoint');
try { boundRead($socket, 1); echo "Политика локального чтения применена\n"; }
finally { socket_close($socket); }

Политика локального чтения применена

Все уровни, значения, системные ограничения, возвраты и ошибки совпадают с socket_set_option. Название не помечено PHP.net устаревшим; его можно встретить в старых библиотеках. Не путайте sockets aliases с socket_set_timeout/socket_set_blocking: последние относятся к streams.

Связанные действия: socket_set_option, socket_close.

• PHP: socket_setopt

PHP 7.0.7+ · sockets

socket_export_stream(Socket $socket): resource|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
$stream = socket_export_stream($client);
if ($stream === false) { throw new RuntimeException('Не удалось получить stream'); }
stream_set_timeout($stream, 2);
if (fwrite($stream, "product:1\n") !== 10) { throw new RuntimeException('Запрос не записан'); }
serveProduct($peer);
$json = fgets($stream, 4097);
if ($json === false) { throw new RuntimeException('Нет ответа'); }
showProduct($json);
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Подключить stream-функции к уже имеющемуся сокету, сохранив один endpoint.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. resource stream и объект Socket представляют один endpoint. Здесь закрытие поручено socket_close: повторный fclose того же ресурса не нужен. Для длинных записей нужен цикл обработки частичной записи. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$sender, $receiver] = labPair();
try {
    $stream = socket_export_stream($sender);
    if ($stream === false) throw new RuntimeException('Нет stream');
    if (fwrite($stream, 'A42') !== 3) throw new RuntimeException('Неполная запись');
    echo labReadExact($receiver, 3), "\n";
} finally { labClose($sender, $receiver); }

A42

Этот вариант. Существующий stream возвращается повторно. Метаданные относятся к stream; его read timeout первоначально берётся из default_socket_timeout, поэтому настройки stream и sockets надо задавать явно в выбранном интерфейсе. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$a, $b] = labPair();
try {
    $first = socket_export_stream($a); $second = socket_export_stream($a);
    if ($first === false || $second === false) throw new RuntimeException('Нет stream');
    echo $first === $second ? "Это тот же stream\n" : "Иной ресурс\n";
    echo stream_get_meta_data($first)['blocked'] ? "Блокирующий режим\n" : "Неблокирующий режим\n";
} finally { labClose($a, $b); }

Это тот же stream
Блокирующий режим

Не чередуйте чтение через fread и socket_read без понимания буферизации: данные уже могли уйти в буфер одного слоя. Выберите один API для потока данных. socket_export_stream не добавляет TLS и не превращает байты в HTTP. Явное закрытие Socket инвалидирует связанный stream; обратное закрытие тоже делает дальнейший обмен через прежний endpoint недопустимым.

Связанные действия: socket_import_stream, socket_close.

• PHP: socket_export_stream

PHP 5.4+ · sockets

socket_import_stream(resource $stream): Socket|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$listener = localListener();
socket_getsockname($listener, $host, $port);
$stream = stream_socket_client('tcp://'.$host.':'.$port, $number, $message, 1);
if ($stream === false) { throw new RuntimeException('Нет stream-клиента'); }
$client = socket_import_stream($stream);
if ($client === false) { throw new RuntimeException('Stream не является сетевым'); }
$peer = socket_accept($listener);
if ($peer === false) { throw new RuntimeException('Нет принятого клиента'); }
localTimeout($client);
localTimeout($peer);
socket_set_option($client, SOL_TCP, TCP_NODELAY, 1);
writeBytes($client, "product:1\n");
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Настроить системный сокет, стоящий за существующим сетевым stream.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Сначала создан собственный локальный сервер, поэтому внешний адрес не нужен. Импорт полезен для сетевой опции, которой нет в высокоуровневом API; чтение/запись приложения можно оставить stream-функциям. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
$listener = labListener(); socket_getsockname($listener, $host, $port);
$stream = stream_socket_client("tcp://$host:$port", $number, $message, 2);
if ($stream === false) throw new RuntimeException('Нет stream-клиента');
$peer = socket_accept($listener);
if ($peer === false) throw new RuntimeException('Нет клиента');
$socket = socket_import_stream($stream);
if ($socket === false) throw new RuntimeException('Не сетевой stream');
try {
    if (!socket_set_option($socket, SOL_TCP, TCP_NODELAY, 1)) throw new RuntimeException('Нет настройки');
    echo socket_get_option($socket, SOL_TCP, TCP_NODELAY) === 1 ? "TCP stream настроен через Socket\n" : "Ошибка\n";
} finally { labClose($socket, $peer, $listener); }

TCP stream настроен через Socket

Этот вариант. @ здесь локально подавляет ожидаемое предупреждение демонстрации отказа; false всё равно проверяется. В приложении сохраните диагностику через свой обработчик. resource сам по себе ещё не означает сеть.

<?php
declare(strict_types=1);

$file = fopen('php://temp', 'w+b');
if ($file === false) throw new RuntimeException('Нет временного stream');
try {
    $socket = @socket_import_stream($file);
    echo $socket === false ? "Этот stream не содержит сетевой descriptor\n" : "Неожиданный Socket\n";
} finally { fclose($file); }

Этот stream не содержит сетевой descriptor

Импорт не дублирует соединение и отключает read buffering на поддерживаемом stream. Если stream использует TLS, его шифрование реализовано слоем stream: низкоуровневое socket_read/socket_write не выполняет TLS-протокол. Для TLS оставляйте передачу данных stream API, а Socket используйте только для подходящих системных опций. Не сериализуйте Socket в очередь задач.

Связанные действия: socket_export_stream, socket_set_option.

• PHP: socket_import_stream

PHP 5.5+ · sockets

socket_sendmsg(Socket $socket, array $message, int $flags = 0): int|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$receiver = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
$sender = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
if (!socket_bind($receiver, '127.0.0.1', 0) || !socket_bind($sender, '127.0.0.1', 0)) { throw new RuntimeException('UDP не привязан'); }
localTimeout($receiver);
localTimeout($sender);
socket_getsockname($receiver, $host, $port);
$payload = "Молоток;8\n";
$sent = socket_sendmsg($sender, ['name'=>['addr'=>'127.0.0.1','port'=>$port], 'iov'=>['Молоток;', "8\n"]], 0);
if ($sent !== strlen($payload)) { throw new RuntimeException('Датаграмма не отправлена полностью'); }
$received = socket_recvfrom($receiver, $data, 1024, 0, $from, $fromPort);
if ($received === false || $data !== $payload) { throw new RuntimeException('Датаграмма не получена целиком'); }
echo "Получена строка инвентаризации:\n", $data;
socket_close($sender);
socket_close($receiver);

Получена строка инвентаризации:
Молоток;8

Передать сообщение из нескольких буферов и, при необходимости, поддержанные ancillary-данные.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. iov — список буферов; они идут по порядку в одном UDP сообщении. Индексы списка не отправляются. name задаёт получателя, flags передаётся отдельным третьим аргументом. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$receiver, $sender, $port] = labUdp();
try {
    $count = socket_sendmsg($sender, ['name' => ['addr' => '127.0.0.1', 'port' => $port], 'iov' => ['A42=', '7']], 0);
    if ($count !== 5) throw new RuntimeException('Неполная отправка');
    if (socket_recvfrom($receiver, $data, 32, 0, $from, $fromPort) === false) throw new RuntimeException('Нет сообщения');
    echo $count, "\n", $data, "\n";
} finally { labClose($sender, $receiver); }

5
A42=7

Этот вариант. У подключённого UDP endpoint уже есть адрес назначения. Это всё ещё UDP, а не подтверждение доставки в момент sendmsg. Датаграмму действительно получает только последующий recvfrom. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$receiver, $sender, $port] = labUdp();
try {
    if (!socket_connect($sender, '127.0.0.1', $port)) throw new RuntimeException('Нет peer');
    if (socket_sendmsg($sender, ['iov' => ['T=', '21']], 0) !== 4) throw new RuntimeException('Не отправлено');
    if (socket_recvfrom($receiver, $data, 32, 0, $from, $fromPort) === false) throw new RuntimeException('Нет пакета');
    echo $data, "\n";
} finally { labClose($sender, $receiver); }

T=21

Для SOL_SOCKET/SCM_RIGHTS data — непустой список Socket или stream; это передача открытых дескрипторов между доверенными Unix-процессами, не пересылка содержимого файла. Нужен хотя бы один обычный байт. SCM_CREDENTIALS (или системные SCM_CREDS/CREDS2) несёт pid/uid/gid. Для IPPROTO_IPV6: IPV6_PKTINFO принимает addr/ifindex, IPV6_HOPLIMIT и IPV6_TCLASS — int. Доступность определяется ОС. Получение показано рядом с recvmsg/cmsg_space.

Связанные действия: socket_recvmsg, socket_cmsg_space, socket_sendto.

• PHP: socket_sendmsg

PHP 5.5+ · sockets

socket_recvmsg(Socket $socket, array &$message, int $flags = 0): int|false

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
$receiver = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
$sender = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
if (!socket_bind($receiver, '127.0.0.1', 0) || !socket_bind($sender, '127.0.0.1', 0)) { throw new RuntimeException('UDP не привязан'); }
localTimeout($receiver);
localTimeout($sender);
socket_getsockname($receiver, $host, $port);
$payload = "Молоток;8\n";
$sent = socket_sendto($sender, $payload, strlen($payload), 0, '127.0.0.1', $port);
if ($sent !== strlen($payload)) { throw new RuntimeException('Датаграмма не отправлена полностью'); }
$message = ['buffer_size'=>1024, 'controllen'=>64];
$received = socket_recvmsg($receiver, $message, 0);
$data = implode('', $message['iov'] ?? []);
if ($received === false || $data !== $payload) { throw new RuntimeException('Датаграмма не получена целиком'); }
echo "Получена строка инвентаризации:\n", $data;
socket_close($sender);
socket_close($receiver);

Получена строка инвентаризации:
Молоток;8

Получить байты, адрес и ancillary-данные одним системным чтением.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. До вызова массив задаёт размеры буферов; после вызова это уже полученное сообщение. controllen здесь небольшой резерв без запроса ancillary-опций; для конкретной структуры используйте cmsg_space. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$receiver, $sender, $port] = labUdp();
try {
    if (socket_sendto($sender, 'A42=7', 5, 0, '127.0.0.1', $port) !== 5) throw new RuntimeException('Нет отправки');
    $message = ['buffer_size' => 32, 'controllen' => 64];
    $count = socket_recvmsg($receiver, $message, 0);
    if ($count === false) throw new RuntimeException('Нет сообщения');
    echo $count, "\n", implode('', $message['iov']), "\n";
} finally { labClose($sender, $receiver); }

5
A42=7

Этот вариант. name резервирует получение адреса. flags — выходные признаки ядра; это не копия третьего аргумента. Полученный адрес идентифицирует endpoint, но не аутентифицирует человека или устройство. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
[$receiver, $sender, $port] = labUdp(); socket_getsockname($sender, $sourceAddress, $sourcePort);
try {
    if (socket_sendto($sender, 'T=21', 4, 0, '127.0.0.1', $port) !== 4) throw new RuntimeException('Нет отправки');
    $message = ['name' => ['family' => AF_INET], 'buffer_size' => 64, 'controllen' => 64];
    if (socket_recvmsg($receiver, $message, 0) === false) throw new RuntimeException('Нет данных');
    echo $message['name']['addr'], "\n";
    echo $message['name']['port'] === $sourcePort ? "Порт отправителя совпал\n" : "Ошибка порта\n";
    echo ($message['flags'] & (MSG_TRUNC | MSG_CTRUNC)) === 0 ? "Данные и control не обрезаны\n" : "Обрезка\n";
} finally { labClose($sender, $receiver); }

127.0.0.1
Порт отправителя совпал
Данные и control не обрезаны

PHP.net оставляет эту страницу почти без описания; структура ниже сверена с tagged source PHP 8.5.11. Вход: buffer_size — ваш ограниченный размер обычных данных, controllen — обязательный положительный размер ancillary-буфера, name — необязательная структура семейства. Выход: name, control, iov и flags; входной массив заменяется. Нулевой результат означает EOF на TCP или допустимую пустую UDP датаграмму. MSG_TRUNC/MSG_CTRUNC требуют отдельной обработки: усечённую команду нельзя исполнять как полную.

control содержит только распознанные PHP структуры. Для SCM_RIGHTS проверьте число и тип полученных ресурсов, права доверенного Unix-peer, закройте лишние дескрипторы; не открывайте процессу произвольные права через общий socket-файл. Windows WSARecvMsg имеет собственные ограничения протокола; рабочие примеры здесь используют UDP. Ошибки преобразования и системного вызова дают warning/false; не полагайтесь на то, что все ошибки записаны именно в socket_last_error($socket): часть путей обновляет глобальную ошибку.

Связанные действия: socket_sendmsg, socket_cmsg_space, socket_recvfrom.

• PHP: socket_recvmsg

PHP 5.5+ · sockets

socket_cmsg_space(int $level, int $type, int $num = 0): ?int

<?php
declare(strict_types=1);

require __DIR__ . '/local-net.php';
if (PHP_OS_FAMILY === 'Windows' || !defined('SCM_RIGHTS')) { throw new RuntimeException('Нужен Unix со SCM_RIGHTS'); }
[$sender, $receiver] = localPair();
$file = fopen(__DIR__ . '/receipt.txt', 'rb');
if ($file === false) { throw new RuntimeException('Квитанция не открыта'); }
$message = ['iov'=>['F'], 'control'=>[['level'=>SOL_SOCKET, 'type'=>SCM_RIGHTS, 'data'=>[$file]]]];
if (socket_sendmsg($sender, $message, 0) !== 1) { throw new RuntimeException('Дескриптор не передан'); }
$received = ['buffer_size'=>1, 'controllen'=>socket_cmsg_space(SOL_SOCKET, SCM_RIGHTS, 1)];
if (socket_recvmsg($receiver, $received, 0) === false) { throw new RuntimeException('Нет сообщения'); }
$copy = $received['control'][0]['data'][0];
echo stream_get_contents($copy);
fclose($copy);
fclose($file);
socket_close($sender);
socket_close($receiver);

Квитанция: Молоток, 2 шт., 900 руб.

Не угадывать размер буфера control для recvmsg.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Результат включает системные заголовки и выравнивание, а не только размер int. Число зависит от архитектуры; печатаем проверенное свойство, а не выдуманную переносимую константу.

<?php
declare(strict_types=1);

$size = socket_cmsg_space(IPPROTO_IPV6, IPV6_HOPLIMIT);
echo is_int($size) && $size > 0 ? "Размер ancillary-буфера рассчитан\n" : "Нет размера\n";

Размер ancillary-буфера рассчитан

Этот вариант. Суммируются CMSG_SPACE отдельных сообщений. Это лишь подготовка массива, не включение соответствующих IPV6_RECV* опций и не получение пакета.

<?php
declare(strict_types=1);

$limit = socket_cmsg_space(IPPROTO_IPV6, IPV6_HOPLIMIT);
$traffic = socket_cmsg_space(IPPROTO_IPV6, IPV6_TCLASS);
if (!is_int($limit) || !is_int($traffic)) throw new RuntimeException('Нет размеров');
$message = ['buffer_size' => 1024, 'controllen' => $limit + $traffic];
echo $message['controllen'] >= $limit ? "Резерв для двух control сообщений готов\n" : "Ошибка\n";

Резерв для двух control сообщений готов

level/type должны обозначать одну из структур, которые понимает PHP: SCM_RIGHTS/credentials либо перечисленные IPv6 ancillary-типы. num задаёт число элементов переменной части, прежде всего число дескрипторов SCM_RIGHTS; для одного fd передайте 1. Не подставляйте сюда число байтов обычного сообщения. В PHP 8.5 неизвестная пара, отрицательное/слишком большое num вызывает ValueError. Историческая сигнатура PHP.net допускает null; текущая реализация возвращает int при успехе и исключение при перечисленных ошибках.

Связанные действия: socket_recvmsg, socket_sendmsg.

• PHP: socket_cmsg_space

PHP 8.3+ · sockets

socket_atmark(Socket $socket): bool

<?php
declare(strict_types=1);

if (!function_exists('socket_atmark')) { throw new RuntimeException('Нужна сборка со sockatmark'); }
require __DIR__ . '/local-net.php';
[$listener, $client, $peer] = localTcp();
writeBytes($client, "product:1\n");
socket_clear_error($peer);
$marked = socket_atmark($peer);
if ($marked === false && socket_last_error($peer) !== 0) { throw new RuntimeException('Не удалось проверить позицию'); }
if ($marked) { throw new RuntimeException('Этот протокол не использует urgent data'); }
serveProduct($peer);
showProduct(readCatalogLine($client));
socket_close($peer);
socket_close($client);
socket_close($listener);

Молоток — 8 шт.

Узнать, стоит ли TCP поток на отметке urgent/OOB данных.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Предусловие: PHP 8.3+ и наличие системного sockatmark, обычно Unix. Эта Windows-сборка проверяет синтаксис примера, а не обещает наличие функции. false при отсутствии метки — нормальный результат, а не всегда failure. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
if (!function_exists('socket_atmark')) throw new RuntimeException('Нужна платформа с sockatmark');
[$listener, $client, $peer] = labTcp();
try {
    socket_clear_error($peer);
    $marked = socket_atmark($peer);
    if ($marked === false && socket_last_error($peer) !== 0) throw new RuntimeException('Ошибка atmark');
    echo $marked ? "Urgent mark\n" : "Обычная позиция потока\n";
} finally { labClose($peer, $client, $listener); }

Обычная позиция потока

Этот вариант. Проверка позиции не читает обычные байты. В протоколе с OOB отдельный байт читают MSG_OOB либо используют SO_OOBINLINE по правилам ОС. Не добавляйте urgent data как универсальную «приоритетную очередь»: TCP и системы различаются. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
if (!function_exists('socket_atmark')) throw new RuntimeException('Нужен sockatmark');
[$listener, $client, $peer] = labTcp();
try {
    labWriteAll($client, 'A42'); socket_clear_error($peer);
    $marked = socket_atmark($peer);
    if ($marked === false && socket_last_error($peer) !== 0) throw new RuntimeException('Ошибка atmark');
    if ($marked) throw new RuntimeException('Наш протокол не использует urgent data');
    echo labReadExact($peer, 3), "\n";
} finally { labClose($peer, $client, $listener); }

A42

Связанные действия: socket_recv, socket_set_option, socket_last_error.

• PHP: socket_atmark

PHP 7.3+, Windows only · sockets

socket_wsaprotocol_info_export(Socket $socket, int $process_id): string|false

<?php
declare(strict_types=1);

if (PHP_OS_FAMILY !== 'Windows') { throw new RuntimeException('Нужна Windows'); }
require __DIR__ . '/local-net.php';
$receiver = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
$sender = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
if (!socket_bind($receiver, '127.0.0.1', 0) || !socket_bind($sender, '127.0.0.1', 0)) { throw new RuntimeException('UDP не привязан'); }
localTimeout($receiver);
localTimeout($sender);
socket_getsockname($receiver, $host, $port);
$id = socket_wsaprotocol_info_export($sender, getmypid());
if ($id === false) { throw new RuntimeException('Описание не создано'); }
$copy = socket_wsaprotocol_info_import($id);
if ($copy === false) { throw new RuntimeException('Описание не импортировано'); }
if (!socket_wsaprotocol_info_release($id)) { throw new RuntimeException('Mapping не освобождён'); }
$payload = "Молоток;8\n";
if (socket_sendto($copy, $payload, strlen($payload), 0, '127.0.0.1', $port) !== strlen($payload)) { throw new RuntimeException('Нет отправки'); }
if (socket_recvfrom($receiver, $data, 1024, 0, $from, $fromPort) === false) { throw new RuntimeException('Нет данных'); }
echo "Получена строка инвентаризации:\n", $data;
socket_close($copy);
socket_close($sender);
socket_close($receiver);

Получена строка инвентаризации:
Молоток;8

Подготовить описание Windows-сокета для конкретного процесса.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Windows-only: target PID взят у текущего процесса, чтобы самостоятельный пример не нуждался во внешнем worker. Это демонстрация механизма, не модель распараллеливания. Между процессами ID передают только предназначенному PID.

<?php
declare(strict_types=1);

if (PHP_OS_FAMILY !== 'Windows') throw new RuntimeException('Нужна Windows');
$original = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($original === false) throw new RuntimeException('Нет сокета');
$id = socket_wsaprotocol_info_export($original, getmypid());
if ($id === false) throw new RuntimeException('Не создано описание');
try { echo is_string($id) && $id !== '' ? "Описание для указанного PID создано\n" : "Ошибка\n"; }
finally { socket_wsaprotocol_info_release($id); socket_close($original); }

Описание для указанного PID создано

Этот вариант. После успешного import mapping можно освободить, но handle продолжает работать. Два handle относятся к одному underlying socket: они разделяют настройки и входящую очередь, а не создают независимые копии данных. Каждый владелец закрывает свой handle. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
if (PHP_OS_FAMILY !== 'Windows') throw new RuntimeException('Нужна Windows');
[$receiver, $sender, $port] = labUdp();
$id = socket_wsaprotocol_info_export($sender, getmypid());
if ($id === false) throw new RuntimeException('Нет описания');
$copy = socket_wsaprotocol_info_import($id);
if ($copy === false) throw new RuntimeException('Нет handle');
try {
    if (!socket_wsaprotocol_info_release($id)) throw new RuntimeException('Не освобождено');
    socket_getsockname($sender, $host1, $port1); socket_getsockname($copy, $host2, $port2);
    echo $port1 === $port2 ? "Один исходящий endpoint\n" : "Разные порты\n";
    if (socket_sendto($copy, 'A42', 3, 0, '127.0.0.1', $port) !== 3) throw new RuntimeException('Нет отправки');
    if (socket_recvfrom($receiver, $data, 32, 0, $from, $fromPort) === false) throw new RuntimeException('Нет данных');
    echo $data, "\n";
} finally { labClose($copy, $sender, $receiver); }

Один исходящий endpoint
A42

В настоящей паре процессов родитель узнаёт PID доверенного ребёнка, экспортирует именно для него, передаёт ID по согласованному IPC и освобождает mapping после подтверждённого import. ID не является безопасным токеном аутентификации: имя mapping в текущей реализации предсказуемо. Не передавайте его посторонним и не принимайте произвольный ID из HTTP. Согласуйте одного читателя/писателя либо явный протокол владения: одновременные чтения конкурируют за одни данные. Close одного handle не заменяет освобождение mapping и не закрывает чужие handle.

Связанные действия: socket_wsaprotocol_info_import, socket_wsaprotocol_info_release, socket_close.

• PHP: socket_wsaprotocol_info_export

PHP 7.3+, Windows only · sockets

socket_wsaprotocol_info_import(string $info_id): Socket|false

<?php
declare(strict_types=1);

if (PHP_OS_FAMILY !== 'Windows') { throw new RuntimeException('Нужна Windows'); }
require __DIR__ . '/local-net.php';
$receiver = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
$sender = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
if (!socket_bind($receiver, '127.0.0.1', 0) || !socket_bind($sender, '127.0.0.1', 0)) { throw new RuntimeException('UDP не привязан'); }
localTimeout($receiver);
localTimeout($sender);
socket_getsockname($receiver, $host, $port);
$id = socket_wsaprotocol_info_export($sender, getmypid());
if ($id === false) { throw new RuntimeException('Описание не создано'); }
$copy = socket_wsaprotocol_info_import($id);
if ($copy === false) { throw new RuntimeException('Описание не импортировано'); }
if (!socket_wsaprotocol_info_release($id)) { throw new RuntimeException('Mapping не освобождён'); }
$payload = "Молоток;8\n";
if (socket_sendto($copy, $payload, strlen($payload), 0, '127.0.0.1', $port) !== strlen($payload)) { throw new RuntimeException('Нет отправки'); }
if (socket_recvfrom($receiver, $data, 1024, 0, $from, $fromPort) === false) { throw new RuntimeException('Нет данных'); }
echo "Получена строка инвентаризации:\n", $data;
socket_close($copy);
socket_close($sender);
socket_close($receiver);

Получена строка инвентаризации:
Молоток;8

Открыть собственный handle ранее экспортированного Windows endpoint.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Windows-only: target PID взят у текущего процесса, чтобы самостоятельный пример не нуждался во внешнем worker. Это демонстрация механизма, не модель распараллеливания. Между процессами ID передают только предназначенному PID.

<?php
declare(strict_types=1);

if (PHP_OS_FAMILY !== 'Windows') throw new RuntimeException('Нужна Windows');
$original = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($original === false) throw new RuntimeException('Нет сокета');
$id = socket_wsaprotocol_info_export($original, getmypid());
if ($id === false) throw new RuntimeException('Не создано описание');
$copy = socket_wsaprotocol_info_import($id);
try {
    if ($copy === false) throw new RuntimeException('Не импортировано');
    echo $copy instanceof Socket ? "Получен второй handle endpoint\n" : "Ошибка\n";
} finally {
    if ($copy !== false) socket_close($copy);
    socket_wsaprotocol_info_release($id); socket_close($original);
}

Получен второй handle endpoint

Этот вариант. После успешного import mapping можно освободить, но handle продолжает работать. Два handle относятся к одному underlying socket: они разделяют настройки и входящую очередь, а не создают независимые копии данных. Каждый владелец закрывает свой handle. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
if (PHP_OS_FAMILY !== 'Windows') throw new RuntimeException('Нужна Windows');
[$receiver, $sender, $port] = labUdp();
$id = socket_wsaprotocol_info_export($sender, getmypid());
if ($id === false) throw new RuntimeException('Нет описания');
$copy = socket_wsaprotocol_info_import($id);
if ($copy === false) throw new RuntimeException('Нет handle');
try {
    if (!socket_wsaprotocol_info_release($id)) throw new RuntimeException('Не освобождено');
    socket_getsockname($sender, $host1, $port1); socket_getsockname($copy, $host2, $port2);
    echo $port1 === $port2 ? "Один исходящий endpoint\n" : "Разные порты\n";
    if (socket_sendto($copy, 'A42', 3, 0, '127.0.0.1', $port) !== 3) throw new RuntimeException('Нет отправки');
    if (socket_recvfrom($receiver, $data, 32, 0, $from, $fromPort) === false) throw new RuntimeException('Нет данных');
    echo $data, "\n";
} finally { labClose($copy, $sender, $receiver); }

Один исходящий endpoint
A42

В настоящей паре процессов родитель узнаёт PID доверенного ребёнка, экспортирует именно для него, передаёт ID по согласованному IPC и освобождает mapping после подтверждённого import. ID не является безопасным токеном аутентификации: имя mapping в текущей реализации предсказуемо. Не передавайте его посторонним и не принимайте произвольный ID из HTTP. Согласуйте одного читателя/писателя либо явный протокол владения: одновременные чтения конкурируют за одни данные. Close одного handle не заменяет освобождение mapping и не закрывает чужие handle.

Связанные действия: socket_wsaprotocol_info_export, socket_wsaprotocol_info_release, socket_close.

• PHP: socket_wsaprotocol_info_import

PHP 7.3+, Windows only · sockets

socket_wsaprotocol_info_release(string $info_id): bool

<?php
declare(strict_types=1);

if (PHP_OS_FAMILY !== 'Windows') { throw new RuntimeException('Нужна Windows'); }
require __DIR__ . '/local-net.php';
$receiver = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
$sender = localSocket(AF_INET, SOCK_DGRAM, SOL_UDP);
if (!socket_bind($receiver, '127.0.0.1', 0) || !socket_bind($sender, '127.0.0.1', 0)) { throw new RuntimeException('UDP не привязан'); }
localTimeout($receiver);
localTimeout($sender);
socket_getsockname($receiver, $host, $port);
$id = socket_wsaprotocol_info_export($sender, getmypid());
if ($id === false) { throw new RuntimeException('Описание не создано'); }
$copy = socket_wsaprotocol_info_import($id);
if ($copy === false) { throw new RuntimeException('Описание не импортировано'); }
if (!socket_wsaprotocol_info_release($id)) { throw new RuntimeException('Mapping не освобождён'); }
$payload = "Молоток;8\n";
if (socket_sendto($copy, $payload, strlen($payload), 0, '127.0.0.1', $port) !== strlen($payload)) { throw new RuntimeException('Нет отправки'); }
if (socket_recvfrom($receiver, $data, 1024, 0, $from, $fromPort) === false) { throw new RuntimeException('Нет данных'); }
echo "Получена строка инвентаризации:\n", $data;
socket_close($copy);
socket_close($sender);
socket_close($receiver);

Получена строка инвентаризации:
Молоток;8

Освободить mapping с описанием Windows-сокета, когда он больше не нужен.

Socket — объект одной конечной точки связи. Его получают функцией socket_create/accept, а затем передают первым аргументом следующей операции. В записи $ok = socket_bind($socket, '127.0.0.1', 0) переменная слева сохраняет результат, скобки содержат аргументы, а === false отличает отказ от нуля байтов или пустой строки. Все длины сетевых данных измеряются в байтах, не в буквах.

Начало: адрес, порт, TCP/UDP и первый локальный обмен. Вызов функции, передача результата через & и обработка исключений помогают прочитать синтаксис. В PHP 8 Socket/AddressInfo — объекты; старые проверки is_resource для них не подходят.

Этот вариант. Windows-only: target PID взят у текущего процесса, чтобы самостоятельный пример не нуждался во внешнем worker. Это демонстрация механизма, не модель распараллеливания. Между процессами ID передают только предназначенному PID.

<?php
declare(strict_types=1);

if (PHP_OS_FAMILY !== 'Windows') throw new RuntimeException('Нужна Windows');
$original = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
if ($original === false) throw new RuntimeException('Нет сокета');
$id = socket_wsaprotocol_info_export($original, getmypid());
if ($id === false) throw new RuntimeException('Не создано описание');
try {
    echo socket_wsaprotocol_info_release($id) ? "Mapping освобождён\n" : "Нет mapping\n";
    echo socket_wsaprotocol_info_release($id) ? "Неожиданное повторение\n" : "Повторно освобождать нечего\n";
} finally { socket_close($original); }

Mapping освобождён
Повторно освобождать нечего

Этот вариант. После успешного import mapping можно освободить, но handle продолжает работать. Два handle относятся к одному underlying socket: они разделяют настройки и входящую очередь, а не создают независимые копии данных. Каждый владелец закрывает свой handle. Приложенный local-sockets.php создаёт только собственные локальные соединения и задаёт двухсекундные таймауты ввода/вывода. Его функции разобраны в разделе «Локальная лаборатория». Файл нужно сохранить рядом с примером; никакой внешний сервер не требуется.

<?php
declare(strict_types=1);

require __DIR__ . '/local-sockets.php';
if (PHP_OS_FAMILY !== 'Windows') throw new RuntimeException('Нужна Windows');
[$receiver, $sender, $port] = labUdp();
$id = socket_wsaprotocol_info_export($sender, getmypid());
if ($id === false) throw new RuntimeException('Нет описания');
$copy = socket_wsaprotocol_info_import($id);
if ($copy === false) throw new RuntimeException('Нет handle');
try {
    if (!socket_wsaprotocol_info_release($id)) throw new RuntimeException('Не освобождено');
    socket_getsockname($sender, $host1, $port1); socket_getsockname($copy, $host2, $port2);
    echo $port1 === $port2 ? "Один исходящий endpoint\n" : "Разные порты\n";
    if (socket_sendto($copy, 'A42', 3, 0, '127.0.0.1', $port) !== 3) throw new RuntimeException('Нет отправки');
    if (socket_recvfrom($receiver, $data, 32, 0, $from, $fromPort) === false) throw new RuntimeException('Нет данных');
    echo $data, "\n";
} finally { labClose($copy, $sender, $receiver); }

Один исходящий endpoint
A42

В настоящей паре процессов родитель узнаёт PID доверенного ребёнка, экспортирует именно для него, передаёт ID по согласованному IPC и освобождает mapping после подтверждённого import. ID не является безопасным токеном аутентификации: имя mapping в текущей реализации предсказуемо. Не передавайте его посторонним и не принимайте произвольный ID из HTTP. Согласуйте одного читателя/писателя либо явный протокол владения: одновременные чтения конкурируют за одни данные. Close одного handle не заменяет освобождение mapping и не закрывает чужие handle.

Связанные действия: socket_wsaprotocol_info_export, socket_wsaprotocol_info_import, socket_close.

• PHP: socket_wsaprotocol_info_release