PHP 怎么用Swoole Library

wen PHP项目 2026-08-04 2

本文目录导读：

安装
基础使用
常用组件
高级特性
协程化 HTTP 服务
最佳实践
注意事项

Swoole Library 是 Swoole 官方提供的协程化组件库，它为 Swoole 提供了一系列常用的协程化功能封装,以下是详细的使用方法：

安装

# 安装 Swoole 扩展
pecl install swoole
# 安装 Swoole Library
composer require swoole/library

基础使用

协程客户端

<?php
use Swoole\Coroutine\Http\Client;
use function Swoole\Coroutine\run;
run(function () {
    // HTTP 客户端
    $client = new Client('www.example.com', 80);
    $client->set(['timeout' => 1]);
    $client->get('/');
    echo $client->statusCode;
    echo $client->body;
    $client->close();
});

协程化数据库操作

<?php
use Swoole\Coroutine\PostgreSQL;
use function Swoole\Coroutine\run;
run(function () {
    // PostgreSQL 连接
    $pg = new PostgreSQL();
    $conn = $pg->connect("host=localhost dbname=test user=postgres password=secret");
    $result = $pg->query($conn, "SELECT * FROM users");
    $rows = $pg->fetchAll($result);
    var_dump($rows);
});

常用组件

协程 Redis 客户端

<?php
use Swoole\Coroutine\Redis;
use function Swoole\Coroutine\run;
run(function () {
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);
    $redis->set('key', 'value');
    $value = $redis->get('key');
    echo $value;
});

协程 MySQL 客户端

<?php
use Swoole\Coroutine\MySQL;
use function Swoole\Coroutine\run;
run(function () {
    $mysql = new MySQL();
    $mysql->connect([
        'host' => '127.0.0.1',
        'user' => 'root',
        'password' => 'password',
        'database' => 'test',
    ]);
    $result = $mysql->query('SELECT * FROM users');
    var_dump($result);
});

高级特性

协程 Channel

<?php
use Swoole\Coroutine\Channel;
use function Swoole\Coroutine\run;
run(function () {
    $channel = new Channel(10);
    // 生产者
    go(function () use ($channel) {
        for ($i = 0; $i < 10; $i++) {
            $channel->push($i);
            echo "Produced: $i\n";
        }
    });
    // 消费者
    go(function () use ($channel) {
        while (true) {
            $data = $channel->pop();
            if ($data === false) {
                break;
            }
            echo "Consumed: $data\n";
        }
    });
});

协程 WaitGroup

<?php
use Swoole\Coroutine\WaitGroup;
use function Swoole\Coroutine\run;
run(function () {
    $wg = new WaitGroup();
    for ($i = 0; $i < 3; $i++) {
        $wg->add();
        go(function () use ($wg, $i) {
            // 模拟耗时操作
            co::sleep(1);
            echo "Task $i done\n";
            $wg->done();
        });
    }
    $wg->wait();
    echo "All tasks completed\n";
});

协程化 HTTP 服务

<?php
use Swoole\Http\Server;
use Swoole\Http\Request;
use Swoole\Http\Response;
$server = new Server("0.0.0.0", 9501);
$server->on("request", function (Request $request, Response $response) {
    // 使用协程处理请求
    go(function () use ($response) {
        // 模拟异步操作
        co::sleep(0.1);
        $response->header("Content-Type", "text/plain");
        $response->end("Hello Swoole Library\n");
    });
});
$server->start();

最佳实践

组合使用

<?php
use Swoole\Coroutine\Http\Client;
use Swoole\Coroutine\Redis;
use function Swoole\Coroutine\run;
run(function () {
    // 同时发起多个请求
    $results = [];
    go(function () use (&$results) {
        // HTTP 请求
        $http = new Client('api.example.com', 80);
        $http->get('/data');
        $results['http'] = $http->body;
        $http->close();
    });
    go(function () use (&$results) {
        // Redis 操作
        $redis = new Redis();
        $redis->connect('127.0.0.1', 6379);
        $results['redis'] = $redis->get('cache_key');
    });
    // 等待所有协程完成
    co::sleep(1);
    var_dump($results);
});

注意事项

版本兼容性：确保 Swoole 扩展版本 >= 4.4.0
内存管理：协程会占用内存，注意控制并发数
错误处理：使用 try-catch 处理异常
性能优化：合理使用连接池，避免重复创建连接

Swoole Library 提供了丰富的协程化组件，可以大幅提升 PHP 应用的并发处理能力,特别适合构建高性能的网络应用和微服务。