PHPマルチプロセス挿入データ-PHPチュートリアル-php.cn

PHPマルチプロセス挿入データ

巴扎黑

リリース： 2023-03-07 13:24:01

オリジナル

3331 人が閲覧しました

仮想マシン centos7、シングルコア、1G メモリの場合

/**
 * 模拟并发请求，10万次写入数据库
 * 拆分为10个进程，每个进程处理一万条插入
 */

$total = 10000;
$num   = 10;
$per   = $total/$num;

$sql  = '';
$child = '';

echo 'start '.microtime(true).PHP_EOL;
for($i = 1; $i<= $num; $i++)
{
    $pid = pcntl_fork();
    if($pid == -1) {
        die(&#39;fork error&#39;);
    }
    if($pid > 0) {
        //$id = pcntl_wait($status,WNOHANG);
        $child[] = $pid;
    } else if ($pid == 0) {
        $link  = mysqli_connect('localhost','root','root','yii2advanced');
        $start = ($i-1)*$per + 1;
        $end   = $start + $per;
        for($j = $start; $j< $end; $j++){
            $time = microtime(true);
            $sql = &#39;insert pcntl_test (rank,time) values (&#39;.$j.&#39;,&#39;.$time.&#39;)&#39;;
            mysqli_query($link,$sql);
        }
        mysqli_close($link);
        $id = getmypid();
        echo &#39;child &#39;.$id.&#39; finished &#39;.microtime(true).PHP_EOL;
        exit(0);
    }
}

while(count($child)){
    foreach($child as $k => $pid) {
        $res = pcntl_waitpid($pid, $status, WNOHANG);
        if ( -1 == $res || $res > 0) {
            unset($child[$k]);
        }
    }
}
echo 'end '.microtime(true).PHP_EOL;

ログイン後にコピー

$total=10000, $num = 10 の場合、実行結果は次のようになります:

start 1491903371.5548
child 19860 finished 1491903417.2113
child 19857 finished 1491903417.6909
child 19864 finished 1491903417.7793
child 19855 finished 1491903417.8695
child 19859 finished 1491903417.9162
child 19861 finished 1491903418.0089
child 19856 finished 1491903418.0532
child 19863 finished 1491903418.0842
child 19862 finished 1491903418.1474
child 19858 finished 1491903418.4341
end 1491903418.4424
总时间为46.88759994506836秒

ログイン後にコピー

$total=10000,$num = 100 の場合、実行結果

start 1491904334.1735
child 20085 finished 1491904337.0712
child 20086 finished 1491904337.144
……
child 20262 finished 1491904341.5602
child 20264 finished 1491904341.5803
end 1491904341.5869
总时间为7.413399934768677

ログイン後にコピー

$total=10000, $num = 1000の場合、実行結果は以下の通りです:

start 1491904562.0166
child 20282 finished 1491904562.1191
child 20277 finished 1491904562.1268
child 20279 finished 1491904562.1352
...
child 21586 finished 1491904576.6954
child 21582 finished 1491904576.7024
child 21584 finished 1491904576.7226
end 1491904576.7297
总时间为14.71310019493103，相比100个子进程，耗时更长了。进程切换太多，影响了了效率应该是原因之一。

ログイン後にコピー

$total=100000, $num=100の場合、100,000レコード、100プロセス挿入

start 1491905670.2652
child 21647 finished 1491905725.4382
child 21651 finished 1491905725.4595
child 21642 finished 1491905725.5402
....
child 21810 finished 1491905729.7709
child 21812 finished 1491905729.8498
child 21811 finished 1491905729.9612
end 1491905729.9679
总时间为59.70270013809204

ログイン後にコピー

単一プロセスinserts 10,000 データ 1 件に 18 秒かかります。これは、10 プロセスで 10,000 レコードを挿入するよりも時間がかかりません。
1 つのプロセスで 100,000 レコードを挿入するには 187.40066790581 かかり、比較的時間がかかります。 3分。。。

ただし、100,000 レコードを挿入するために 1,000 プロセスをフォークすると、成功すると約 36 秒かかり、Mysqli_connection が false を返す可能性があります。接続数は制限されていますか?

10,000 個の子プロセスをフォークし、100 万個のデータを挿入すると、多くの接続エラーが発生します。最終的には 360 秒かかり、945,300 件のレコードがデータテーブルに挿入され、成功率は 94.53% でした。したがって、データベースの関連構成情報を確認してください

mysql>  show global status like '%connect%';
+-----------------------------------------------+---------------------+
| Variable_name                                 | Value               |
+-----------------------------------------------+---------------------+
| Aborted_connects                              | 0                   |
| Connection_errors_accept                      | 0                   |
| Connection_errors_internal                    | 0                   |
| Connection_errors_max_connections             | 628                 |
| Connection_errors_peer_address                | 0                   |
| Connection_errors_select                      | 0                   |
| Connection_errors_tcpwrap                     | 0                   |
| Connections                                   | 16519               |
| Locked_connects                               | 0                   |
| Max_used_connections                          | 501                 |
| Max_used_connections_time                     | 2017-04-12 15:19:54 |
| Performance_schema_session_connect_attrs_lost | 0                   |
| Ssl_client_connects                           | 0                   |
| Ssl_connect_renegotiates                      | 0                   |
| Ssl_finished_connects                         | 0                   |
| Threads_connected                             | 4                   |
+-----------------------------------------------+---------------------+


mysql>  show global variables like '%connect%';
+-----------------------------------------------+--------------------+
| Variable_name                                 | Value              |
+-----------------------------------------------+--------------------+
| character_set_connection                      | utf8mb4            |
| collation_connection                          | utf8mb4_general_ci |
| connect_timeout                               | 10                 |
| disconnect_on_expired_password                | ON                 |
| init_connect                                  |                    |
| max_connect_errors                            | 100                |
| max_connections                               | 500                |
| max_user_connections                          | 0                  |
| performance_schema_session_connect_attrs_size | 512                |
+-----------------------------------------------+--------------------+

修改 myqsql 配置文件，/etc/my.cnf
把max_connections 改为10000，然后重启mysql
实际MySQL服务器允许的最大连接数16384；
结果然并卵，虚拟机好像挂了了。

ログイン後にコピー

同時実行性が大きい場合、問題は mysql への接続にあります。
接続プールを通じてこの問題の解決を試みることができます。

仮想マシン centos7、シングルコア、1G メモリの場合

/**
 * 模拟并发请求，10万次写入数据库
 * 拆分为10个进程，每个进程处理一万条插入
 */

$total = 10000;
$num   = 10;
$per   = $total/$num;

$sql  = '';
$child = '';

echo 'start '.microtime(true).PHP_EOL;
for($i = 1; $i<= $num; $i++)
{
    $pid = pcntl_fork();
    if($pid == -1) {
        die(&#39;fork error&#39;);
    }
    if($pid > 0) {
        //$id = pcntl_wait($status,WNOHANG);
        $child[] = $pid;
    } else if ($pid == 0) {
        $link  = mysqli_connect('localhost','root','root','yii2advanced');
        $start = ($i-1)*$per + 1;
        $end   = $start + $per;
        for($j = $start; $j< $end; $j++){
            $time = microtime(true);
            $sql = &#39;insert pcntl_test (rank,time) values (&#39;.$j.&#39;,&#39;.$time.&#39;)&#39;;
            mysqli_query($link,$sql);
        }
        mysqli_close($link);
        $id = getmypid();
        echo &#39;child &#39;.$id.&#39; finished &#39;.microtime(true).PHP_EOL;
        exit(0);
    }
}

while(count($child)){
    foreach($child as $k => $pid) {
        $res = pcntl_waitpid($pid, $status, WNOHANG);
        if ( -1 == $res || $res > 0) {
            unset($child[$k]);
        }
    }
}
echo 'end '.microtime(true).PHP_EOL;

ログイン後にコピー

$total=10000, $num = 10; の場合、実行結果は次のようになります。結果は以下の通り:

start 1491903371.5548
child 19860 finished 1491903417.2113
child 19857 finished 1491903417.6909
child 19864 finished 1491903417.7793
child 19855 finished 1491903417.8695
child 19859 finished 1491903417.9162
child 19861 finished 1491903418.0089
child 19856 finished 1491903418.0532
child 19863 finished 1491903418.0842
child 19862 finished 1491903418.1474
child 19858 finished 1491903418.4341
end 1491903418.4424
总时间为46.88759994506836秒

ログイン後にコピー

$total=10000, $num = 1000の場合、実行結果は以下の通り:

start 1491904334.1735
child 20085 finished 1491904337.0712
child 20086 finished 1491904337.144
……
child 20262 finished 1491904341.5602
child 20264 finished 1491904341.5803
end 1491904341.5869
总时间为7.413399934768677

ログイン後にコピー

$total=100000, $num=100の場合、100,000レコード、100プロセス挿入

start 1491904562.0166
child 20282 finished 1491904562.1191
child 20277 finished 1491904562.1268
child 20279 finished 1491904562.1352
...
child 21586 finished 1491904576.6954
child 21582 finished 1491904576.7024
child 21584 finished 1491904576.7226
end 1491904576.7297
总时间为14.71310019493103，相比100个子进程，耗时更长了。进程切换太多，影响了了效率应该是原因之一。

ログイン後にコピー

Single 1 万件のデータを挿入するプロセスには 18 秒かかります。これは、10 プロセスで 10,000 件のレコードを挿入するよりも時間がかかりません。

1 つのプロセスで 100,000 レコードを挿入するには 187.40066790581 かかり、比較的時間がかかります。 3分。。。

ただし、100,000レコードを挿入するために1,000プロセスをforkすると、成功すると36秒ほどかかり、Mysqli_connectionがfalseを返す可能性があります。接続数が制限されていますか？

10,000 個の子プロセスをフォークし、100 万個のデータを挿入すると、多くの接続エラーが発生します。最終的には 360 秒かかり、945,300 件のレコードがデータテーブルに挿入され、成功率は 94.53% でした。したがって、データベースの関連する構成情報を確認してください

start 1491905670.2652
child 21647 finished 1491905725.4382
child 21651 finished 1491905725.4595
child 21642 finished 1491905725.5402
....
child 21810 finished 1491905729.7709
child 21812 finished 1491905729.8498
child 21811 finished 1491905729.9612
end 1491905729.9679
总时间为59.70270013809204

ログイン後にコピー

同時実行数が大きい場合、問題は mysql への接続にあります。

接続プールを通じてこの問題の解決を試みることができます。

以上がPHPマルチプロセス挿入データの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。