Сетевые подключения через сокеты в PHP: методы и примеры

Расширенные примеры сокетного программирования в PHP

Неблокирующий сокет с таймаутом

Неблокирующий режим позволяет выполнять другие операции во время ожидания ответа. Пример с сокетом и функцией socket_select():

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_nonblock($socket);

$address = '93.184.216.34';
$port = 80;
$result = @socket_connect($socket, $address, $port);

// socket_connect в неблокирующем режиме сразу вернёт false с ошибкой EINPROGRESS
$write = [$socket];
$except = null;
$timeout_sec = 5;
$timeout_usec = 0;

if (socket_select($null = null, $write, $except, $timeout_sec, $timeout_usec) > 0) {
    // Соединение установлено
    $request = "GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n";
    socket_write($socket, $request);

    $read = [$socket];
    $response = '';
    $time = time() + 5;
    while (time() < $time) {
        $ready = socket_select($read, $null, $null, 2);
        if ($ready > 0 && in_array($socket, $read)) {
            $chunk = socket_read($socket, 4096);
            if ($chunk === false || $chunk === '') break;
            $response .= $chunk;
        }
    }
    echo $response;
} else {
    echo "Таймаут соединения\n";
}
socket_close($socket);

HTTP/1.1 200 OK
Content-Type: text/html
...(полный ответ сервера)

Пояснение: после вызова socket_connect() в неблокирующем режиме ждём завершения соединения через socket_select. Затем отправляем запрос и читаем ответ, контролируя таймаут.

Подключение через SSL/TLS с проверкой сертификата

Для защищённых соединений используется потоковый контекст с SSL-опциями. Пример с stream_socket_client:

$options = [
    'ssl' => [
        'verify_peer'      => true,
        'verify_peer_name' => true,
        'allow_self_signed' => false,
        'cafile'           => '/path/to/cacert.pem'
    ]
];
$context = stream_context_create($options);

$client = stream_socket_client(
    'ssl://example.com:443',
    $errno,
    $errstr,
    10,
    STREAM_CLIENT_CONNECT,
    $context
);

if ($client) {
    fwrite($client, "GET / HTTP/1.1\r\nHost: example.com\r\nConnection: close\r\n\r\n");
    $body = stream_get_contents($client);
    echo $body;
    fclose($client);
} else {
    echo "SSL ошибка: $errstr ($errno)\n";
}

... (содержимое сайта по HTTPS)

Использование сокетов для отправки произвольных данных (например, Syslog)

Протокол Syslog работает через UDP на порту 514. Пример отправки сообщения:

$socket = socket_create(AF_INET, SOCK_DGRAM, SOL_UDP);
$message = "<14>Jan  1 12:34:56 myhost test message";
socket_sendto($socket, $message, strlen($message), 0, 'syslog.example.com', 514);
socket_close($socket);
echo "Сообщение отправлено\n";

Сообщение отправлено

Пояснение: UDP не требует установки соединения - данные отправляются сразу. Функция socket_sendto() используется для отправки датаграммы.

Многопоточная обработка множества сокетов с socket_select

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

$server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_bind($server, '0.0.0.0', 8080);
socket_listen($server);
socket_set_nonblock($server);

$clients = [];
$start = time();

while (time() - $start < 10) { // работаем 10 секунд
    $read = array_merge([$server], $clients);
    $write = null;
    $except = null;
    if (socket_select($read, $write, $except, 1) > 0) {
        if (in_array($server, $read)) {
            $new = socket_accept($server);
            if ($new) {
                socket_set_nonblock($new);
                $clients[] = $new;
                echo "Новое соединение\n";
            }
        }
        foreach ($clients as $i => $client) {
            if (in_array($client, $read)) {
                $data = socket_read($client, 1024);
                if ($data === false || $data === '') {
                    socket_close($client);
                    unset($clients[$i]);
                    echo "Клиент отключился\n";
                } else {
                    echo "Получено: $data\n";
                }
            }
        }
    }
}

foreach ($clients as $client) socket_close($client);
socket_close($server);

Результат: скрипт обрабатывает подключения, не блокируя выполнение. socket_select позволяет отслеживать множество дескрипторов.