PHP中如何将Gearman Worker的数据库连接资源传递给Client？

我已在PHP中使用Gearman实现了连接池（一种我熟知的传统技术），核心思路是启动带有若干数据库连接的Worker，由Client发起连接请求并获取连接。但获取到数据库连接资源后，无法成功传递给Client：直接返回资源会提示“对象无法转换为字符串”，序列化后连接资源则会丢失。相关代码如下：

Worker代码（worker.php） #

// start worker
// addfunction ('getdb', 'getdb')

function getdb ($job){
    $data = unserialize($job->workload());
    $uname = $data['uname'];
    $password = $data['pwd']; // 修正原代码拼写错误：pasword改为password
    $con = mysqli_connect($host, $uname, $password, $db);
    return $con;
}

Client代码 #

// gearman client
$connection = $client->doNormal('getdb', serialize(['uname' => $uname, 'pwd' => $pass])); // 修正原代码数组键名缺失问题

var_dump($connection);

执行var_dump后$connection显示为null或字符串“0”，请问如何实现Worker到Client的连接资源传递？

首先明确：数据库连接资源是进程内的专属资源，无法通过Gearman在不同进程（Worker和Client分属不同进程）之间直接传递。Gearman只能传递可序列化的字符串数据，而数据库连接是底层操作系统的文件句柄，属于进程私有，跨进程传递完全无效。

你需要调整连接池的实现思路，不要试图传递连接资源，而是让Worker作为数据库操作的代理：

1. 修改Worker职责：Worker不返回连接，而是接收Client的具体数据库操作请求（比如查询、插入语句），在Worker内部使用持有的连接执行操作，然后返回操作结果（可序列化的数据，比如数组、JSON字符串）。

示例修改后的Worker代码：

// 预先初始化数据库连接池，比如启动时创建N个连接
$connectionPool = [];
$poolSize = 5;
$host = 'your_host';
$db = 'your_db';
$uname = 'your_user';
$password = 'your_pwd';

for ($i = 0; $i < $poolSize; $i++) {
    $con = mysqli_connect($host, $uname, $password, $db);
    if ($con) {
        $connectionPool[] = $con;
    }
}

// 实现从连接池获取空闲连接的简单逻辑
function getConnectionFromPool(&$pool) {
    foreach ($pool as $key => $con) {
        // 检查连接是否存活
        if (mysqli_ping($con)) {
            // 取出连接，标记为已占用（这里简化处理，实际可以加状态标记）
            return array_splice($pool, $key, 1)[0];
        } else {
            // 连接失效，移除并重新创建
            mysqli_close($con);
            array_splice($pool, $key, 1);
            $newCon = mysqli_connect($host, $uname, $password, $db);
            if ($newCon) {
                $pool[] = $newCon;
            }
        }
    }
    // 无空闲连接，创建新的
    $newCon = mysqli_connect($host, $uname, $password, $db);
    return $newCon;
}

// 释放连接回池
function releaseConnectionToPool(&$pool, $con) {
    if (mysqli_ping($con)) {
        $pool[] = $con;
    } else {
        mysqli_close($con);
    }
}

// 处理数据库操作请求的Worker函数
function handleDbOperation($job) {
    global $connectionPool;
    $data = unserialize($job->workload());
    $operation = $data['operation'];
    $params = $data['params'];
    
    $con = getConnectionFromPool($connectionPool);
    if (!$con) {
        return serialize(['status' => 'error', 'msg' => '无法获取数据库连接']);
    }
    
    $result = null;
    switch ($operation) {
        case 'query':
            $sql = $params['sql'];
            $res = mysqli_query($con, $sql);
            $result = [];
            while ($row = mysqli_fetch_assoc($res)) {
                $result[] = $row;
            }
            mysqli_free_result($res);
            break;
        case 'insert':
            $sql = $params['sql'];
            $result = mysqli_query($con, $sql) ? ['status' => 'success', 'insert_id' => mysqli_insert_id($con)] : ['status' => 'error', 'msg' => mysqli_error($con)];
            break;
        // 可扩展其他操作类型
    }
    
    releaseConnectionToPool($connectionPool, $con);
    return serialize(['status' => 'success', 'data' => $result]);
}

// 注册Worker函数
$worker = new GearmanWorker();
$worker->addServer();
$worker->addFunction('handle_db_operation', 'handleDbOperation');

while ($worker->work());

2. 修改Client逻辑：Client不再请求连接，而是封装具体的数据库操作请求，发送给Worker，接收并处理返回的结果。

示例Client代码：

$client = new GearmanClient();
$client->addServer();

// 示例：发起查询请求
$requestData = serialize([
    'operation' => 'query',
    'params' => [
        'sql' => 'SELECT * FROM your_table LIMIT 10'
    ]
]);

$response = $client->doNormal('handle_db_operation', $requestData);
$result = unserialize($response);

if ($result['status'] === 'success') {
    var_dump($result['data']);
} else {
    echo '操作失败：' . $result['msg'];
}

另外补充几个关键点：

• 连接池的管理要在Worker进程内部完成，包括连接的创建、存活检测、复用、销毁。
• 避免在Worker的任务函数内每次创建新连接，而是预先初始化连接池，提升复用效率。
• 传递的数据必须是可序列化的，比如数组、字符串，不能传递资源类型。

内容的提问来源于stack exchange，提问作者user2678738