连接池

3.1 版本开始，加入 Swoole Server 连接池，在 Swoole Server中，回调 workerStart 自动启动连接池。

连接池实现

在 Server onWokerStart 回调中，程序会调用 app() 函数递归所有服务，若服务实现自 FastD\Pool\PoolInterface 接口，那么在 Server 启动的时候，就会自动调用 initPool 方法，在该方法下执行连接，连接后除非 Worker 中断，否则会一直连接。

  1. <?php
  3. namespace FastD\Pool;
  5. use Medoo\Medoo;
  6. use FastD\Model\Database;
  8. class DatabasePool implements PoolInterface
  9. {
  10.     /**
  11.      * @var Medoo[]
  12.      */
  13.     protected $connections = [];
  15.     /**
  16.      * @var array
  17.      */
  18.     protected $config;
  20.     /**
  21.      * Database constructor.
  22.      *
  23.      * @param array $config
  24.      */
  25.     public function __construct(array $config)
  26.     {
  27.         $this->config = $config;
  28.     }
  30.     /**
  31.      * @param $key
  32.      *
  33.      * @return Database
  34.      */
  35.     public function getConnection($key)
  36.     {
  37.         if (!isset($this->connections[$key])) {
  38.             $config = $this->config[$key];
  39.             $this->connections[$key] = new Database([
  40.                 'database_type' => isset($config['adapter']) ? $config['adapter'] : 'mysql',
  41.                 'database_name' => $config['name'],
  42.                 'server' => $config['host'],
  43.                 'username' => $config['user'],
  44.                 'password' => $config['pass'],
  45.                 'charset' => isset($config['charset']) ? $config['charset'] : 'utf8',
  46.                 'port' => isset($config['port']) ? $config['port'] : 3306,
  47.                 'prefix' => isset($config['prefix']) ? $config['prefix'] : '',
  48.             ]);
  49.         }
  51.         return $this->connections[$key];
  52.     }
  54.     /**
  55.      * {@inheritdoc}
  56.      */
  57.     public function initPool()
  58.     {
  59.         foreach ($this->config as $name => $config) {
  60.             $this->getConnection($name);
  61.         }
  62.     }
  63. }

然后通过 ServiceProvider 注入到容器中, 可参考ServiceProvider

启动服务器，就会连接到每个 worker 当中，要注意的是，所有每个 worker 都是独立的，也就是如果开 20 个 worker，就会产生 20 个连接。

  2. Server: fast-d
  3. App version 2.0.0 (dev)
  4. Swoole version 1.9.5
  5. PID file: /Users/janhuang/Documents/htdocs/me/fastd/fastd/tests/config/../runtime/pid/fast-d.pid, PID: 23683
  6. Server udp://0.0.0.0:9527
  7. Server Master[23683] is started
  8. Server Worker[23695] is started [15]
  9. Server Worker[23690] is started [10]
  10. Server Worker[23691] is started [11]
  11. Server Worker[23692] is started [12]
  12. Server Worker[23693] is started [13]
  13. Server Worker[23694] is started [14]
  14. Server Worker[23696] is started [16]
  15. Server Worker[23697] is started [17]
  16. Server Worker[23698] is started [18]
  17. Server Worker[23699] is started [19]
  18. Server Worker[23700] is started [20]
  19. Server Worker[23701] is started [21]
  20. Server Worker[23702] is started [22]
  21. Server Worker[23703] is started [23]
  22. Server Worker[23704] is started [24]
  23. Server Worker[23705] is started [25]
  24. Server Worker[23706] is started [26]
  25. Server Worker[23707] is started [27]
  26. Server Worker[23708] is started [28]
  27. Server Worker[23709] is started [29]
  28. Server Worker[23710] is started [0]
  29. Server Worker[23711] is started [1]
  30. Server Worker[23712] is started [2]
  31. Server Worker[23713] is started [3]
  32. Server Worker[23714] is started [4]
  33. Server Worker[23715] is started [5]
  34. Server Worker[23716] is started [6]
  35. Server Worker[23717] is started [7]
  36. Server Worker[23718] is started [8]
  37. Server Manager[23689] is started
  38. Server Worker[23719] is started [9]

下一节: 扩展