当前位置：首页 > PHP

php实现nio

2026-01-29 09:34:37PHP

在PHP中实现NIO（非阻塞I/O）通常需要借助扩展或特定库，因为PHP本身是单线程同步模型。以下是几种实现方式：

使用Swoole扩展

Swoole是PHP的高性能网络通信引擎，直接支持异步非阻塞I/O模型。安装后可通过以下方式实现：

$server = new Swoole\Server("0.0.0.0", 9501, SWOOLE_PROCESS, SWOOLE_SOCK_TCP);
$server->set([
    'worker_num' => 4,
    'daemonize' => false,
    'max_request' => 10000,
    'dispatch_mode' => 2,
    'open_tcp_nodelay' => true,
]);
$server->on('Connect', function ($serv, $fd) {
    echo "Client connected\n";
});
$server->on('Receive', function ($serv, $fd, $reactor_id, $data) {
    $serv->send($fd, "Server: ".$data);
});
$server->on('Close', function ($serv, $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 " . $connection->getRemoteAddress() . "!\n");
    $connection->on('data', function ($data) use ($connection) {
        $connection->close();
    });
});
$loop->run();

使用stream_select函数

PHP原生函数stream_select可实现有限的非阻塞I/O操作：

$read = [$socket];
$write = $except = null;
if (stream_select($read, $write, $except, 0) > 0) {
    foreach ($read as $sock) {
        $data = fread($sock, 1024);
        // 处理数据
    }
}

使用Libevent扩展

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

$base = event_base_new();
$event = event_new();
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) {
    $client = stream_socket_accept($socket);
    // 处理客户端连接
}