React PHP中非阻塞I/O实现困境：Socket服务器数据库插入操作咨询

看起来你现在的核心问题是同步数据库操作阻塞了React的事件循环——ReactPHP的核心优势就是基于异步非阻塞的事件循环，但你的$database->write($data)如果是同步IO操作的话，会彻底卡住整个服务器，导致无法同时处理其他连接或请求。下面是具体的解决方案：

核心思路：使用React生态的异步数据库客户端 #

ReactPHP生态有专门的异步数据库库（覆盖MySQL、PostgreSQL等主流数据库），这些库都是基于事件循环实现的非阻塞操作，不会卡住你的Socket服务器。我们以MySQL为例来修改你的代码：

第一步：安装异步MySQL客户端 #

先通过Composer安装官方的React MySQL库：

composer require react/mysql

第二步：修改代码为非阻塞模式 #

替换你原来的同步Database类，改用异步的数据库连接，并在data事件中使用异步操作：

<?php
require __DIR__ . '/vendor/autoload.php';

use React\EventLoop\Factory;
use React\Socket\Server;
use React\Socket\ConnectionInterface;
use React\MySQL\Connection;

$loop = Factory::create();

// 创建异步MySQL连接（替换成你的数据库信息）
$dbConfig = [
    'host' => '127.0.0.1',
    'port' => 3306,
    'user' => 'your_username',
    'password' => 'your_password',
    'dbname' => 'your_database'
];
$connection = new Connection($dbConfig, $loop);

// 处理数据库连接结果
$connection->connect()->then(function () {
    echo "数据库连接成功！\n";
}, function (Exception $e) {
    echo "数据库连接失败：" . $e->getMessage() . "\n";
});

$server = new Server('127.0.0.1:4040', $loop);

$server->on('connection', function(ConnectionInterface $conn) use ($connection) { 
    $conn->write('Welcome, you can start writing your notes now...'); 
    
    $conn->on('data', function($data) use ($conn, $connection) { 
        // 预处理接收的数据：去除多余换行、空格
        $noteContent = trim($data);
        
        // 异步执行插入操作，用参数绑定防止SQL注入
        $connection->query(
            'INSERT INTO notes (content) VALUES (?)',
            [$noteContent]
        )->then(function ($result) use ($conn) {
            // 插入成功后给客户端回复
            $conn->write('Note saved successfully!');
        }, function (Exception $e) use ($conn) {
            // 处理插入失败的情况
            $conn->write('Failed to save note: ' . $e->getMessage());
        });
    }); 
});

echo "Socket server running on 127.0.0.1:4040\n";
$loop->run();

关键说明 #

• 为什么原来的代码会阻塞？：同步数据库操作（比如用PDO、mysqli的同步方法）会让PHP进程等待数据库返回结果，这段时间内事件循环完全停滞，无法处理其他Socket连接的请求，彻底失去了ReactPHP的异步优势。
• 参数绑定的重要性：上面的代码用?作为占位符，把$noteContent作为参数传入，避免了SQL注入风险，千万不要直接把$data拼到SQL语句里。
• 错误处理：一定要处理Promise的catch分支，否则数据库操作失败时会静默报错，你很难排查问题。

其他数据库的适配 #

如果用的是PostgreSQL，可以用react/pgsql库，用法和上面的MySQL示例类似，核心都是使用异步的数据库客户端，基于Promise来处理操作结果，确保不会阻塞事件循环。

内容的提问来源于stack exchange，提问作者Raheel