こんにちは。PHPの裏側を覗く旅へようこそ。
Node.jsやGo、あるいはRustあたりの非同期・イベント駆動な世界を体験してきた優秀なエンジニアなら、一度はこう思ったことがあるはずです。「おいおい、PHPでリアルタイムな監視システムやWebSocketサーバーを作るなんて、結局プロセスを大量にフォークするか、無駄に重い外連味のある拡張を入れるしかないんじゃないのか？」と。
もしあなたがそう考えているなら、ここから先の話はとてもエキサイティングなものになりますよ。
PHP 8.1で静かに、しかし劇的に導入された Fiber（ファイバー）。これを正しく理解すれば、私たちは外部の重厚な非同期ランタイムに頼ることなく、PHPのプロセス空間だけで美しく、かつ極めて効率的なイベント駆動型アーキテクチャを構築できるようになります。
今回は、Fiberの本質である「スタックless/stackfulの狭間でどう動くか」というZend Engineの裏側の話から、それを用いた「リアルタイム監視・状態同期システム」の設計に至るまで、じっくりと紐解いていきましょう。
—
1. Fiberの本質：Zend VMとコールバック地獄からの脱却
まず、PHPのFiberが他の言語（例えばGoのGoroutineや、古くはLuaのコルーチン）と何が違うのか、その核心に触れておきます。
PHPのFiberは 「Stackful Fiber」 です。つまり、Fiberの内部でどれだけ深く関数呼び出しをネストさせようとも、その実行コンテキスト（コールスタック、Zend Executorの内部状態、シンボルテーブルの一部）が丸ごとヒープ上に保存されます。
従来の非同期PHP（ReactPHPやAmp v2など）は、非同期I/Oを扱うために「コールバック地獄」や「Promiseのチェイン」を強制されていました。あれは、PHPの関数が途中で実行をサスペンド（中断）する能力を持っていなかったため、コードを細切れのクロージャに分割せざるを得なかったからです。
しかし、Fiberを使えばこう書けます。
// Fiberの中では、あたかも同期処理を書いているかのように手続き型で記述できる
$fiber = new Fiber(function () {
echo “1. 監視タスクを開始します…\n> “;
// 処理を一時停止し、イベントループへ制御を「yield」する
$data = Fiber::suspend(‘FETCH_METRICS’);
echo “2. イベントループからデータが戻りました: {$data}\n”;
});
// Fiberを開始
$value = $fiber->start();
// 出力: 1. 監視タスクを開始します…
// $value には ‘FETCH_METRICS’ が入る
ここがポイントです。Fiberは `Fiber::suspend()` に到達した瞬間、Zend VMの実行コンテキストを即座に親（イベントループ側）へ返却します。OSのスレッドをブロックすることなく、メモリ上の軽量なオブジェクトとして「お昼寝」状態に入るわけです。
—
2. イベント駆動型アーキテクチャの心臓部を作る
リアルタイム監視システムを構築するには、「何かが起きるのを待つ（I/O多重化）」と「タスクを進める（Fiberの再開）」を調停する、いわゆる イベントループ が必要になります。
フルスクラッチで本格的なepollラッパーを書くのは紙幅の都合上省きますが、Stream（ソケットやプロセス間通信）の読み込み可能状態を監視し、対応するFiberをレジューム（再開）させる最小限にして完璧なループ機構を実装してみましょう。
class EventLoop {
private array $waitingStreams = [];
private bool $running = false;
/
- ストリームの読み込みを非同期で待機し、Fiberを中断する
/
public static function awaitRead($stream): mixed {
$fiber = Fiber::getCurrent();
if (!$fiber) {
throw new \RuntimeException(‘Fiberの外側ではawaitできません’);
}
// どのストリームがどのFiberの再開を待っているかを登録
// ここがイベントループとの唯一の接点
return Fiber::suspend(function ($loop) use ($stream, $fiber) {
$loop->waitingStreams[(int)$stream] = [
‘stream’ => $stream,
‘fiber’ => $fiber,
];
});
}
public function run(callable $entryPoint): void {
$fiber = new Fiber($entryPoint);
$fiber->start();
$this->running = true;
while ($this->running && ($fiber->isSuspended() || !empty($this->waitingStreams))) {
// 監視対象のストリームがない場合はループを抜ける
if (empty($this->waitingStreams)) {
break;
}
$read = [];
foreach ($this->waitingStreams as $item) {
$read[] = $item[‘stream’];
}
$write = $except = [];
// stream_selectでI/O多重化（ノンブロッキングなイベント待ち受け）
// 第4引数を [0, 200000] (0.2秒) に設定し、CPUの無駄な高負荷を防ぐ
$selected = @stream_select($read, $write, $except, 0, 200000);
if ($selected === false) {
break; // エラー発生時は安全に離脱
}
if ($selected > 0) {
foreach ($read as $stream) {
$key = (int)$stream;
if (isset($this->waitingStreams[$key])) {
$task = $this->waitingStreams[$key];
unset($this->waitingStreams[$key]);
// ストリームからデータを読み出す（簡易的実装）
$data = fread($stream, 8192);
// 停止していたFiberを再開（resume）し、読み込んだデータを渡す
if ($task[‘fiber’]->isSuspended()) {
$task[‘fiber’]->resume($data);
}
}
}
}
}
}
}
このコードの美しさは、「同期的なコードの見た目を維持しながら、内部では完全にイベント駆動のノンブロッキングI/Oを行っている」 という点にあります。開発者は複雑なステートマシンを頭の中で組み立てる必要がなくなり、上から下へ流れる直感的なコードを書けるようになります。
—
3. 実践：Fiberによるリアルタイムサーバー監視と状態同期
では、先ほどのイベントループを土台にして、「複数サーバーのリソース状況を非同期に監視し、しきい値を超えたら即座にアラート（状態同期）を発信するシステム」を組んでみましょう。
ここでは、実際のプロセスやネットワークソケットに見立てたストリームを使って、並行監視タスクを走らせます。
require_once ‘EventLoop.php’; // 先ほどのクラス
// 疑似的なメトリクス収集を行うワーカー（複数台のサーバーを想定）
function monitorServerNode(string $nodeName, $simulatedStream): void {
echo “[監視開始] {$nodeName} のメトリクスストリームを監視します。\n”;
while (true) {
// I/Oの完了を待つ間、CPUは他のFiber（他のサーバー監視）の処理に明け渡される
$metricsJson = EventLoop::awaitRead($simulatedStream);
if ($metricsJson === false || $metricsJson === ”) {
echo “[警告] {$nodeName} との接続が切断されました。\n”;
break;
}
$metrics = json_decode(trim($metricsJson), true);
if (!$metrics) continue;
// 状態同期とアラート判定のロジック
if ($metrics[‘cpu_usage’] > 85.0) {
// 実際にはここでSlack通知やDBへの状態書き込みを行う
echo “>>> [アラート発信] {$nodeName}: CPU負荷が急上昇しています！ (” . $metrics[‘cpu_usage’] . “%)\n”;
} else {
echo “[正常] {$nodeName} CPU: {$metrics[‘cpu_usage’]}%, MEM: {$metrics[‘memory_usage’]}%\n”;
}
}
}
// — メイン実行エントリ —
$loop = new EventLoop();
// テスト用に、非同期読み込みが可能なパイプ（ストリームペア）を2つ作成する
$sockets1 = stream_socket_pair(STREAM_PF_UNIX, STREAM_SOCK_STREAM, STREAM_IPPROTO_IP);
$sockets2 = stream_socket_pair(STREAM_PF_UNIX, STREAM_SOCK_STREAM, STREAM_IPPROTO_IP);
// メインのループを起動
$loop->run(function () use ($sockets1, $sockets2) {
// Node-Aを監視するFiberを起動
$fiberA = new Fiber(fn() => monitorServerNode(‘Server-A (Tokyo)’, $sockets1[0]));
$fiberA->start();
// Node-Bを監視するFiberを起動
$fiberB = new Fiber(fn() => monitorServerNode(‘Server-B (SiliconValley)’, $sockets2[0]));
$fiberB->start();
// デモ用：バックグラウンドで定期的にメトリクスデータを流し込むタイマー的な処理
// （実際のプロダクションでは、外部からのパケットや非同期プロセスからの通知が入る）
// ここでは分かりやすく、別プロセスやタイマーの代わりにイベントループを回すイメージを伝えます。
});
このアーキテクチャの優れているところは、PHPのボトルネックになりがちな「I/O待ちの時間」を完全にゼロに圧縮できる点です。10台、50台のサーバー監視であっても、プロセスを無闇に増やしてメモリを圧迫する必要はありません。すべてが1つのPHPプロセス、1つのイベントループの中で綺麗に調停されます。
—
4. アーキテクトからの実践的アドバイス：落とし穴と対策
最後に、現場でFiberを使う際に絶対に知っておくべき「PHPならではの罠」をいくつか共有しておきます。ここを知っているかどうかで、シニアとしての格が分かれます。
1. サードパーティ製ライブラリのブロッキング呼び出しに注意する
Fiber内で `file_get_contents()` や通常の `PDO` による同期クエリを実行すると、その瞬間 PHPのプロセス全体がブロック されます。いくらFiberで非同期に書いても、OSのシステムコールレベルでブロックがかかると意味がありません。非同期対応のドライバ（AmpやSwoole/Swowの提供するドライバ、あるいはReactPHPのストリーム等）を適切に組み合わせる必要があります。
2. グローバル状態の共有（競合状態）の排除
Fiberはシングルスレッドで動くため、Goのように「異なるスレッドから同時に変数が書き換わる」ことはありません。しかし、「awaitの前後でグローバルな状態（static変数やシングルトン）が変わっている」 という事態は頻発します。非同期境界（`Fiber::suspend` が呼ばれる箇所）を跨ぐときは、変数のスコープや状態の整合性に細心の注意を払ってください。
—
まとめ
PHPのFiberは、単なる「ちょっと新しい文法機能」ではありません。
それは、長年私たちが諦めかけていた「PHPにおけるエレガントな非同期・イベント駆動プログラミング」の扉を開く、極めて強力なZend Engineのコア機能です。
ここを理解すれば、あなたの書くPHPコードの裏側が、どれほど無駄なブロッキングから解放され、美しく効率的にCPUとメモリを使えているかが手に取るようにわかるはずです。
さあ、次のプロジェクトでは、古い「全部同期型のブルートフォースな設計」を捨てて、Fiberの風を通してみませんか？ PHPの裏側は、あなたが思うよりもずっとモダンで、美しく動いていますよ。