PHP原生Socket模拟HTTP POST/GET请求方法

实现原理与准备

要通过Socket模拟HTTP请求，核心在于遵循HTTP协议的规范：
1. 建立连接：使用TCP连接到目标主机的80端口（默认）或指定端口。
2. 发送请求行与方法头：明确请求方式（如POST）、路径、协议版本以及必要的Header（如Host, Content-Type, Content-Length）。
3. 发送实体内容：对于POST请求，需要将表单数据序列化为 application/x-www-form-urlencoded 格式并附加在报文末尾。
4. 读取响应：接收服务器返回的状态行和Header，随后提取Body内容。

第一步：封装Socket POST请求函数

我们首先定义一个通用的 sock_post 函数。该函数负责解析URL、处理参数格式化、建立Socket连接、发送完整HTTP报文并读取服务器响应。

<?php
function sock_post($url, $data='') {
    // 1. 解析URL结构
    $url = parse_url($url);
    // 确保scheme为http，若无则默认为http
    $url['scheme'] || $url['scheme'] = 'http';
    // 若URL中无host，尝试使用当前请求主机（适用于相对路径测试）
    $url['host'] || $url['host'] = $_SERVER['HTTP_HOST'];
    // 规范化路径，确保以 '/' 开头
    $url['path'][0] != '/' && $url['path'] = '/'.$url['path'];

    // 2. 处理请求数据
    $query = $data;
    // 如果传入的是数组，使用 http_build_query 转换为查询字符串格式
    if(is_array($data)) $query = http_build_query($data);

    // 3. 建立Socket连接
    // fsockopen 返回文件句柄，便于使用 fputs/fgets 读写
    $fp = @fsockopen($url['host'], $url['port'] ? $url['port'] : 80);
    if (!$fp) return "Failed to open socket to $url[host]";

    // 4. 构造并发送 HTTP 请求头 (HTTP/1.0)
    // 注意：HTTP/1.0 默认是短连接，Connection: close 显式表明意图
    fputs($fp, sprintf("POST %s%s%s HTTP/1.0\r\n", 
        $url['path'], 
        $url['query'] ? '?' : '', 
        $url['query']));
    fputs($fp, "Host: $url[host]\r\n");
    fputs($fp, "Content-type: application/x-www-form-urlencoded\r\n");
    fputs($fp, "Content-length: " . strlen($query) . "\r\n");
    fputs($fp, "Connection: close\r\n\r\n"); // 双 \r\n 表示头部结束

    // 5. 发送 POST 实体数据
    fputs($fp, "$query\r\n");

    // 6. 读取并解析响应
    // 先读取状态行
    $line = fgets($fp,1024);
    // 简单验证状态码是否为 200 OK
    if (@!eregi("^HTTP/1/.. 200", $line)) { 
        fclose($fp);
        return;
    }

    $results = "";
    $inheader = 1; // 标记是否仍在读取 Header
    while(!feof($fp)) {
        $line = fgets($fp,1024);
        // Header 之间通常由空行分隔
        if ($inheader && ($line == "\r\n" || $line == "\n")) {
            $inheader = 0; // 进入 Body 区域
        } elseif (!$inheader) {
            $results .= $line; // 累积 Body 内容
        }
    }
    fclose($fp);
    return $results;
}

// 调用示例：向 localhost 的 get_post.php 发起 POST 请求，传递数组参数
$re = sock_post('http://localhost/direct_post/get_post.php?id=1', array('wel'=>'hello'));
echo $re;
?>

第二步：创建用于接收请求的测试脚本

为了验证上述Socket请求是否成功，我们需要一个接收端脚本。以下代码 get_post.php 将打印出接收到的所有 $_POST 和 $_GET 变量，以便观察数据是否正确传输。

<?php
echo "post:";
print_r($_POST);
echo 'get:';
print_r($_GET);
?>

关键参数与注意事项

• 换行符规范：在原始草稿中存在换行符误用（如 /n），正确的HTTP协议换行必须使用 \r\n（回车+换行）。上述代码已修正此问题，否则部分严格校验的服务器可能拒绝请求。
• 连接超时：fsockopen 支持第三个参数 $errno 和第四个参数 $errstr，建议在实际生产环境中加入超时限制，避免脚本因网络阻塞而长时间挂起。例如： $fp = @fsockopen($host, $port, $errno, $errstr, 30);
• HTTP版本：示例中使用 HTTP/1.0 主要是为了简化逻辑，因为1.0默认关闭持久连接。若需使用 HTTP/1.1，则需要添加 Connection: keep-alive 或 Connection: close，并仔细处理多段响应的边界。

总结

通过上述代码，我们实现了在不依赖外部库的情况下，利用PHP原生Socket功能进行HTTP数据交互。这种方式虽然代码量较大且需手动处理协议细节，但在排查网络层问题或进行简单的API测试时具有一定的灵活性。以上就是PHP中用Socket模拟HTTP POST或GET提交数据的详细内容，更多关于PHP网络编程的资料请关注本站其它相关文章！