再次理解异步
传统的PHP采用同步阻塞的形式,譬如一个程序需要获取redis
和mysql
里面的数据,那么执行过程时间是redis + mysql
。
如果采用异步的形式,那么时间将是max(redis, mysql)
。
协程的作用
应用层可使用完全同步的编程方式,底层自动实现异步IO。
也就是说,你写的时候是同步的形式,但是程序执行的时候是异步的。
协程Redis
基于Server
、Http\Server
、WebSocket\Server
进行开发,
底层在onRequet
, onReceive
, onConnect
等事件回调之前自动创建一个协程,在回调函数
中使用协程API。
这里注意了,是在回调函数里面使用协程API。
简单例子
<?php
// 1.创建HTTP_SERVER对象
$http = new swoole_http_server("0.0.0.0", 8001);
// 2.接收请求事件
$http->on('request',function($request,$response){
/************* 协程代码段 *****************/
// 1)创建redis对象
$redis = new Swoole\Coroutine\Redis();
// 2)连接redis服务
$redis->connect('127.0.0.1',6379);
// 3)获取value
$value = $redis->get($request->get['a']);
// 4)输出到浏览器
$response->end($value);
/************* 协程代码段 *****************/
});
// 3.启动服务器
$http->start();
协程Mysql例子
$swoole_mysql = new Swoole\Coroutine\MySQL();
$swoole_mysql->connect([
'host' => '127.0.0.1',
'port' => 3306,
'user' => 'user',
'password' => 'pass',
'database' => 'test',
]);
$res = $swoole_mysql->query('select sleep(1)');
更多的协程相关功能可以参考官方问题:https://wiki.swoole.com/wiki/page/p-coroutine.html
相信看过我所有关于Swoole扩展文章的朋友,后续阅读swoole官方文档都不会有太大的难度。