PHP协程编程入门：Swoole协程 使用PHP实现高并发服务的核心方法

go

<?php
// 确保在Swoole环境下运行，例如在Swoole HTTP Server的请求回调中
go(function () {
    echo "协程1开始执行\n";
    Co::sleep(1); // 模拟一个耗时1秒的非阻塞I/O操作
    echo "协程1执行完毕\n";
});

go(function () {
    echo "协程2开始执行\n";
    Co::sleep(0.5); // 模拟一个耗时0.5秒的非阻塞I/O操作
    echo "协程2执行完毕\n";
});

// 在Swoole Server中，主进程会等待所有协程执行完毕（或达到超时）
// 在独立协程模式下，需要手动启动协程调度器，例如通过 Sgo::run() 或 Co::create()
// 这里为了演示，我们假设它在Swoole Server环境中，协程会被调度执行。
?>

file_get_contents

stream_socket_client

<?php
// 在Swoole Server启动前或onRequest回调的开始处调用
Swoole\Runtime::enableCoroutine();

$http = new Swoole\Http\Server("0.0.0.0", 9501);

$http->on("request", function ($request, $response) {
    go(function () use ($response) {
        echo "收到请求，启动协程处理...\n";
        // 模拟请求外部API，这里使用透明协程化的file_get_contents
        $data1 = file_get_contents("http://httpbin.org/delay/2"); // 会自动协程化，非阻塞
        echo "第一个外部请求完成\n";

        // 模拟数据库查询，如果PDO被协程化，这里也是非阻塞的
        // $pdo = new PDO('mysql:host=127.0.0.1;dbname=test', 'user', 'pass');
        // $stmt = $pdo->prepare('SELECT SLEEP(1)');
        // $stmt->execute();
        // echo "数据库查询完成\n";

        $response->end("Hello Swoole Coroutine! Data1 size: " . strlen($data1) . "\n");
    });
});

$http->start();
?>

go()

go(function() { ... });

<?php
// 这是一个简单的Swoole HTTP服务器示例，展示go()的用法
$http = new Swoole\Http\Server("0.0.0.0", 9501);

$http->on("request", function ($request, $response) {
    // 启动一个协程来处理这个请求
    go(function () use ($response) {
        // 模拟一个耗时的业务逻辑，例如调用外部服务
        echo "协程开始处理请求: " . microtime(true) . "\n";
        Co::sleep(1); // 模拟耗时1秒的非阻塞I/O等待
        echo "协程处理完成: " . microtime(true) . "\n";
        $response->end("Hello from Coroutine!");
    });
});

$http->start();
?>

Co::sleep(1)

sleep

Stream

file_get_contents('http://...')

new PDO(...)

new Redis(...)

<?php
// 务必在所有业务逻辑开始前调用
Swoole\Runtime::enableCoroutine();

$http = new Swoole\Http\Server("0.0.0.0", 9502);

$http->on("request", function ($request, $response) {
    go(function () use ($response) {
        // 这里的file_get_contents在enableCoroutine后，会自动变为协程化的非阻塞版本
        $content1 = file_get_contents("http://httpbin.org/delay/1");
        $content2 = file_get_contents("http://httpbin.org/delay/1.5");

        // 假设你配置了MySQL，这里PDO的查询也会是非阻塞的
        // $pdo = new PDO('mysql:host=127.0.0.1;dbname=test', 'user', 'password');
        // $stmt = $pdo->prepare('SELECT * FROM users LIMIT 1');
        // $stmt->execute();
        // $user = $stmt->fetch();

        $response->end("Requests finished! Content1 len: " . strlen($content1) . ", Content2 len: " . strlen($content2));
    });
});

$http->start();
?>

Swoole\Coroutine\Http\Client

$user_id

Co::getContext()

<?php
// 错误示范：全局变量被污染
$global_user_id = 0;

go(function () {
    global $global_user_id;
    $global_user_id = 1; // 协程1设置
    Co::sleep(0.1);
    echo "协程1读取: " . $global_user_id . "\n"; // 可能被协程2修改
});

go(function () {
    global $global_user_id;
    $global_user_id = 2; // 协程2设置
    Co::sleep(0.1);
    echo "协程2读取: " . $global_user_id . "\n"; // 可能被协程1修改
});
// 运行结果可能会是：
// 协程2读取: 2
// 协程1读取: 2
// 导致数据混乱
?>

Task

enableCoroutine()

new PDO