PHP长连接如何获取数据

在当今的互联网世界，数据的实时性变得越来越重要，对于需要频繁交互的应用，比如在线聊天、实时游戏或者股票交易等，传统的HTTP请求方式就显得力不从心了，这时，长连接技术就显得尤为重要，长连接允许服务器和客户端之间保持一个持久的连接，这样数据就可以实时地在两者之间传输，无需每次都重新建立连接，就让我们来聊聊如何在PHP中实现长连接，并高效地获取数据。

我们要明白长连接并不是一个新的概念，它在TCP/IP协议中已经存在了很久，在HTTP协议中，我们可以通过设置HTTP头中的Connection字段为keep-alive来实现长连接，这并不是我们今天要讨论的重点，我们的目标是实现一个PHP脚本，它可以保持与客户端的长连接，并实时地发送数据。

使用PHP的socket扩展

PHP提供了一个socket扩展，允许我们创建TCP/IP网络的socket连接，这个扩展可以用来实现长连接，因为它允许我们监听端口，接受连接，并发送或接收数据。

1、创建服务器端socket

    $address = '0.0.0.0'; // 监听所有接口
    $port = 12345; // 选择一个端口
    // 创建socket
    $sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
    socket_bind($sock, $address, $port); // 绑定地址和端口
    socket_listen($sock); // 开始监听
    echo "Server is running...
";

2、接受客户端连接

    while(true) {
        $client = socket_accept($sock); // 接受连接
        if ($client < 0) {
            echo "socket_accept() failed: " . socket_strerror($client) . "
";
            continue;
        }
        // 处理连接
        while(true) {
            $buf = socket_read($client, 2048); // 读取数据
            if ($buf === false) {
                echo "socket_read() failed: " . socket_strerror(socket_last_error($client)) . "
";
                break;
            }
            if ($buf == "") {
                echo "Connection closed by client
";
                break;
            }
            // 处理接收到的数据
            echo "Received: " . $buf . "
";
            // 发送数据回客户端
            socket_write($client, "Data received");
        }
        socket_close($client); // 关闭客户端连接
    }
    socket_close($sock); // 关闭服务器端socket

3、客户端连接服务器

客户端可以使用任何支持TCP连接的库来连接服务器，这里是一个简单的示例，使用PHP的cURL库：

    $address = '127.0.0.1';
    $port = 12345;
    $fp = fsockopen($address, $port, $errno, $errstr, 30);
    if (!$fp) {
        echo "$errstr ($errno)
";
    } else {
        echo "Connected
";
        // 发送数据到服务器
        fwrite($fp, "Hello Server
");
        // 读取服务器响应
        while (!feof($fp)) {
            echo fgets($fp, 128);
        }
        fclose($fp);
    }