摘要：本人前一遍中提到，當(dāng)進(jìn)程數(shù)過(guò)多時(shí)，多進(jìn)程插入數(shù)據(jù)庫(kù)表，超過(guò)了最大連接數(shù)，就會(huì)報(bào)錯(cuò)，插入就會(huì)有失敗的情況。這樣就可以控制有的連接數(shù)不會(huì)達(dá)到上限，程序不會(huì)出現(xiàn)連接數(shù)據(jù)庫(kù)失敗的情況。多進(jìn)程耗內(nèi)存比較嚴(yán)重，下一步打算用多線程來(lái)試試。

本人前一遍blog中提到，當(dāng)進(jìn)程數(shù)過(guò)多時(shí)，多進(jìn)程插入mysql數(shù)據(jù)庫(kù)表，超過(guò)了mysql最大連接數(shù)，就會(huì)報(bào)錯(cuò)，插入就會(huì)有失敗的情況。想通過(guò)進(jìn)程間通信來(lái)控制一下連接數(shù)，參考了一些網(wǎng)上的blog
實(shí)現(xiàn)了一下，利用共享內(nèi)存來(lái)存放mysql的連接數(shù)，當(dāng)某個(gè)進(jìn)程在獲取信號(hào)量后，嘗試去連接數(shù)據(jù)庫(kù)之前，先判斷一下，當(dāng)前的連接數(shù)是否超過(guò)了預(yù)定的閾值，如果沒(méi)有，就連接數(shù)據(jù)庫(kù)，連接成功后，連接數(shù)加一，立馬釋放信號(hào)，等操作數(shù)據(jù)庫(kù)完畢后，進(jìn)程再次阻塞，來(lái)獲取信號(hào)，然后把連接數(shù)減一，釋放信號(hào)量后，進(jìn)程退出。
這樣就可以控制有mysql的連接數(shù)不會(huì)達(dá)到上限，程序不會(huì)出現(xiàn)連接數(shù)據(jù)庫(kù)失敗的情況。當(dāng)然我可以直接少fork一些進(jìn)程，本人就是覺(jué)得要折騰一下。不然進(jìn)程通信就懵逼了。而且也不會(huì)有以下的問(wèn)題出現(xiàn)。
但是本人實(shí)驗(yàn)，fork一萬(wàn)個(gè)子進(jìn)程，虛擬機(jī)很容易就掛了。后來(lái)該為fork 5000個(gè)子進(jìn)程，插入一百萬(wàn)條數(shù)據(jù)，模擬的是最原始的插入。虛擬機(jī)雖然沒(méi)有崩， 但是很卡，期間會(huì)出現(xiàn)很多僵尸進(jìn)程，這里有點(diǎn)疑問(wèn)。
多進(jìn)程耗內(nèi)存比較嚴(yán)重，下一步打算用多線程來(lái)試試。
ps：要支持Semaphore函數(shù)，php在編譯安裝是要加上如下參數(shù)：

--enable-sysvsem
--enable-sysvshm
--enable-sysvmsg

為此，我還重新編譯了php。。。。蛋疼啊。代碼如下：

 0) {
        //$id = pcntl_wait($status,WNOHANG);
        $child[] = $pid;
    } else if ($pid == 0) {
        while(true) {
            // 獲得信號(hào)量
            sem_acquire($signal);
            $count = shm_get_var($shm_id, SHARE_KEY);
            if ($count >= $poolSize) {
                sem_release($signal);
                continue;
            } else {
                $link  = mysqli_connect("localhost","root","root","yii2advanced");
                if ($link) {
                    $count++;
                    shm_put_var($shm_id,SHARE_KEY,$count);
                    sem_release($signal);
                    $start = ($i-1)*$per + 1;
                    $end   = $start + $per;
                    for($j = $start; $j< $end; $j++){
                        $time = microtime(true);
                        $sql = "insert pcntl_test (rank,time) values (".$j.",".$time.")";
                        mysqli_query($link,$sql);
                    }
                    mysqli_close($link);
                    break;
                }
                
            }
            sleep(1);
        }
        sem_acquire($signal);
        $count = shm_get_var($shm_id,SHARE_KEY);
        $count--;
        shm_put_var($shm_id, SHARE_KEY, $count);
        sem_release($signal);
        $id = getmypid();
        $count++;
        echo "count : ".$count." child ".$id." finished ".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]);
        }
    }
}
$end = microtime(true);
echo "end ".$end.PHP_EOL;
echo "fork ".$num."process insert ".$total." recodes takes ".($end-$begin).PHP_EOL;

最后，我統(tǒng)計(jì)分析了一下5千個(gè)進(jìn)程，一百萬(wàn)條記錄，插入時(shí)，mysql的連接數(shù)情況（平均連接數(shù)為464），用python作圖如下：