Webman不原生支持Cassandra,须用DataStax官方php-driver;Session需懒加载+健康检查管理,禁用onWorkerStart直连;批量写入靠手写BATCH CQL,异步依赖Worker::async()封装。
Webman 本身不提供 Cassandra 集成支持,也没有官方适配的连接池、重连策略或多进程安全封装。想在 Webman 中稳定使用 Cassandra,必须绕过「框架内置」幻想,直面驱动选型、生命周期管理、连接复用这三个硬点。
Webman 里不能用 pdo_cassandra 扩展
Linux 下看似能 pecl install cassandra 成功,但实际运行会报:Class 'PDO' has no connection driver for 'cassandra' 或直接 Segmentation fault。原因很实在:官方 php-cassandra 扩展(即 cassandra.so)从 2021 年起就停止维护,PHP 8.1+ 兼容性差,且其 PDO 驱动层未实现完整的 PDO::ATTR_PERSISTENT 支持。Webman 的常驻进程模型下,短生命周期的 PDO 连接极易泄漏,而扩展内部又没做连接池清理逻辑。
必须用 DataStax 官方 datastax/php-driver
这是目前唯一仍在 actively maintained、支持 PHP 8.0–8.3、兼容 Cassandra 4.x/5.x 的驱动。它不依赖系统扩展,纯 PHP 实现(底层用 cURL + socket),通过 Composer 加载即可:
composer require datastax/php-driver- 代码入口不是
new PDO('cassandra:...'),而是Cassandra::cluster()->withContactPoints(...)->build() - 每个
$cluster->build()返回的是无状态工厂,真正耗资源的是$cluster->connect('keyspace')返回的Cassandra\Session实例 - 该
Session实例是线程不安全但协程安全的 —— 可在 Webman 的单 worker 进程内复用,但不能跨进程共享
Session 必须手动管理生命周期,不能放 onWorkerStart 里简单 new
很多人把 $session = $cluster->connect() 写在 onWorkerStart 回调里,以为“一个 worker 一个 session 就稳了”。错在两点:
- 如果 Cassandra 服务临时不可达,
connect()会阻塞整个 worker 启动,导致 Webman 卡死在启动阶段 - 一旦 session 断开(如网络抖动、Cassandra 重启),该实例不会自动重连,后续所有
$session->execute()都抛Cassandra\Exception\RuntimeException
正确做法是:封装一个懒加载 + 健康检查的 Session 管理器,在每次请求前判断 $session->isConnected()(需先调 $session->execute('SELECT now() FROM system.local') 探活),断开则重建。别省这几十毫秒。
立即学习“PHP免费学习笔记(深入)”;
批量写入和异步执行得自己兜底
DataStax 驱动不提供类似 Laravel 的 insertMany() 或 asyncExecute() 封装。批量插入必须手写 BATCH CQL:
$cql = "BEGIN BATCH INSERT INTO users (id, name) VALUES (?, ?); INSERT INTO users_by_email (email, id) VALUES (?, ?); APPLY BATCH"; $session->execute($cql, new Cassandra\ExecutionOptions([ 'arguments' => [$id, $name, $email, $id] ]));
而所谓“异步”,只能靠 Webman 的 Worker::async() 包一层 —— 但注意:它只是把执行扔进另一个协程,并非驱动原生异步;若批量失败,错误仍要你手动捕获并重试,没有幂等回滚机制。
Cassandra 在 Webman 里的真实水位线不在语法,而在连接韧性与故障恢复节奏。别信“连上就能跑”,Session 的存活状态、CQL 批处理的原子边界、以及超时后是否该降级为本地缓存——这些才是压测时最先崩掉的地方。