发表新帖

跨worker 检查客户端fd 是否存在

我在TCP server 中，onWorkerStart 位置有一个定时器，统一管理所有的FD状态，但在做在线状态检查时返回false ，不知道什么原因。

```php
function my_onWorkerStart(\swoole_server $serv, $worker_id)
{
    global $argv;
    $jobType = ($worker_id >= $serv->setting['worker_num']) ? 'task' : 'event';
    PHP_OS === "Linux" && cli_set_process_title("php {$argv[0]} {$jobType} worker{$worker_id}");

if ($worker_id === 0) {
        \Swoole\Timer::tick(1000, function () use ($serv) {
            foreach (PRedis::instance('trans_process')->smembers("trans_running") as $trans_key) {
                $info = PRedis::instance('trans_process')->hgetall("trans_{$trans_key}");
                if ($info) {
                    // 超时了(5s)
                    if (microtime(true) - $info['begin_at_ms'] > 10) {
                        // 检查是否有链接活跃
                        $fds = PRedis::instance('trans_process')->smembers("trans_{$trans_key}_fd");
                        $inActiveFds = array_filter($fds, function ($fd) use ($serv) {
                            return $serv->exist((int)$fd);// 这里期望对应的未断开的链接返回True
                        });
                        if (!$inActiveFds) {
                            // 回退异常事务
                            $request_data = [
                                'cmd' => 65535,
                                'request_key' => $trans_key,
                                'param' => []
                            ];
                            $serv->taskwait($request_data, 2, (int)$info['task_worker_id']);

// 删除记录
                            PRedis::instance('trans_process')->srem("trans_running", $trans_key);
                            PRedis::instance('trans_process')->delete("trans_{$trans_key}");
                            PRedis::instance('trans_process')->delete("trans_{$trans_key}_fd");
                        }
                    }
                }
            }
        });
    }
}
```

PHP 7.4.1  swoole 4.4.16  Darwin bogon 19.4.0

发布于6年前 · 8 次浏览 · 来自提问