Swoole-2.0 提供了PHP原生协程调度器,PHP代码可以按照同步方式编写,底层引擎使用异步IO,调度器会在IO完成后自动切换PHP函数调用栈。 内置协程不依赖PHP的Yield/Generator语法,实现了真正的同步代码,异步IO。Swoole-2.0兼容Swoole-1.0所有现存特性,同时支持同步阻塞、异步非阻塞回调、协程 3 种 IO 模型。 协程可以理解为用户态线程,通过协作而不是抢占来进行切换。相对于操作系统进程或者线程,协程所有的操作都可以在用户态完成,创建和切换的消耗更低。Swoole可以为每一个请求创建对应的协程,根据IO的状态来合理地调度协程。 Swoole-2.0内置协程的优势: 开发者可以使用最传统的PHP同步编码方式即可实现异步IO。过去使用Node.js和Swoole1.0编写异步程序时必须使用嵌套回调,开发效率低,逻辑复杂之后开发维护都很困难。现在使用Swoole-2.0内置协程可以轻松编写异步程序,彻底告别Callback Hell。 由于Swoole-2.0是在底层封装了协程,所以对比其他的PHP协程框架,如TSF、Zan,开发者不需要额外使用yield关键词来标识一个协程IO切换操作,所以不再需要对yield的语义进行深入理解以及对每一级的调用都修改为yield,这极大的提高了开发效率。 Swoole-2.0除了支持常见的如TCP、UDP、HTTP、Redis、MySQL协程客户端之外,还支持并发Client,可以同时并发执行多个不同类型的协程客户端调用,时间为Max(耗时最长Client的时间)。而Go语言需要使用非常复杂的goroutine+chan+select才能实现。Swoole-2.0的并发调用使用更加简单。
主要特性:底层内置协程,同步的代码,异步的IO TCP/UDP/UnixSocket协程客户端Swoole\Coroutine\Client Http/WebSocket协程客户端Swoole\Coroutine\HttpClient Redis协程客户端Swoole\Coroutine\Redis MySQL协程客户端Swoole\Coroutine\MySQL 并发Client 支持异步超时 默认开启命名空间
要求:安装方式:Swoole-2.0需要通过添加--enable-coroutine编译参数启用协程能力,示例如下: 1 2 3 4 | phpize
. /configure --with-php-config={path-to-php-config} -- enable -coroutine
make
make install
|
添加编译参数,swoole server将切换到协程模式
使用示例:TCP协程客户端1 2 3 4 5 6 7 | $client = new Swoole\Coroutine\Client(SWOOLE_SOCK_TCP);
$client ->connect( '127.0.0.1' , 9501,0.5)
$client ->send( "hello world\n" );
echo $client ->recv();
$client ->close();
|
Http协程客户端
1 2 3 4 5 6 7 8 9 10 11 | $cli = new Swoole\Coroutine\Http\Client( '127.0.0.1' , 80);
$cli ->setHeaders([
'Host' => "localhost" ,
"User-Agent" => 'Chrome/49.0.2587.3' ,
'Accept' => 'text/html,application/xhtml+xml,application/xml' ,
'Accept-Encoding' => 'gzip' ,
]);
$cli ->set([ 'timeout' => 1]);
$cli ->get( '/index.php' );
echo $cli ->body;
$cli ->close();
|
Redis协程客户端 1 2 3 | $redis = new Swoole\Coroutine\Redis();
$redis ->connect( '127.0.0.1' , 6379);
$val = $redis ->get( 'key' );
|
MySQL协程客户端 1 2 3 4 5 6 7 | $swoole_mysql = new Swoole\Coroutine\MySQL();
$swoole_mysql ->connect([ 'host' => '127.0.0.1' ,
'user' => 'user' ,
'password' => 'pass' ,
'database' => 'test' ,
]);
$res = $swoole_mysql ->query( 'select sleep(1)' );
|
并发调用 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 | $tcpclient = new Swoole\Coroutine\Client(SWOOLE_SOCK_TCP);
$tcpclient ->connect( '127.0.0.1' , 9501,0.5)
$tcpclient ->send( "hello world\n" );
$redis = new Swoole\Coroutine\Redis();
$redis ->connect( '127.0.0.1' , 6379);
$redis ->setDefer();
$redis ->get( 'key' );
$mysql = new Swoole\Coroutine\MySQL();
$mysql ->connect([ 'host' => '127.0.0.1' ,
'user' => 'user' ,
'password' => 'pass' ,
'database' => 'test' ,
]);
$mysql ->setDefer();
$mysql ->query( 'select sleep(1)' );
$httpclient = new Swoole\Coroutine\Http\Client( '0.0.0.0' , 9599);
$httpclient ->setHeaders([ 'Host' => "api.mp.qq.com" ]);
$httpclient ->set([ 'timeout' => 1]);
$httpclient ->setDefer();
$httpclient ->get( '/' );
$tcp_res = $tcpclient ->recv();
$redis_res = $redis ->recv();
$mysql_res = $mysql ->recv();
$http_res = $httpclient ->recv();
|
通常,如果一个业务请求中需要做一次redis请求和一次mysql请求,那么网络IO会是这样: redis发包->redis收包->mysql发包->mysql收包 以上流程网络IO的时间就等于 redis网络IO时间 + mysql网络IO时间。 而对于协程版本的Client,网络IO可以是这样: redis发包->mysql发包->redis收包->mysql收包 以上流程网络IO的时间就接近于 MAX(redis网络IO时间, mysql网络IO时间)。 现在支持并发请求的Client有: 除了Swoole\Coroutine\Client,其他Client都实现了defer特性,用于声明延迟收包。 注意事项全局变量:协程使得原有的异步逻辑同步化,但是在协程的切换是隐式发生的,所以在协程切换的前后不能保证全局变量以及static变量的一致性。 请勿在下列场景中调用协程客户端: 析构函数__destruct() 魔术方法__call()
当前版本为Alpha预览版本,不建议在生产环境上使用
使用新版本 |