多应用+插件架构,代码干净,二开方便,首家独创一键云编译技术,文档视频完善,免费商用码云13.8K 广告
# 异步Swoole\Mysql **`(要求Workerman版本>=3.3.6)`** ## 注意: 此组件由swoole底层提供,由C语言编写,具有超高性能。 ## 安装: ``` 安装有swoole扩展即可 ``` ## 示例: ```php <?php require_once '../Autoloader.php'; use Workerman\Worker; use \Swoole\Mysql; $worker = new Worker('tcp://0.0.0.0:6161'); $worker->onWorkerStart = function () { global $mysql; $mysql = new Mysql; $server = array( 'host' => '192.168.56.102', 'port' => 3306, 'user' => 'test', 'password' => 'test', 'database' => 'test', 'charset' => 'utf8', //指定字符集 'timeout' => 2, // 可选:连接超时时间(非查询超时时间),默认为SW_MYSQL_CONNECT_TIMEOUT(1.0) ); $mysql->connect($server, function (Mysql $db, $r) { if ($r === false) { var_dump($db->connect_errno, $db->connect_error); die; } }); }; $worker->onMessage = function ($connection, $data) { global $mysql; $sql = 'show tables'; $mysql->query($sql, function (Mysql $db, $r) { if ($r === false) { var_dump($db->error, $db->errno); } elseif ($r === true) { var_dump($db->affected_rows, $db->insert_id); } var_dump($r); }); }; Worker::runAll(); ``` ## 文档: <https://wiki.swoole.com/wiki/page/517.html>