php 异步写入数据库

在 PHP 中实现异步写入数据库可以使用以下两种方法：

1. 使用 Swoole 扩展

Swoole 是一个高性能的异步网络通信框架，可以用来实现异步写入数据库。以下是一个简单的示例代码：

$server = new swoole_server("127.0.0.1", 9501, SWOOLE_PROCESS, SWOOLE_SOCK_TCP);

$server->on('receive', function ($serv, $fd, $from_id, $data) {
    $serv->send($fd, "hello\n");
    $serv->after(1000, function () use ($fd) {
        $dbh = new PDO('mysql:host=localhost;dbname=test', 'root', 'password');
        $dbh->exec("INSERT INTO `test` (`name`) VALUES ('test')");
        $dbh = null;
        $serv->send($fd, "world\n");
    });
});

$server->start();

2. 使用 MySQLi 的异步 API

MySQLi 是 PHP 的一个扩展库，它提供了异步 API，可以用来实现异步写入数据库。以下是一个简单的示例代码：

$mysqli = new mysqli("127.0.0.1", "root", "password", "test", 3306, null, MYSQLI_ASYNC);
$mysqli->query("INSERT INTO `test` (`name`) VALUES ('test')", MYSQLI_ASYNC);

$links = [$mysqli];
$wait_for = null;
$wait_timeout_sec = 1;
$wait_timeout_usec = 0;

do {
    $result = mysqli_poll($links, $wait_for, $wait_timeout_sec, $wait_timeout_usec);
    if ($result === false) {
        echo "Error: " . mysqli_error($mysqli);
        break;
    } elseif ($result > 0) {
        $result = $mysqli->reap_async_query();
        var_dump($result);
        break;
    }
} while (true);

需要注意的是，使用 MySQLi 异步 API 需要开启 MySQLi 的异步模式，而且只有在 PHP 编译时开启了 mysqli 模块的异步支持才能使用。