1. <?php
    2. $server=new swoole\http\server("0.0.0.0",9503);
    3. //swoole会开辟一个协程栈,对协程栈进行初始化
    4. $server->on('request',function(){
    5. $time=time();
    6. $swoole_mysql = new Co\MySQL();
    7. $swoole_mysql->connect([
    8. 'host' => '127.0.0.1',
    9. 'port' => 3306,
    10. 'user' => 'root',
    11. 'password' => 'Qq!990979940',
    12. 'database' => 'test',
    13. ]);
    14. //max(mysql(3),mysql(1));
    15. $swoole_mysql->setDefer(); //延迟收包
    16. $swoole_mysql->query('select sleep(3)'); //阻塞
    17. //$swoole_mysql->close();
    18. $swoole_mysql1 = new Co\MySQL();
    19. $swoole_mysql1->connect([
    20. 'host' => '127.0.0.1',
    21. 'port' => 3306,
    22. 'user' => 'root',
    23. 'password' => 'Qq!990979940',
    24. 'database' => 'test',
    25. ]);
    26. $swoole_mysql1->setDefer();
    27. $res = $swoole_mysql1->query('select sleep(4)');
    28. //$swoole_mysql1->close();
    29. var_dump($swoole_mysql1->recv(),$swoole_mysql->recv());
    30. //同步代码
    31. echo time()-$time.PHP_EOL;
    32. });
    33. $server->start();