连接池

安装

  1. composer require hyperf/pool

为什么需要连接池？

当并发量很低的时候，连接可以临时建立，但当服务吞吐达到几百、几千的时候，频繁 建立连接 Connect 和 销毁连接 Close 就有可能会成为服务的一个瓶颈，那么当服务启动的时候，先建立好若干个连接并存放于一个队列中，当需要使用时从队列中取出一个并使用，使用完后再反还到队列去，而对这个队列数据结构进行维护的，就是连接池。

使用连接池

对于 Hyperf 官方提供的组件，都是已经对接好连接池的，在使用上无任何的感知，底层自动完成连接的取用和归还。

自定义连接池

定义一个连接池首先需要实现一个继承了 Hyperf\Pool\Pool 的子类并实现抽象方法 createConnection，并返回一个实现了 Hyperf\Contract\ConnectionInterface 接口的对象，这样您创建的连接池对象就已经完成了，如下示例：

  1. <?php
  2. namespace App\Pool;
  4. use Hyperf\Contract\ConnectionInterface;
  5. use Hyperf\Pool\Pool;
  7. class MyConnectionPool extends Pool
  8. {
  9.     public function createConnection(): ConnectionInterface
  10.     {
  11.         return new MyConnection();
  12.     }
  13. }

这样便可以通过对实例化后的 MyConnectionPool 对象调用 get(): ConnectionInterface 和 release(ConnectionInterface $connection): void 方法执行连接的取用和归还了。

SimplePool

这里框架提供了一个非常简单的连接池实现。

  1. <?php
  3. use Hyperf\Pool\SimplePool\PoolFactory;
  4. use Swoole\Coroutine\Http\Client;
  6. $factory = $container->get(PoolFactory::class);
  8. $pool = $factory->get('your pool name', function () use ($host, $port, $ssl) {
  9.     return new Client($host, $port, $ssl);
  10. }, [
  11.     'max_connections' => 50
  12. ]);
  14. $connection = $pool->get();
  16. $client = $connection->getConnection(); // 即上述 Client.
  18. // Do something.
  20. $connection->release();

低频组件

连接池内置 LowFrequencyInterface 接口，默认使用的低频组件，会根据从连接池中获取连接的频率，来决定是否释放连接池中多余的连接。

如果我们需要替换对应的低频组件，可以直接在 dependencies 配置中替换，以下以数据库组件为例。

  1. <?php
  3. declare(strict_types=1);
  5. namespace App\Pool;
  7. class Frequency extends \Hyperf\Pool\Frequency
  8. {
  9.     /**
  10.      * 被计算频率的时间间隔
  11.      * @var int
  12.      */
  13.     protected $time = 10;
  15.     /**
  16.      * 触发低频的频率
  17.      * @var int
  18.      */
  19.     protected $lowFrequency = 5;
  21.     /**
  22.      * 连续触发低频的最小时间间隔
  23.      * @var int
  24.      */
  25.     protected $lowFrequencyInterval = 60;
  26. }

修改映射关系如下

  1. <?php
  2. return [
  3.     Hyperf\DbConnection\Frequency::class => App\Pool\Frequency::class,
  4. ];

恒定频率

当然，框架还提供了另外一种低频组件 ConstantFrequency。

当此组件实例化后，会启动定时器，在固定间隔调用 Pool::flushOne(false) 方法，此方法会拿出连接池中的一个连接，并判断超过闲置时长后，销毁连接。

  1. <?php
  2. return [
  3.     Hyperf\DbConnection\Frequency::class => Hyperf\Pool\ConstantFrequency::class,
  4. ];