Download the PHP package easyswoole/pool without Composer

• Pool
  • 安装
  • 基础实现代码
  • 定义池对象
  • 定义池
  • 使用
  • 连接池实现示例
  • 安装easyswoole/redis组件
  • 新增RedisPool管理器
  • 连接池配置项
  • 池管理器
  • 池对象方法

Pool

通用的连接池管理。

安装

基础示例代码

定义池对象

定义池

不一定非要在创建对象方法 createObject() 中返回 对象，任意类型对象均可

使用

Redis连接池实现示例

安装 easyswoole/redis 组件：

新增RedisPool管理器

新增文件 \App\Pool\RedisPool.php，内容如下：

RedisPool 管理器（基于 AbstractPool 实现）：

或使用 RedisPool 管理器（基于 MagicPool 实现）：

不管是基于 AbstractPool 实现还是基于 MagicPool 实现效果是一致的。

在主进程（或 EasySwooleEvent.php 的 initialize / mainServerCreate 事件）中注册到池管理器 Manager 中:

调用（可在控制器中全局进行调用）：

连接池配置项

在实例化一个连接池对象时，需要传入一个连接池配置对象 EasySwoole\Pool\Config，该对象的属性如下:

池管理器

池管理器可以做全局的连接池管理，例如在 EasySwooleEvent.php 中的 initialize 事件中注册，然后可以在控制器中获取连接池然后进行获取连接：

在控制器中获取连接池连接进行调用：

池对象方法

getObj

获取一个连接池的连接对象：

::: warning 通过 getObj 方法获取的对象，都必须调用 recycleObj 或者 unsetObj 方法进行回收，否则连接池对象会越来越少。 :::

unsetObj

直接释放一个连接池的连接对象，其他协程不能再获取到这个连接对象，而是会重新创建一个连接对象

::: warning 释放之后，并不会立即销毁该对象，而是会在作用域结束之后销毁 :::

recycleObj

回收一个连接对象，回收之后，其他协程可以正常获取这个连接对象。

::: warning 回收之后，其他协程可以正常获取这个连接，但在此时，该连接还处于当前协程中，如果再次调用该连接进行数据操作，将会造成协程混乱，所以需要开发人员自行约束，当对这个连接对象进行 recycleObj 操作后不能再操作这个对象 :::

invoke

获取一个连接，传入到 $call 回调函数中进行处理，回调结束后自动回收连接：

::: warning 通过该方法无需手动回收连接，在回调函数结束后，则自动回收 :::

defer

获取一个连接，协程结束后自动回收

::: warning 通过该方法无需手动回收连接，在协程结束后，则自动回收 :::

::: warning 需要注意的事，defer 方法是协程结束后才回收，如果你当前协程运行时间过长，则会一直无法回收，直到协程结束 :::

keepMin

保持最小连接(热启动)。

由于 easyswoole/pool 当刚启动服务，出现过大的并发时，可能会突然需要几十个甚至上百个连接，这时为了让创建连接的时间分散，可以通过调用 keepMin 方法进行预热启动连接。

调用此方法后，将会预先创建 N 个连接，用于服务启动之后的控制器直接获取连接：

预热使用示例如下：

在 EasySwooleEvent.php 中的 mainServerCreate 中，当 Worker 进程启动后，热启动连接：

将会输出:

::: warning keepMin 是根据不同进程，创建不同的连接的，比如你有 10 个 Worker 进程，将会输出 10 次，总共创建 10 * 10 = 100 个连接 :::

getConfig

获取连接池的配置:

destroy

销毁连接池。

调用之后，连接池剩余的所有链接都会被执行 unsetObj，并且将关闭连接队列，调用之后 getObj 等方法都将失效：

reset

重置连接池。

调用 reset 之后，会自动调用 destroy 销毁连接池，并在下一次 getObj 时重新初始化该连接池：

status

获取连接池当前状态，调用之后将输出:

idleCheck

回收空闲超时的连接

intervalCheck

调用此方法后，将调用 idleCheck 和 keepMin 方法，用于手动回收空闲连接和手动热启动连接