Gateway/Worker模型 数据库使用示例

安装

具体安装使用参见 Workerman手册 Workerman/MySQL

使用示例

项目/Events.php

  1. <?php
  2. use \GatewayWorker\Lib\Gateway;
  3. require_once '/your/path/of/mysql-master/src/Connection.php';
  5. /**
  6.  * 数据库示例，假设有个your_db_name库，里面有个user表
  7.  */
  8. class Events
  9. {
  10.     /**
  11.      * 新建一个类的静态成员，用来保存数据库实例
  12.      */
  13.     public static $db = null;
  15.     /**
  16.      * 进程启动后初始化数据库连接
  17.      */
  18.     public static function onWorkerStart($worker)
  19.     {
  20.         self::$db = new Workerman\MySQL\Connection('host', 'port', 'user', 'password', 'db_name');
  21.     }
  23.    /**
  24.     * 有消息时触发该方法，根据发来的命令打印2个用户信息
  25.     * @param int $client_id 发消息的client_id
  26.     * @param mixed $message 消息
  27.     * @return void
  28.     */
  29.    public static function onMessage($client_id, $message)
  30.    {
  31.         // 发来的消息
  32.         $commend = trim($message);
  33.         if($commend !== 'get_user_list')
  34.         {
  35.             Gateway::sendToClient($client_id, "unknown commend\n");
  36.             return;
  37.         }
  38.         // 使用数据库实例
  39.         self::$db->select('*')->from('users')->where('uid>3')->offset(5)->limit(2)->query();
  40.         // 打印结果
  41.         return Gateway::sendToClient($client_id, var_export($ret, true));
  42.    }
  44. }