当前位置：首页 > PHP

php实现tcp请求

2026-03-13 11:13:50PHP

PHP实现TCP请求的方法

PHP可以通过多种方式实现TCP请求，包括使用内置函数、扩展库或第三方库。以下是几种常见的实现方法：

使用fsockopen函数

fsockopen是PHP内置函数，用于打开一个网络连接或Unix域套接字连接。以下是一个简单的TCP客户端示例：

$host = 'example.com';
$port = 80;
$timeout = 30;

$fp = fsockopen($host, $port, $errno, $errstr, $timeout);
if (!$fp) {
    echo "Error: $errstr ($errno)";
} else {
    $out = "GET / HTTP/1.1\r\n";
    $out .= "Host: $host\r\n";
    $out .= "Connection: Close\r\n\r\n";

    fwrite($fp, $out);
    while (!feof($fp)) {
        echo fgets($fp, 128);
    }
    fclose($fp);
}

使用stream_socket_client函数

stream_socket_client提供了更强大的流处理能力，适合更复杂的TCP通信场景：

$socket = stream_socket_client("tcp://example.com:80", $errno, $errstr, 30);
if (!$socket) {
    die("$errstr ($errno)");
} else {
    fwrite($socket, "GET / HTTP/1.0\r\nHost: example.com\r\nAccept: */*\r\n\r\n");
    while (!feof($socket)) {
        echo fgets($socket, 1024);
    }
    fclose($socket);
}

使用socket扩展

PHP的socket扩展提供了更底层的套接字编程接口：

$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket === false) {
    die("socket_create() failed: " . socket_strerror(socket_last_error()));
}

$result = socket_connect($socket, 'example.com', 80);
if ($result === false) {
    die("socket_connect() failed: " . socket_strerror(socket_last_error($socket)));
}

$in = "GET / HTTP/1.1\r\n";
$in .= "Host: example.com\r\n";
$in .= "Connection: Close\r\n\r\n";
socket_write($socket, $in, strlen($in));

while ($out = socket_read($socket, 2048)) {
    echo $out;
}

socket_close($socket);

使用第三方库（如ReactPHP）

对于需要异步TCP通信的场景，可以使用ReactPHP这样的第三方库：

php实现tcp请求

require 'vendor/autoload.php';

$loop = React\EventLoop\Factory::create();
$connector = new React\Socket\Connector($loop);

$connector->connect('example.com:80')->then(function (React\Socket\ConnectionInterface $connection) {
    $connection->write("GET / HTTP/1.0\r\nHost: example.com\r\nAccept: */*\r\n\r\n");

    $connection->on('data', function ($data) {
        echo $data;
    });

    $connection->on('close', function () {
        echo "[CLOSED]\n";
    });
});

$loop->run();