Heim Backend-Entwicklung PHP-Tutorial PHP-Mehrprozess-Einfügungsdaten

PHP-Mehrprozess-Einfügungsdaten

May 26, 2018 am 09:45 AM

In der virtuellen Maschine Centos7, Single Core, 1G Speicher

/**
 * 模拟并发请求,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;
Nach dem Login kopieren
Nach dem Login kopieren

Wenn $total=10000, $num = 10; sind die Ausführungsergebnisse wie folgt:

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秒
Nach dem Login kopieren
Nach dem Login kopieren

Wenn $total =10000, $num = 100, lautet das Ausführungsergebnis wie folgt:

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
Nach dem Login kopieren
Nach dem Login kopieren

Wenn $total=10000, $num = 1000, lautet das Ausführungsergebnis wie folgt:

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个子进程,耗时更长了。进程切换太多,影响了了效率应该是原因之一。
Nach dem Login kopieren
Nach dem Login kopieren

Wenn $total =100000, $num=100, 100.000 Datensätze, 100 Prozesse einfügen

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
Nach dem Login kopieren
Nach dem Login kopieren

Ein einzelner Prozess fügt 10.000 Daten ein, es dauert 18 Sekunden, verglichen mit 10 Prozessen, die 10.000 einfügen Aufzeichnungen, weniger zeitaufwändig.
Das Einfügen von 100.000 Datensätzen in einem einzigen Vorgang erfordert 187,40066790581, was relativ langsam ist. Drei Minuten. . .

Wenn ich jedoch 1.000 Prozesse forke, um 100.000 Datensätze einzufügen, kann bei Erfolg innerhalb von 36 Sekunden ein Fehler auftreten. Ist die Anzahl der Verbindungen begrenzt?

Forken Sie 10.000 untergeordnete Prozesse und fügen Sie 1 Million Daten ein. Zu diesem Zeitpunkt treten viele Verbindungsfehler auf. Am Ende dauerte es 360 Sekunden und es wurden 945.300 Datensätze in die Datentabelle eingefügt, mit einer Erfolgsquote von 94,53 %. Überprüfen Sie daher die relevanten Konfigurationsinformationen der Datenbank

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;
结果然并卵,虚拟机好像挂了了。
Nach dem Login kopieren
Nach dem Login kopieren

Wenn die Parallelität groß ist, liegt das Problem in der Verbindung zu MySQL.
Sie können versuchen, dieses Problem über einen Verbindungspool zu lösen.

In der virtuellen Maschine Centos7, Single Core, 1G Speicher

/**
 * 模拟并发请求,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;
Nach dem Login kopieren
Nach dem Login kopieren

Wenn $total=10000, $num = 10; ist das Ausführungsergebnis wie folgt:

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秒
Nach dem Login kopieren
Nach dem Login kopieren

Wenn $total=10000, $num = 100, ist das Ausführungsergebnis wie folgt:

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
Nach dem Login kopieren
Nach dem Login kopieren

Wenn $total=10000, $num = 1000, ist das Ausführungsergebnis wie folgt:

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个子进程,耗时更长了。进程切换太多,影响了了效率应该是原因之一。
Nach dem Login kopieren
Nach dem Login kopieren

Wenn $total=100000, $num=100, 100.000 Datensätze, 100 Prozesse einfügen

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
Nach dem Login kopieren
Nach dem Login kopieren

Ein einzelner Prozess fügt 10.000 Daten ein, es dauert 18 Sekunden, verglichen mit 10 Prozesse, die 10.000 einfügen. In Bezug auf die Aufnahme dauert es weniger Zeit.
Das Einfügen von 100.000 Datensätzen in einem einzigen Vorgang erfordert 187,40066790581, was relativ langsam ist. Drei Minuten. . .

Wenn ich jedoch 1.000 Prozesse forke, um 100.000 Datensätze einzufügen, kann bei Erfolg innerhalb von 36 Sekunden ein Fehler auftreten. Ist die Anzahl der Verbindungen begrenzt?

Forken Sie 10.000 untergeordnete Prozesse und fügen Sie 1 Million Daten ein. Zu diesem Zeitpunkt treten viele Verbindungsfehler auf. Am Ende dauerte es 360 Sekunden und es wurden 945.300 Datensätze in die Datentabelle eingefügt, mit einer Erfolgsquote von 94,53 %. Überprüfen Sie daher die relevanten Konfigurationsinformationen der Datenbank

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;
结果然并卵,虚拟机好像挂了了。
Nach dem Login kopieren
Nach dem Login kopieren

Wenn die Parallelität groß ist, liegt das Problem in der Verbindung zu MySQL.
Sie können versuchen, dieses Problem über einen Verbindungspool zu lösen.

Das obige ist der detaillierte Inhalt vonPHP-Mehrprozess-Einfügungsdaten. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!

Erklärung dieser Website
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn

Heiße KI -Werkzeuge

Undresser.AI Undress

Undresser.AI Undress

KI-gestützte App zum Erstellen realistischer Aktfotos

AI Clothes Remover

AI Clothes Remover

Online-KI-Tool zum Entfernen von Kleidung aus Fotos.

Undress AI Tool

Undress AI Tool

Ausziehbilder kostenlos

Clothoff.io

Clothoff.io

KI-Kleiderentferner

Video Face Swap

Video Face Swap

Tauschen Sie Gesichter in jedem Video mühelos mit unserem völlig kostenlosen KI-Gesichtstausch-Tool aus!

Heißer Artikel

<🎜>: Bubble Gum Simulator Infinity - So erhalten und verwenden Sie Royal Keys
1 Monate vor By 尊渡假赌尊渡假赌尊渡假赌
Nordhold: Fusionssystem, erklärt
1 Monate vor By 尊渡假赌尊渡假赌尊渡假赌
Mandragora: Flüstern des Hexenbaum
4 Wochen vor By 尊渡假赌尊渡假赌尊渡假赌

Heiße Werkzeuge

Notepad++7.3.1

Notepad++7.3.1

Einfach zu bedienender und kostenloser Code-Editor

SublimeText3 chinesische Version

SublimeText3 chinesische Version

Chinesische Version, sehr einfach zu bedienen

Senden Sie Studio 13.0.1

Senden Sie Studio 13.0.1

Leistungsstarke integrierte PHP-Entwicklungsumgebung

Dreamweaver CS6

Dreamweaver CS6

Visuelle Webentwicklungstools

SublimeText3 Mac-Version

SublimeText3 Mac-Version

Codebearbeitungssoftware auf Gottesniveau (SublimeText3)

Heiße Themen

Java-Tutorial
1677
14
PHP-Tutorial
1280
29
C#-Tutorial
1257
24
Was passiert, wenn Session_Start () mehrmals aufgerufen wird? Was passiert, wenn Session_Start () mehrmals aufgerufen wird? Apr 25, 2025 am 12:06 AM

Mehrere Anrufe bei Session_Start () führen zu Warnmeldungen und möglichen Datenüberschreibungen. 1) PHP wird eine Warnung ausstellen und veranlassen, dass die Sitzung gestartet wurde. 2) Dies kann zu unerwarteten Überschreibungen von Sitzungsdaten führen. 3) Verwenden Sie Session_Status (), um den Sitzungsstatus zu überprüfen, um wiederholte Anrufe zu vermeiden.

Welche Bedeutung hat die Funktion Session_start ()? Welche Bedeutung hat die Funktion Session_start ()? May 03, 2025 am 12:18 AM

Session_Start () iscrucialinphPFormAnagingUSSERSIONS.1) ItinitiatesanewSessionifnoneExists, 2) Wiederaufnahmen und 3) setaSessionCookieforContinuityAcrossRequests, aktivierende Anwendungen wie

Komponist: Unterstützung bei der PHP -Entwicklung durch KI Komponist: Unterstützung bei der PHP -Entwicklung durch KI Apr 29, 2025 am 12:27 AM

KI kann dazu beitragen, die Verwendung von Komponisten zu optimieren. Zu den spezifischen Methoden gehören: 1. Abhängigkeitsmanagementoptimierung: AI analysiert Abhängigkeiten, empfiehlt die beste Versionskombination und reduziert Konflikte. 2. Automatisierte Codegenerierung: AI generiert Composer.json -Dateien, die den Best Practices entsprechen. 3.. Verbesserung der Codequalität: KI erkennt potenzielle Probleme, liefert Optimierungsvorschläge und verbessert die Codequalität. Diese Methoden werden durch maschinelles Lernen und Technologien für die Verarbeitung von natürlichen Sprachen implementiert, um Entwicklern zu helfen, die Effizienz und die Codequalität zu verbessern.

So verwenden Sie MySQL -Funktionen für die Datenverarbeitung und Berechnung So verwenden Sie MySQL -Funktionen für die Datenverarbeitung und Berechnung Apr 29, 2025 pm 04:21 PM

MySQL -Funktionen können zur Datenverarbeitung und -berechnung verwendet werden. 1. Grundlegende Nutzung umfasst String -Verarbeitung, Datumsberechnung und mathematische Operationen. 2. Erweiterte Verwendung umfasst die Kombination mehrerer Funktionen zur Implementierung komplexer Vorgänge. 3. Die Leistungsoptimierung erfordert die Vermeidung der Verwendung von Funktionen in der WHERE -Klausel und der Verwendung von Gruppenby- und temporären Tabellen.

H5: Schlüsselverbesserungen bei HTML5 H5: Schlüsselverbesserungen bei HTML5 Apr 28, 2025 am 12:26 AM

HTML5 bringt fünf wichtige Verbesserungen mit sich: 1. Semantische Tags verbessern die Code -Klarheit und SEO -Effekte; 2. Multimedia Support vereinfacht Video- und Audio -Einbettung; 3. Form -Verbesserung vereinfacht die Überprüfung; 4. Offline und lokaler Speicher verbessert die Benutzererfahrung. 5. Leinwand- und Grafikfunktionen verbessern die Visualisierung von Webseiten.

Komponist: Der Paketmanager für PHP -Entwickler Komponist: Der Paketmanager für PHP -Entwickler May 02, 2025 am 12:23 AM

Composer ist ein Abhängigkeitsmanagement -Tool für PHP und verwaltet Projektabhängigkeiten über Composer.json -Datei. 1) Composer.json analysieren, um Abhängigkeitsinformationen zu erhalten; 2) Abhängigkeiten analysieren, um einen Abhängigkeitsbaum zu bilden; 3) Download und installieren Sie Abhängigkeiten vom Packagisten in das Lieferantenverzeichnis. 4) Datei Composer.lock erzeugen, um die Abhängigkeitsversion zu sperren, um die Konsistenz und die Wartbarkeit von Projekten zu gewährleisten.

Wie benutze ich Typmerkmale in C? Wie benutze ich Typmerkmale in C? Apr 28, 2025 pm 08:18 PM

Typetraiten werden in C für die Überprüfung und den Betrieb von Kompilierzeittypen verwendet, wodurch die Code-Flexibilität und die Typensicherheit verbessert werden. 1) Das Urteil wird über std :: is_integral und std :: is_floating_point durchgeführt, um eine effiziente Überprüfung und Ausgabe zu erreichen. 2) Verwenden Sie STD :: is_trivial_copyable, um die Vektorkopie zu optimieren, und wählen Sie verschiedene Kopierstrategien entsprechend dem Typ aus. 3) Achten Sie auf die Entscheidungsfindung der Kompilierzeit, die Typensicherheit, die Leistungsoptimierung und die Komplexität der Code. Die angemessene Verwendung von Typetraiten kann die Codequalität erheblich verbessern.

So konfigurieren Sie die Zeichensatz- und Kollationsregeln von MySQL So konfigurieren Sie die Zeichensatz- und Kollationsregeln von MySQL Apr 29, 2025 pm 04:06 PM

Methoden zum Konfigurieren von Zeichensätzen und Kollationen in MySQL gehören: 1. Einstellen der Zeichensätze und Kollationen auf Serverebene: setNames'utf8 '; SetCharactersetutf8; SetCollation_connection = 'utf8_general_ci'; 2. Erstellen Sie eine Datenbank, die bestimmte Zeichensätze und Kollationen verwendet: CreateDatabaseExample_Dbaractersetutf8collatutf8_General_ci; 3.. Geben Sie Zeichensätze und Kollationen an, wenn Sie eine Tabelle erstellen: createTableExample_table (IDINT

See all articles