异步react/mysql

(要求Workerman版本>=3.3.6)

注意:

此组件是第三方组件，可能会有潜在的bug，建议使用Workerman\MySQL组件。

安装：

  1. composer require react/mysql

示例：

  1. <?php
  2. require_once __DIR__ . '/vendor/autoload.php';
  3. use Workerman\Worker;
  5. $worker = new Worker('text://0.0.0.0:6161');
  7. // 进程启动时
  8. $worker->onWorkerStart = function() {
  9.     global $mysql;
  10.     // 获得workerman的event-loop，
  11.     $loop  = Worker::getEventLoop();
  12.     // 连接参数
  13.     $mysql = new React\MySQL\Connection($loop, array(
  14.         'host'   => '127.0.0.1', // 不要写localhost
  15.         'dbname' => '数据库名',
  16.         'user'   => '用户名',
  17.         'passwd' => '密码',
  18.     ));
  19.     // 出现错误时
  20.     $mysql->on('error', function($e){
  21.         echo $e;
  22.     });
  23.     // 执行连接
  24.     $mysql->connect(function ($e) {
  25.         if($e) {
  26.             echo $e;
  27.         } else {
  28.             echo "connect success\n";
  29.         }
  30.     });
  31. };
  32. // 收到客户端请求时
  33. $worker->onMessage = function($connection, $data) {
  34.     global $mysql;
  35.     // 执行异步查询
  36.     $mysql->query('show databases' /*$data*/, function ($command, $mysql) use ($connection) {
  37.         if ($command->hasError()) {
  38.             $error = $command->getError();
  39.         } else {
  40.             $results = $command->resultRows;
  41.             $fields  = $command->resultFields;
  42.             $connection->send(json_encode($results));
  43.         }
  44.     });
  45. };
  47. Worker::runAll();

文档：

https://github.com/bixuehujin/reactphp-mysql

注意：

1、所有的异步编码必须在onXXX回调中编写

2、异步客户端需要的$loop变量请使用Worker::getEventLoop();返回值