再次理解异步

传统的PHP采用同步阻塞的形式,譬如一个程序需要获取redismysql里面的数据,那么执行过程时间是redis + mysql

如果采用异步的形式,那么时间将是max(redis, mysql)

协程的作用

应用层可使用完全同步的编程方式,底层自动实现异步IO。

也就是说,你写的时候是同步的形式,但是程序执行的时候是异步的。

协程Redis

基于ServerHttp\ServerWebSocket\Server进行开发,

底层在onRequet, onReceive, onConnect等事件回调之前自动创建一个协程,在回调函数中使用协程API。

这里注意了,是在回调函数里面使用协程API。

简单例子

  1. <?php
  2. // 1.创建HTTP_SERVER对象
  3. $http = new swoole_http_server("0.0.0.0", 8001);
  4. // 2.接收请求事件
  5. $http->on('request',function($request,$response){
  6. /************* 协程代码段 *****************/
  7. // 1)创建redis对象
  8. $redis = new Swoole\Coroutine\Redis();
  9. // 2)连接redis服务
  10. $redis->connect('127.0.0.1',6379);
  11. // 3)获取value
  12. $value = $redis->get($request->get['a']);
  13. // 4)输出到浏览器
  14. $response->end($value);
  15. /************* 协程代码段 *****************/
  16. });
  17. // 3.启动服务器
  18. $http->start();

协程Mysql例子

  1. $swoole_mysql = new Swoole\Coroutine\MySQL();
  2. $swoole_mysql->connect([
  3. 'host' => '127.0.0.1',
  4. 'port' => 3306,
  5. 'user' => 'user',
  6. 'password' => 'pass',
  7. 'database' => 'test',
  8. ]);
  9. $res = $swoole_mysql->query('select sleep(1)');

更多的协程相关功能可以参考官方问题:https://wiki.swoole.com/wiki/page/p-coroutine.html

相信看过我所有关于Swoole扩展文章的朋友,后续阅读swoole官方文档都不会有太大的难度。