php发送异步请求示例

function funCurlRequestAsync($url, $param = [])
{
    $parse_url = parse_url($url);

    $scheme = $parse_url['scheme'];

    if (empty($parse_url['query'])) {
        $path = $parse_url['path'];
    } else {
        $path = $parse_url['path'] . '?' . $parse_url['query'];
    }

    if ($scheme == 'https') {
        $host = 'ssl://' . $parse_url['host'];
    } else {
        $host = $parse_url['host'];
    }

    if (isset($parse_url['port'])) {
        $port = $parse_url['port'];
    } else {
        $port = $scheme == 'https' ? 443 : 80;
    }

    $postData = json_encode($param);

    $header = "POST $path HTTP/1.1\r\n";
    $header .= "Host: $host\r\n";
    $header .= "Content-Type: application/json\r\n";
    $header .= "Content-Length: " . strlen($postData) . "\r\n";
    $header .= "Connection: Close\r\n\r\n";

    $header .= $postData;

    $fp = fsockopen($host, $port, $error_code, $error_msg, 1);
    if (!$fp) {
        return ['error_code' => $error_code, 'error_msg' => $error_msg];
    } else {
        stream_set_blocking($fp, 0);
        stream_set_timeout($fp, 10);
        fwrite($fp, $header);
        usleep(2000); // 延时，防止在nginx服务器上无法执行成功
        fclose($fp);
        return ['error_code' => 0];
    }
}