0

0

Swoole协程是什么?协程如何使用?

幻夢星雲

幻夢星雲

发布时间:2025-08-14 15:54:02

|

762人浏览过

|

来源于php中文网

原创

Swoole协程通过用户态调度实现轻量级并发,利用go函数创建协程、WaitGroup同步任务,并通过Runtime::enableCoroutine启用全局协程化,使I/O操作自动非阻塞;相比多线程/多进程,协程开销小、调度高效,共享内存但需避免全局变量污染,推荐使用协程上下文传递数据,数据库连接则通过连接池复用,提升资源利用率和系统吞吐量。

swoole协程是什么?协程如何使用?

Swoole协程,简单来说,就是Swoole为PHP带来的一种轻量级并发编程方式。它让我们可以用接近编写同步代码的直观方式,去实现高性能的异步I/O操作。它不是多线程或多进程,而是在单个进程内通过用户态调度,实现任务之间的协作式切换,从而在等待I/O时,CPU可以去处理其他任务,而不是空闲着。这感觉就像在同一个房间里,一个人在等水烧开的时候,可以顺手把菜切了,而不是傻等着。

解决方案

使用Swoole协程的核心,在于利用Swoole提供的

go
函数来创建一个新的协程,以及通过
Swoole\Coroutine\run
Swoole\Runtime::enableCoroutine
来启动或全局启用协程环境。

最直接的用法就是将需要异步执行的代码块包裹在

go
函数中:

add();
    go(function () use ($wg) {
        echo "协程A:开始模拟耗时操作...\n";
        Co::sleep(1.5); // 模拟I/O等待
        echo "协程A:耗时操作完成。\n";
        $wg->done();
    });

    // 模拟第二个耗时操作
    $wg->add();
    go(function () use ($wg) {
        echo "协程B:开始模拟另一个耗时操作...\n";
        Co::sleep(1); // 模拟I/O等待
        echo "协程B:另一个耗时操作完成。\n";
        $wg->done();
    });

    $wg->wait(); // 等待所有协程完成
    echo "所有协程任务都完成了。\n";
});
?>

这段代码里,

run
函数创建了一个协程容器,而两个
go
函数则分别创建了两个独立的协程。当一个协程执行到
Co::sleep()
这样的I/O阻塞操作时,它会自动让出CPU,让Swoole调度器去执行另一个准备就绪的协程,而不是傻等。等I/O操作完成后,Swoole会再把执行权还给它。
WaitGroup
在这里扮演了一个同步工具的角色,确保主协程在所有子协程都完成后才继续执行。

如果你想让大部分I/O操作(比如

file_get_contents
PDO
Redis
等)自动协程化,而无需手动
go
,可以启用运行时协程化:

query('SELECT * FROM users');

    echo "所有I/O操作都在协程中异步完成。\n";
});
?>

这种方式极大地简化了异步编程的复杂度,让原本需要大量回调函数或复杂状态机才能实现的异步逻辑,变得像同步代码一样清晰。

协程为什么能提升应用性能?它和传统多线程/多进程有什么区别

协程提升性能的关键在于它对I/O密集型任务的处理方式。在传统的PHP-FPM模式下,一个请求通常会占用一个进程,当这个进程进行数据库查询、文件读写或网络请求(这些都是I/O操作)时,它会阻塞,直到I/O完成。这意味着,在等待I/O的这段时间里,这个进程是“闲置”的,无法处理其他请求,导致服务器的并发能力受限。

协程则不同,它是一种“协作式多任务”机制。当一个协程遇到I/O操作时,它会主动或被动地让出CPU执行权。Swoole的调度器会立即切换到另一个准备就绪的协程去执行,而不是等待当前协程的I/O完成。这样,在单个进程内,CPU可以持续地执行有意义的计算任务,而不是被I/O阻塞。这就像一个多面手,在等待A任务反馈时,可以立马切换到B任务,大大提高了CPU的利用率和系统的吞吐量。

与传统多线程或多进程的区别在于:

  • 资源消耗:协程非常轻量。创建一个协程的开销远小于创建一个线程或进程。线程有自己的栈和上下文,进程则更重,有独立的内存空间。协程的切换只是用户态的上下文切换,不涉及内核,开销极小。
  • 调度方式
    • 进程/线程:通常由操作系统内核进行抢占式调度,内核决定何时切换,并进行上下文切换。
    • 协程:由Swoole在用户态进行协作式调度。协程主动让出执行权(例如遇到I/O操作时),或者在某些特定条件下被动切换。
  • 数据共享
    • 进程:默认不共享内存,需要IPC(进程间通信)机制。
    • 线程:共享进程内存空间,但需要加锁等同步机制来避免数据竞争。
    • 协程:在同一个进程内,它们共享进程的内存空间,但由于是协作式调度,通常不需要像线程那样频繁地加锁(除非是共享全局变量且有写入操作,但这本身就是协程编程中应尽量避免的)。协程间的数据传递通常通过Channel(通道)更安全。

所以,协程更像是“用户态的线程”,它在保持单进程高效利用CPU的同时,解决了传统异步编程的“回调地狱”问题,让代码更易读、易维护。

在Swoole协程环境中,如何管理全局变量和数据库连接?

在Swoole协程环境下,全局变量和数据库连接的管理确实是需要特别注意的地方,因为它们可能导致意想不到的问题,比如数据污染或连接耗尽。

全局变量管理:

在传统PHP-FPM模式下,每个请求都是独立的进程,全局变量在请求结束后就会被销毁。但在Swoole常驻内存的模式下,多个协程可能在同一个进程内并发执行,并且共享进程的内存空间。这意味着,如果你不小心在协程中修改了全局变量,这个修改可能会影响到其他协程,导致数据混乱。

比如:

易优制冷机械设备网站源码1.6.9
易优制冷机械设备网站源码1.6.9

易优制冷机械设备网站源码是基于易优cms开发,适合企业进行制冷设备展示使用。程序内核为Thinkphp5.0开发,后台简洁,为企业网站而生。 这是一套安装就能建站的程序,不定期更新程序BUG,更新网站功能。 我们提供的不仅是模板这么简单,我们还提供程序相关咨询、协助安装等服务。 默认不包含小程序插件,需要另外单独购买插件。 模板安装步骤 1、请将安装包ZIP上

下载

这种情况下,协程A最后输出的

user_id
很可能不是它自己设置的1,而是被协程B修改后的2。

最佳实践:

  1. 避免使用全局变量:这是最根本的原则。尽量将数据通过函数参数传递,或者使用协程上下文(

    Swoole\Coroutine::getContext()
    )来存储协程私有数据。协程上下文是每个协程独有的,不会相互影响。

  2. 使用协程上下文:对于需要在协程内传递但又不希望污染全局的数据,协程上下文是理想选择。

    这样,即使两个协程并发执行,它们的

    request_id
    也是独立的。

数据库连接管理:

数据库连接是宝贵的资源,创建和销毁连接都有开销。在协程环境下,如果每个请求都去创建新的数据库连接,很快就会耗尽数据库的最大连接数。

最佳实践:

  1. 使用连接池(Connection Pool):这是Swoole协程环境下管理数据库连接的标准做法。连接池预先创建好一定数量的数据库连接,并维护它们。当一个协程需要数据库连接时,它从连接池中“借用”一个连接;使用完毕后,将连接“归还”给连接池,而不是关闭。这样,连接可以被多个协程复用,大大减少了连接创建和销毁的开销,也避免了连接数超限的问题。

    Swoole生态中有许多成熟的连接池库,例如

    swoole/pdo-coroutine
    hyperf/db
    等框架自带的连接池。

    maxConnections = $maxConnections;
            $this->pool = new Channel($maxConnections);
            for ($i = 0; $i < $maxConnections; $i++) {
                // 实际生产中这里是创建真实的PDO或MySQLi连接
                $this->pool->push(new class {
                    public $id;
                    public function __construct() { $this->id = uniqid('conn_'); }
                    public function query(string $sql) { Co::sleep(0.01); return "Result for " . $sql . " using " . $this->id; }
                });
            }
        }
    
        public function get()
        {
            return $this->pool->pop(); // 从池中获取连接
        }
    
        public function put($conn)
        {
            $this->pool->push($conn); // 将连接归还池中
        }
    }
    
    run(function () {
        $dbPool = new DbPool(5); // 创建一个包含5个连接的连接池
    
        for ($i = 0; $i < 10; $i++) {
            go(function () use ($dbPool, $i) {
                $conn = null;
                try {
                    $conn = $dbPool->get(); // 获取连接
                    echo "协程{$i}: 获得连接 " . $conn->id . "\n";
                    $result = $conn->query("SELECT * FROM users WHERE id = {$i}");
                    echo "协程{$i}: 查询结果: " . $result . "\n";
                } finally {
                    if ($conn) {
                        $dbPool->put($conn); // 确保连接被归还
                        echo "协程{$i}: 归还连接 " . $conn->id . "\n";
                    }
                }
            });
        }
        Co::sleep(0.5); // 等待所有协程完成
    });
    ?>

    通过连接池,即使有大量并发协程,实际使用的数据库连接数也始终控制在池的大小范围内,极大地提高了资源利用率和稳定性。

总结来说,在Swoole协程环境中,核心思想是“无状态”和“资源复用”。尽量避免依赖全局状态,并通过连接池等机制来高效地管理外部资源。

相关专题

更多
php文件怎么打开
php文件怎么打开

打开php文件步骤:1、选择文本编辑器;2、在选择的文本编辑器中,创建一个新的文件,并将其保存为.php文件;3、在创建的PHP文件中,编写PHP代码;4、要在本地计算机上运行PHP文件,需要设置一个服务器环境;5、安装服务器环境后,需要将PHP文件放入服务器目录中;6、一旦将PHP文件放入服务器目录中,就可以通过浏览器来运行它。

2531

2023.09.01

php怎么取出数组的前几个元素
php怎么取出数组的前几个元素

取出php数组的前几个元素的方法有使用array_slice()函数、使用array_splice()函数、使用循环遍历、使用array_slice()函数和array_values()函数等。本专题为大家提供php数组相关的文章、下载、课程内容,供大家免费下载体验。

1604

2023.10.11

php反序列化失败怎么办
php反序列化失败怎么办

php反序列化失败的解决办法检查序列化数据。检查类定义、检查错误日志、更新PHP版本和应用安全措施等。本专题为大家提供php反序列化相关的文章、下载、课程内容,供大家免费下载体验。

1497

2023.10.11

php怎么连接mssql数据库
php怎么连接mssql数据库

连接方法:1、通过mssql_系列函数;2、通过sqlsrv_系列函数;3、通过odbc方式连接;4、通过PDO方式;5、通过COM方式连接。想了解php怎么连接mssql数据库的详细内容,可以访问下面的文章。

952

2023.10.23

php连接mssql数据库的方法
php连接mssql数据库的方法

php连接mssql数据库的方法有使用PHP的MSSQL扩展、使用PDO等。想了解更多php连接mssql数据库相关内容,可以阅读本专题下面的文章。

1416

2023.10.23

html怎么上传
html怎么上传

html通过使用HTML表单、JavaScript和PHP上传。更多关于html的问题详细请看本专题下面的文章。php中文网欢迎大家前来学习。

1234

2023.11.03

PHP出现乱码怎么解决
PHP出现乱码怎么解决

PHP出现乱码可以通过修改PHP文件头部的字符编码设置、检查PHP文件的编码格式、检查数据库连接设置和检查HTML页面的字符编码设置来解决。更多关于php乱码的问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

1445

2023.11.09

php文件怎么在手机上打开
php文件怎么在手机上打开

php文件在手机上打开需要在手机上搭建一个能够运行php的服务器环境,并将php文件上传到服务器上。再在手机上的浏览器中输入服务器的IP地址或域名,加上php文件的路径,即可打开php文件并查看其内容。更多关于php相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

1306

2023.11.13

Golang gRPC 服务开发与Protobuf实战
Golang gRPC 服务开发与Protobuf实战

本专题系统讲解 Golang 在 gRPC 服务开发中的完整实践,涵盖 Protobuf 定义与代码生成、gRPC 服务端与客户端实现、流式 RPC(Unary/Server/Client/Bidirectional)、错误处理、拦截器、中间件以及与 HTTP/REST 的对接方案。通过实际案例,帮助学习者掌握 使用 Go 构建高性能、强类型、可扩展的 RPC 服务体系,适用于微服务与内部系统通信场景。

4

2026.01.15

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
最新Python教程 从入门到精通
最新Python教程 从入门到精通

共4课时 | 0.7万人学习

Node.js 教程
Node.js 教程

共57课时 | 8.6万人学习

CSS3 教程
CSS3 教程

共18课时 | 4.5万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号