http2-client.php

<?php

declare(strict_types=1);

/**
 * HTTP/2 Client 示例 — 基于 Workerman AsyncTcpConnection
 *
 * 使用方式:
 *   php examples/http2-client.php
 *
 * 通过 http2:// 协议连接，encode() 自动将数组编码为 HTTP/2 帧，
 * 无需手动构造帧。
 */

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

use Protocols\Http2;
use Workerman\Connection\AsyncTcpConnection;
use Workerman\Connection\ConnectionInterface;
use Workerman\Worker;

$worker = new Worker();
$worker->onWorkerStart = function () {
    $conn = new AsyncTcpConnection('http2://127.0.0.1:8080');

    // ---- 连接建立 ----
    $conn->onConnect = function (ConnectionInterface $conn) {
        echo "[client] connected\n";
        Http2::initConnection($conn);

        // 通过 encode() 发送请求，stream_id 自动分配（1, 3, 5, ...）
        $conn->send([
            ':method'   => 'GET',
            ':path'     => '/',
            ':scheme'   => 'http',
            ':authority'=> '127.0.0.1:8080',
        ]);

        $conn->send([
            ':method'   => 'GET',
            ':path'     => '/api',
            ':scheme'   => 'http',
            ':authority'=> '127.0.0.1:8080',
        ]);

        echo "[client] requests sent\n";
    };

    // ---- 接收响应 ----
    $conn->onMessage = function (ConnectionInterface $conn, $data) {
        // $data 可能是 null（连接级帧）或完整请求数组
        if ($data === null) {
            return;
        }

        echo "[client] stream={$data['stream_id']} response received\n";

        // 打印响应头
        foreach ($data['headers'] as [$name, $value]) {
            echo "  {$name}: {$value}\n";
        }
        echo "  body: {$data['body']}\n";
    };

    // ---- 连接关闭 ----
    $conn->onClose = function (ConnectionInterface $conn) {
        echo "[client] disconnected\n";
        Http2::destroyConnection($conn);
    };

    $conn->connect();
};

Worker::runAll();