我要投稿

PHP Fiber协程实战：构建高性能异步编程架构

资深开发工程师 php

2025-07-31 0 259

PHP Fiber协程实战：构建高性能异步编程架构

一、性能突破

Fiber协程使并发能力提升1000倍，内存占用仅为传统方式的1/20

// 传统同步模式：100并发需要100个进程
// Fiber协程模式：10000并发仅需1个进程

二、核心概念

1. Fiber基础使用

$fiber = new Fiber(function(): void {
    echo "协程开始n";
    Fiber::suspend();
    echo "协程恢复n";
});

echo "启动协程n";
$fiber->start();  // 输出：协程开始
echo "挂起中n";
$fiber->resume(); // 输出：协程恢复

2. 协程通信

$fiber = new Fiber(function($param): void {
    $value = Fiber::suspend($param);
    echo "接收到: $valuen";
});

$initial = $fiber->start('初始值'); // 返回"初始值"
$fiber->resume('新数据'); // 输出：接收到: 新数据

三、高级应用

1. 协程HTTP客户端

class AsyncHttp {
    public static function get(string $url): Fiber {
        return new Fiber(function() use ($url) {
            $ch = curl_init($url);
            curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);
            $response = curl_exec($ch);
            Fiber::suspend($response);
        });
    }
}

$fiber1 = AsyncHttp::get('http://api1.example.com');
$fiber2 = AsyncHttp::get('http://api2.example.com');

$fiber1->start();
$fiber2->start();

$result1 = $fiber1->resume();
$result2 = $fiber2->resume();

2. 协程调度器

class Scheduler {
    private array $fibers = [];

    public function add(Fiber $fiber): void {
        $this->fibers[] = $fiber;
    }

    public function run(): void {
        while (!empty($this->fibers)) {
            foreach ($this->fibers as $i => $fiber) {
                try {
                    if (!$fiber->isStarted()) {
                        $fiber->start();
                    } elseif (!$fiber->isTerminated()) {
                        $fiber->resume();
                    }
                } catch (Throwable $e) {
                    unset($this->fibers[$i]);
                }
            }
        }
    }
}

四、完整案例

高性能HTTP服务器

class HttpServer {
    private $socket;
    private $scheduler;

    public function __construct(string $address) {
        $this->socket = stream_socket_server($address);
        $this->scheduler = new Scheduler();
    }

    public function start(): void {
        while (true) {
            $client = stream_socket_accept($this->socket, 0);
            $this->scheduler->add(new Fiber(function() use ($client) {
                $request = fread($client, 1024);
                $response = "HTTP/1.1 200 OKrnContent-Length: 13rnrnHello, Fiber!";
                fwrite($client, $response);
                fclose($client);
                Fiber::suspend();
            }));
            $this->scheduler->run();
        }
    }
}

$server = new HttpServer('0.0.0.0:8080');
$server->start();

function checkVersion() {
alert(‘请确保使用PHP8.1+版本运行示例代码’);
}