在swoole协程环境下搭建mysql连接池并防止并发复用，核心策略是结合`swoole\coroutine\mysql`对象与基于channel的锁机制。具体做法是使用一个固定容量的channel作为信号量来控制并发访问，每个协程在获取连接前必须从channel中取出一个令牌，使用完毕后归还令牌；同时，由于`swoole\coroutine\mysql`实例本身不是线程/协程安全的，严禁在不同协程间共享同一个连接对象，因此连接池应维护一组独立的连接实例，通过channel分配和回收这些独立实例，从而彻底避免连接被错误复用的问题。
如何构建基础的协程MySQL连接池结构？
基础连接池的实现依赖于Swoole提供的`Swoole\Coroutine\Channel`类来管理连接的借出与归还。我们需要预先创建一定数量的`Swoole\Coroutine\MySQL`实例，并将它们放入Channel中。当业务代码需要执行SQL时，先从Channel中阻塞地获取一个空闲连接，执行完数据库操作后，务必将连接重新放回Channel。这种模式确保了同一时刻只有有限数量的协程持有连接，且每个连接只被当前持有的协程独占使用，从根本上杜绝了并发复用同一连接对象导致的脏数据或协议错乱问题。
安装、修复、更新或打包一个基于 Python 和 PyMySQL 实现的 Windows `mysql` 命令。适用于用户希望在 PowerShell/CMD 中输入 `mysql` 时重定向到 Python 实现、需要交互式输入 MySQL 连接信息、需要同步到当前用户本地 bin 目录，或需要将该能力封装成可公开复用的 Codex skill。
class MysqlPool {
private $channel;
private $config;
public function __construct($config) {
$this->config = $config;
// 初始化Channel，容量为最大连接数
$this->channel = new Swoole\Coroutine\Channel(10);
// 预创建连接
for ($i = 0; $i < 10; $i++) {
$client = new Swoole\Coroutine\MySQL();
$connect = $client->connect($this->config);
if (!$connect) {
throw new Exception("Connect failed");
}
$this->channel->push($client);
}
}
public function get() {
// 阻塞获取连接，超时时间5秒
$client = $this->channel->pop(5);
if (!$client) {
throw new Exception("Get connection timeout");
}
return $client;
}
public function release($client) {
// 归还连接到池中
$this->channel->push($client);
}
}
// 使用示例
Co::run(function () {
$pool = new MysqlPool([
'host' => '127.0.0.1',
'port' => 3306,
'user' => 'test',
'password' => 'test',
'database' => 'test_db',
]);
$db = $pool->get();
try {
$res = $db->query('SELECT * FROM users LIMIT 1');
var_dump($res);
} finally {
$pool->release($db);
}
});
如何处理连接异常断开后的自动重连与清理？
在实际运行中，MySQL连接可能因网络波动、服务器重启或超时而被服务端主动关闭。如果直接复用已断开的连接，`Swoole\Coroutine\MySQL`会抛出错误或返回空结果。因此，连接池需要在每次使用前检查连接状态，或在捕获到连接断开异常时，销毁该坏连接并创建一个新连接替换它。关键在于，这个“销毁-重建”的过程必须在归还连接之前完成，并且要确保新创建的连接被正确推入Channel，以维持池子的总容量不变。这样既保证了连接的可用性，又避免了因为单个连接失效导致整个池子不可用的风险。
// 修改后的get方法，增加健康检查和重连逻辑
public function get() {
$client = $this->channel->pop(5);
if (!$client) {
throw new Exception("Get connection timeout");
}
// 检查连接是否有效
// Swoole 4.8+ 可以使用 isConnected 方法，或者尝试执行简单查询
try {
$result = $client->query('SELECT 1');
if ($result === false) {
// 连接已断开，需要重连
$this->reconnect($client);
}
} catch (\Exception $e) {
// 发生异常，视为连接断开
$this->reconnect($client);
}
return $client;
}
private function reconnect($oldClient) {
// 关闭旧连接
$oldClient->close();
// 创建新连接
$newClient = new Swoole\Coroutine\MySQL();
$connect = $newClient->connect($this->config);
if (!$connect) {
throw new Exception("Reconnect failed");
}
// 将新连接推回Channel，替代旧的
$this->channel->push($newClient);
}
如果在finally块中忘记释放连接会发生什么？
如果在业务逻辑中没有在`finally`块中调用`release()`方法，或者在获取连接后发生了未捕获的致命错误导致脚本退出，那么该连接将永远滞留在当前协程的作用域内，无法回到Channel中被其他协程复用。这会导致连接池中的可用连接数量逐渐减少，最终当所有连接都被“泄漏”后，后续请求在调用`pop()`时会因超时而失败，表现为服务整体不可用。因此，必须严格保证每个`get()`调用都有对应的`release()`调用，通常借助try-finally结构或PHP的析构函数（不推荐用于此场景）来确保资源的确定性释放。
