发表新帖

swoole mysql 协程，请求数据得1-2s 和不用协程差不多，有啥问题吗，帮忙看看

### 问题描述
swoole mysql 协程写了个例子，请求数据时间得1-2s和不用协程的差不多，是写的有啥问题吗，帮忙看看

### Swoole版本，PHP版本，以及操作系统版本信息
php7.3
swoole4.7
centos7.8

### 相关代码
```php
<?php

use Swoole\Runtime;
use Swoole\Coroutine;
use function Swoole\Coroutine\run;

class MySQL
{

public function common()
    {
        $s = microtime(true);
        
        for ($c = 50; $c--;) {
            $pdo = new PDO('mysql:host=192.168.9.71;dbname=test;charset=utf8mb4', 'root', '123456');
            $statement = $pdo->prepare('SELECT * FROM `test` WHERE id=1');
            for ($n = 100; $n--;) {
                $statement->execute();
                $res = $statement->fetch();
                var_dump('a:' . $res['test']);
            }
        }
        for ($c = 50; $c--;) {
            $link = mysqli_connect('192.168.9.71', 'root', '123456', 'test');
            for ($n = 100; $n--;) {
                $temp = mysqli_query($link, "SELECT * FROM `test` WHERE id=1");
                $res = mysqli_fetch_array($temp);
                var_dump('b:' . $res['test']);
            }
        }

echo 'use ' . (microtime(true) - $s) . ' s';
    }

public function go()
    {
        Runtime::enableCoroutine();
        $s = microtime(true);

run(function () {

for ($c = 50; $c--;) {
                Coroutine::create(function () {
                    $pdo = new PDO('mysql:host=192.168.9.71;dbname=test;charset=utf8mb4', 'root', '123456');
                    $statement = $pdo->prepare('SELECT * FROM `test` WHERE id=1');
                    for ($n = 100; $n--;) {
                        $statement->execute();
                        $res = $statement->fetch();
                        var_dump('a:' . $res['test']);
                    }
                });
            }
            for ($c = 50; $c--;) {
                Coroutine::create(function () {
                    $link = mysqli_connect('192.168.9.71', 'root', '123456', 'test');
                    for ($n = 100; $n--;) {
                        $temp = mysqli_query($link, "SELECT * FROM `test` WHERE id=1");
                        $res = mysqli_fetch_array($temp);
                        var_dump('b:' . $res['test']);
                    }
                });
            }
        });
        echo 'use ' . (microtime(true) - $s) . ' s';
    }

}

$mysql = new MySQL();
$mysql->common();

```

### 你期待的结果是什么？实际看到的错误信息又是什么？
下面是 go() 执行结果
...
string(2) "a:"
string(2) "a:"
string(2) "b:"
string(2) "b:"
string(2) "b:"
use 1.723815202713 s

下面是 common() 执行结果
...
string(2) "b:"
string(2) "b:"
string(2) "b:"
string(2) "b:"
string(2) "b:"
use 2.5237798690796 s

区别是上面的应该用了异步，但是没有那么快。

发布于3年前 · 41 次浏览 · 来自提问

phpbin

### 问题描述
swoole mysql 协程写了个例子，请求数据时间得1-2s和不用协程的差不多，是写的有啥问题吗，帮忙看看

### Swoole版本，PHP版本，以及操作系统版本信息
php7.3
swoole4.7
centos7.8

### 相关代码
```php
<?php

use Swoole\Runtime;
use Swoole\Coroutine;
use function Swoole\Coroutine\run;

class MySQL
{

echo 'use ' . (microtime(true) - $s) . ' s';
    }

public function go()
    {
        Runtime::enableCoroutine();
        $s = microtime(true);

run(function () {

}

$mysql = new MySQL();
$mysql->common();

```

下面是 common() 执行结果
...
string(2) "b:"
string(2) "b:"
string(2) "b:"
string(2) "b:"
string(2) "b:"
use 2.5237798690796 s

区别是上面的应该用了异步，但是没有那么快。

2021-09-06

鲁飞

2021-09-07

phpbin 回复鲁飞

2021-09-07

phpbin 回复鲁飞

执行下面的官方的代码，是4s多
[root@localhost test]# php C.php 
use 4.2655529975891 s

```php
<?php

use Swoole\Runtime;
use Swoole\Coroutine;
use function Swoole\Coroutine\run;

// 此行代码后，文件操作，sleep，Mysqli，PDO，streams等都变成异步IO，见'一键协程化'章节
Runtime::enableCoroutine(); # 表示开始协程
$s = microtime(true);

// Swoole\Coroutine\run()见'协程容器'章节
run(function() {
    // i just want to sleep...
    for ($c = 100; $c--;) {
        Coroutine::create(function () {  # 这里和使用 go() 函数是一样的效果
            for ($n = 100; $n--;) {
                usleep(1000);
            }
        });
    }

// 10k file read and write
    for ($c = 100; $c--;) {
        Coroutine::create(function () use ($c) {
            $tmp_filename = "/tmp/test-{$c}.php";
            for ($n = 100; $n--;) {
                $self = file_get_contents(__FILE__);
                file_put_contents($tmp_filename, $self);
                assert(file_get_contents($tmp_filename) === $self);
            }
            unlink($tmp_filename);
        });
    }
});
echo 'use ' . (microtime(true) - $s) . ' s';

```

2021-09-07

phpbin 回复鲁飞

2021-09-07

phpbin

微信公众号

热门内容

暂无回复的问答

- CodeGalaxy K3s 轻量集群节点之间如何实现负载均衡

- 关于openssl CURL WARNING swSSL_connect: SSL_connect(fd=69) failed. Error: error:141A318A:SSL routines:tls_process_ske_dhe:dh key too small[1|394]

- 多个模型如何进行事务异常回退？

- websocket开启wss报错

- 协程tcp服务器如何使用多进程？recv()方法接收信息，打印出来的pid一直是同一个。没用使用到多进程啊。