当前位置：首页 > PHP

php实现nio

2026-04-03 15:53:36PHP

在PHP中实现类似Java NIO（非阻塞I/O）的高性能网络编程，可以通过以下方法实现。PHP原生对非阻塞I/O的支持有限，但可通过扩展或特定模式模拟类似效果：

使用Streams与非阻塞模式

PHP的stream相关函数支持非阻塞模式设置。通过stream_set_blocking()将socket设为非阻塞，配合stream_select()实现多路复用：

php实现nio

$socket = stream_socket_server("tcp://0.0.0.0:8000", $errno, $errstr);
stream_set_blocking($socket, 0); // 设为非阻塞

$read = [$socket];
$write = $except = null;

while (true) {
    $changed = stream_select($read, $write, $except, 0); // 非阻塞检查
    if ($changed > 0) {
        $conn = stream_socket_accept($socket);
        fwrite($conn, "HTTP/1.1 200 OK\r\nContent-Length: 2\r\n\r\nOK");
        fclose($conn);
    }
}

Swoole扩展

Swoole是PHP的高性能网络通信框架，原生支持异步I/O和事件循环：

php实现nio

$server = new Swoole\Server("0.0.0.0", 9501, SWOOLE_PROCESS, SWOOLE_SOCK_TCP);

$server->on('Connect', function ($server, $fd) {
    echo "Client connected\n";
});

$server->on('Receive', function ($server, $fd, $reactorId, $data) {
    $server->send($fd, "Server: " . $data);
});

$server->on('Close', function ($server, $fd) {
    echo "Client closed\n";
});

$server->start();

ReactPHP库

ReactPHP提供事件驱动的非阻塞I/O组件，适合实现异步应用：

$loop = React\EventLoop\Factory::create();
$socket = new React\Socket\Server('0.0.0.0:8080', $loop);

$socket->on('connection', function (React\Socket\ConnectionInterface $connection) {
    $connection->write("Hello\n");
    $connection->on('data', function ($data) use ($connection) {
        $connection->close();
    });
});

$loop->run();

Libevent扩展

通过Libevent实现事件循环（需安装扩展）：

$base = event_base_new();
$event = event_new();

$socket = stream_socket_server("tcp://0.0.0.0:8000");
stream_set_blocking($socket, 0);

event_set($event, $socket, EV_READ | EV_PERSIST, 'accept_cb', $base);
event_base_set($event, $base);
event_add($event);
event_base_loop($base);

function accept_cb($socket, $events, $base) {
    $conn = stream_socket_accept($socket);
    fwrite($conn, "HTTP/1.1 200 OK\r\n\r\n");
    fclose($conn);
}