一次php curl卡住的bug分析

今天药忘吃喽~ 2022-01-20 04:59 830阅读 0赞

php 7.1.18 libcurl 导致curl\_multi\_select() 返回值永远为-1进程卡住,升级到php 7.1.24就OK了

bug原由

用curl\_multi\_init加快多次请求的速度，然后再docker容器中测试发现，会卡住，cpu占用率也非常高 附上代码

foreach ($tmp_openids as $v_openids) {
    
                $multi_ch = curl_multi_init();
    
                $ch_list = [];
    
                $succ_count = 0;
    
                $err_count = 0;
    
                foreach ($v_openids as $k => $v) {
    
                    $send['content']['touser'] = $v;
    
                    $post_data = json_encode($send['content'], JSON_UNESCAPED_UNICODE);
    
                    $this->set_user_nick($message_detail, $user_info_lists, $v, $post_data);
    
                    $ch_list[$k] = curl_init($send['api']);
    
                    curl_setopt($ch_list[$k], CURLOPT_POST, 1);
    
                    curl_setopt($ch_list[$k], CURLOPT_POSTFIELDS, $post_data);
    
                    curl_setopt($ch_list[$k], CURLOPT_RETURNTRANSFER, 1);
    
                    curl_setopt($ch_list[$k], CURLOPT_TIMEOUT, MQ_CURLOPT_TIMEOUT);
    
                    curl_setopt($ch_list[$k], CURLOPT_SSL_VERIFYPEER, false);
    
                    curl_setopt($ch_list[$k], CURLOPT_SSL_VERIFYHOST, false);
    
                    curl_multi_add_handle($multi_ch, $ch_list[$k]);
                }
    
                $active = null;
    
                do {
    
                    $mrc = curl_multi_exec($multi_ch, $active); //处理在栈中的每一个句柄。无论该句柄需要读取或写入数据都可调用此方法。
    
                } while ($mrc == CURLM_CALL_MULTI_PERFORM);
    
                //该函数仅返回关于整个批处理栈相关的错误。即使返回 CURLM_OK 时单个传输仍可能有问题。 
    
                while ($active && $mrc == CURLM_OK) {
    
                    if (curl_multi_select($multi_ch) != -1) {//阻塞直到cURL批处理连接中有活动连接。 
    
                        do {
    
                            $mrc = curl_multi_exec($multi_ch, $active);
    
                        } while ($mrc == CURLM_CALL_MULTI_PERFORM);
    
                    }
    
                }
    
                // 获取http返回的结果
                foreach ($ch_list as $k => &$ch) {
    
                    $result = curl_multi_getcontent($ch);
    
                    curl_multi_remove_handle($multi_ch, $ch);
    
                    curl_close($ch);
    
                    if (!$result) {
    
                        ++$err_count;
    
                        $this->err_log->info('微信接口无反应发送失败!');
    
                    }
                    else {
    
                        if (json_decode($result, true)['errcode'] != 0) {
    
                            $this->err_log->info('微信接口报错' . $result);
    
                            ++$err_count;
    
                        }
                        else {
    
                            ++$succ_count;
                        }
    
                    }
    
                }
    
                curl_multi_close($multi_ch);
    复制代码