php workerman使用mysql查询的demo

以下是一个使用 Workerman 和 MySQL 进行查询的示例：

require_once __DIR__ . '/Workerman/Autoloader.php';

use Workerman\Worker;
use Workerman\Connection\AsyncTcpConnection;

$worker = new Worker();

$worker->onWorkerStart = function() {
    $db = new AsyncTcpConnection('mysql://user:password@localhost/mydatabase');

    $db->onConnect = function($db) {
        $sql = "SELECT * FROM mytable";
        $db->send($sql);
    };

    $db->onMessage = function($db, $data) {
        $result = json_decode($data, true);
        var_dump($result);
    };

    $db->connect();
};

Worker::runAll();

这个示例中，我们创建了一个 Workerman 服务，连接到一个 MySQL 数据库。在 onConnect 回调函数中，我们发送了一个查询语句。当数据库返回结果时，onMessage 回调函数会被调用，我们可以在这里处理查询结果。

注意，我们使用的是 AsyncTcpConnection，这是因为 MySQL 是一个基于 TCP 的协议。使用 AsyncTcpConnection 可以保证我们的查询是异步的，这样就可以在查询期间继续处理其他请求