Архитектура долгоживущих PHP процессов выбор сервера приложений

Расширенные примеры использования серверов приложений PHP

RoadRunner обработка gRPC запросов

Для работы с gRPC требуется определить протокол в файле .proto. Пример proto greeter.proto:

syntax = "proto3";
service Greeter {
  rpc SayHello (HelloRequest) returns (HelloReply);
}
message HelloRequest { string name = 1; }
message HelloReply { string message = 1; }

Генерация кода PHP:

protoc --php_out=. greeter.proto

Регистрация сервиса в RoadRunner через конфигурацию (.rr.yaml):

grpc:
  listen: tcp://127.0.0.1:9001
  workers:
    pool:
      num_workers: 2
  proto:
    - "greeter.proto"

PHP реализация воркера с использованием RoadRunner gRPC:

<?php
use Spiral\RoadRunner\GRPC\Server;
use Spiral\RoadRunner\Worker;
use Greeter\GreeterInterface;
use Greeter\HelloRequest;
use Greeter\HelloReply;

require __DIR__ . '/vendor/autoload.php';

$worker = new Worker();
$server = new Server($worker);

$server->registerService(GreeterInterface::class, new class implements GreeterInterface {
    public function SayHello($ctx, HelloRequest $request): HelloReply {
        $reply = new HelloReply();
        $reply->setMessage('Hello ' . $request->getName());
        return $reply;
    }
});

$server->serve();

Запуск с помощью ./rr serve -c .rr.yaml. Клиентский запрос через gRPCurl:

grpcurl -d '{"name": "World"}' -plaintext 127.0.0.1:9001 Greeter/SayHello
{
  "message": "Hello World"
}

FrankenPHP интеграция с Mercure для real time уведомлений

Mercure встроен в FrankenPHP. Конфигурация Caddyfile:

localhost:8080 {
    php_fastcgi /app/public/worker.php
    route /mercure/* {
        mercure {
            publisher_jwt_key "secret"
            subscriber_jwt_key "secret"
            allow_anonymous
        }
    }
}

PHP код отправки события (publisher.php):

<?php
$hub = 'http://localhost:8080/.well-known/mercure';
$token = 'eyJhbGciOiJIUzI1NiJ9.eyJtZXJjdXJlIjp7InB1Ymxpc2giOlsiKiJdfX0'; // подписано секретом
foreach (['new_post', 'update'] as $topic) {
    $data = json_encode(['message' => 'Hello từ FrankenPHP']);
    $ch = curl_init($hub);
    curl_setopt_array($ch, [
        CURLOPT_POST => true,
        CURLOPT_HTTPHEADER => [
            'Authorization: Bearer ' . $token,
            'Content-Type: application/x-www-form-urlencoded',
        ],
        CURLOPT_POSTFIELDS => http_build_query(['topic' => $topic, 'data' => $data]),
    ]);
    curl_exec($ch);
}

Подписка через JavaScript в браузере:

<script>
const url = new EventSource('http://localhost:8080/.well-known/mercure?topic=new_post');
url.onmessage = event => console.log(event.data);
</script>

Результат – в консоли появится сообщение при запуске publisher.php.

Swoole создание WebSocket сервера с корутинами

Реализация чата с использованием корутин:

<?php
use Swoole\WebSocket\Server;
use Swoole\Http\Request;
use Swoole\WebSocket\Frame;

$server = new Server("0.0.0.0", 9501);

$server->on("open", function (Server $server, Request $request) {
    echo "Connection open: {$request->fd}\n";
});

$server->on("message", function (Server $server, Frame $frame) {
    foreach ($server->connections as $fd) {
        if ($server->isEstablished($fd)) {
            $server->push($fd, $frame->data);
        }
    }
});

$server->on("close", function (Server $server, int $fd) {
    echo "Connection closed: {$fd}\n";
});

$server->start();

Запуск: php server.php. Клиент через wscat:

wscat -c ws://127.0.0.1:9501
Connected (press CTRL+C to quit)
> Hello
< Hello (от сервера обратно всем)

ReactPHP асинхронная работа с базой данных MySQL

Установка пакета:

composer require react/mysql:^0.4

Пример запроса:

<?php
require __DIR__ . '/vendor/autoload.php';

$loop = React\EventLoop\Loop::get();
$factory = new React\MySQL\Factory($loop);
$connection = $factory->createLazyConnection('user:pass@127.0.0.1/testdb');

$connection->query('SELECT * FROM users LIMIT 2')->then(
    function (React\MySQL\QueryResult $result) {
        foreach ($result->resultRows as $row) {
            echo "User: {$row['name']}\n";
        }
    },
    function (Exception $e) {
        echo 'Error: ' . $e->getMessage() . "\n";
    }
);

$loop->run();

Результат выполнения (при наличии таблицы):

User: Alice
User: Bob