mysql 多进程 分批_php 多进程分批插入 50 万条数据 对比 单进程一次插入 50 万条数据性能问题？？...

多进程插入 50 条数据代码

$num = 50 * 10000; // 插入的数量

$tb_name = 'test_tb';

$sex_range = array("男" , "女" , "两性" , "未知" , "male" , "female" , "both" , "unknow");

$sex_range_count = count($sex_range);

$unit_num = 10000; // 单次插入数量

$p_list = array();

// 创建的进程数

$p_num = ceil($num / $unit_num);

$is_main_process = true;

// 用于统计总耗时的插入日志文件

$file = '/home/cxl/桌面/insert.log';

// 清空插入日志(以便重新计算插入耗费时间)

$fs = fopen($file , 'w');

fwrite($fs , '');

fclose($fs);

for ($n = 1; $n <= $p_num; ++$n)

{

$min = ($n - 1) * $unit_num;

$max = min($min + $unit_num , $num);

// echo 'per insert number: min->' . $min . ' ; max->' . $max . PHP_EOL;

$p = pcntl_fork();

if ($p === -1) {

exit('create process ' . $n . ' failed!' . PHP_EOL);

} else if ($p === 0) {

$is_main_process = false;

$sql = 'insert into ' . $tb_name . ' (name , sex , height) values ';

for ($i = $min; $i < $max; ++$i)

{

// name

$name = join('' , random(10 , 'mixed'));

// sex

shuffle($sex_range);

$sex = $sex_range[rand(0 , $sex_range_count - 1)];

// height

$height = rand(50 , 175);

$sql .= '("' . $name . '" , "' . $sex . '" , ' . $height . ') ,';

}

$sql = mb_substr($sql , 0 , -1);

$con = new PDO('mysql:host=127.0.0.1;dbname=Process' , 'users' , 'xxx');

// 每批次插入开始时间

$s_time = microtime(true);

if (!$con->query($sql)) {

exit('插入批次：' . $n . ' 失败' . PHP_EOL);

}

// 每批次插入结束时间

$e_time = microtime(true);

// 每批次插入耗费的时间

$duration = $e_time - $s_time;

// 输出信息

echo '插入批次 ' . $n . ' 花费时间： ' . $duration . 's' . PHP_EOL;

// 记录每次插入耗时(用于统计总耗时)

$fs = fopen($file , 'a');

fwrite($fs , $duration . "rn");

fclose($fs);

break;

} else {

$p_list[] = $p;

}

}

if ($is_main_process) {

foreach ($p_list as $c_pid)

{

pcntl_waitpid($c_pid , $status);

}

$fs = fopen($file , 'r') or exit('process ' . $n . ' open the file failed!' . PHP_EOL);

$total_time = 0;

while ($line = fgets($fs))

{

$line = str_replace("rn" , '' , $line);

$line = floatval($line);

$total_time += $line;

}

echo $p_num . ' 进程插入 ' . ($num / 10000) . 'W 条数据，单次插入 ' . ($unit_num / 10000) . 'W条，耗时：' . $total_time . ' s ' . PHP_EOL;

}

多进程插入 50W 条数据结果(862.17s，都相当于 14min多了。结果完全错误...，问题是，我感觉代码没有写错....呃呃，求解)：

单进程一次性插入 50 万条数据代码

$con = new PDO('mysql:host=127.0.0.1;dbname=Process' , 'users' , 'xxx');

$tb_name = 'test_tb';

$num = 50 * 10000;

$sex_range = array("男" , "女" , "两性" , "未知" , "male" , "female" , "both" , "unknow");

$sex_range_count = count($sex_range);

$unit_num = 10000;

$p_list = array();

$sql = 'insert into ' . $tb_name . ' (name , sex , height) values ';

$p_num = ceil($num / $unit_num);

$is_main_process = true;

for ($i = 1; $i <= $num; ++$i)

{

// name

$name = join('' , random(10 , 'mixed'));

// sex

shuffle($sex_range);

$sex = $sex_range[rand(0 , $sex_range_count - 1)];

// height

$height = rand(50 , 175);

$sql .= '("' . $name . '" , "' . $sex . '" , ' . $height . ') ,';

}

$sql = mb_substr($sql , 0 , -1);

$s_time = microtime(true);

if (!$con->query($sql)) {

exit('插入失败' . PHP_EOL);

}

$e_time = microtime(true);

$duration = $e_time - $s_time;

echo '插入 ' . ($num / 10000) . 'W 条数据花费时间：' . $duration . ' s' . PHP_EOL;

单进程一次性插入 50W 条结果(10.75s，结果准确)：

多进程分批插入数据，反倒比 单进程一次性插入数据更慢！？这是为什么？？