1.15.4.2 react/mysql(异步)
优质
小牛编辑
130浏览
2023-12-01
(要求Workerman版本>=3.3.6)
注意:
此组件是第三方组件,可能会有潜在的bug,建议使用WorkermanMySQL组件。
安装:
composer require react/mysql
示例:
<?php
require_once __DIR__ . '/vendor/autoload.php';
use WorkermanWorker;
$worker = new Worker('text://0.0.0.0:6161');
// 进程启动时
$worker->onWorkerStart = function() {
global $mysql;
// 获得workerman的event-loop,
$loop = Worker::getEventLoop();
// 连接参数
$mysql = new ReactMySQLConnection($loop, array(
'host' => '127.0.0.1', // 不要写localhost
'dbname' => '数据库名',
'user' => '用户名',
'passwd' => '密码',
));
// 出现错误时
$mysql->on('error', function($e){
echo $e;
});
// 执行连接
$mysql->connect(function ($e) {
if($e) {
echo $e;
} else {
echo "connect successn";
}
});
};
// 收到客户端请求时
$worker->onMessage = function($connection, $data) {
global $mysql;
// 执行异步查询
$mysql->query('show databases' /*$data*/, function ($command, $mysql) use ($connection) {
if ($command->hasError()) {
$error = $command->getError();
} else {
$results = $command->resultRows;
$fields = $command->resultFields;
$connection->send(json_encode($results));
}
});
};
Worker::runAll();
文档:
https://github.com/bixuehujin/reactphp-mysql
注意:
1、所有的异步编码必须在onXXX
回调中编写
2、异步客户端需要的$loop
变量请使用Worker::getEventLoop();
返回值