Workerman 5 errorHandler 為啥要綁定每個TCP連接上？

meows 更新于2023-10-05

問題描述

class TcpConnection {
    public $errorHandler = null;
    public function error(Throwable $exception): void
    {
        if (!$this->errorHandler) {
            Worker::stopAll(250, $exception);
            return;
        }
        try {
            ($this->errorHandler)($exception);
        } catch (Throwable $exception) {
            if ($this->eventLoop instanceof Event) {
                echo $exception;
                return;
            }
            throw $exception;
        }
    }
}

為什么不直接設(shè)置為全局Handler，比如：

    $worker = new Worker("http://0.0.0.0:8888");
    $worker->errorHandler = function($e) {
        Worker::log(xxx);
    }
    或者這樣
    Worker::$errorHandler = function($e) {write log..}

class Worker {
    public $errorHandler = null;
    // 或者下面這樣呢？
    // public static $errorHandler = null;
    public static function error(Throwable $exception): void
    {
        if (!$this->errorHandler) {
            Worker::stopAll(250, $exception);
            return;
        }
        try {
            ($this->errorHandler)($exception);
        } catch (Throwable $exception) {
            if (static::$globalEvent instanceof Event) {
                echo $exception;
                return;
            }
            throw $exception;
        }
    }
}

// 這樣做不是更加節(jié)省內(nèi)存，性能更好一些。但每個TCP都綁定errorHandler有其它原因呢？
// 如果在長連接場景，連接都不斷開errorHandler會存在挺多，全局這樣就只有一份。

 987  1 0

1個回答

walkor 2023-10-05

打賞

為了解耦，方便給每個連接定制化錯誤處理，還有方便做單元測試。
$errorHandler = 'myHanlder'; 這種不會占用多少內(nèi)存。

meows 2023-10-07

try {
// Decode request buffer before Emitting onMessage callback.
/* @var ProtocolInterface $parser /
$parser = $this->protocol;
$request = $parser::decode($oneRequestBuffer, $this);
if (static::$enableCache && (!is_object($request) || $request instanceof Request) && $one && !isset($oneRequestBuffer[512])) {
$requests[$oneRequestBuffer] = $request;
if (count($requests) > 512) {
unset($requests[key($requests)]);
}
}
($this->onMessage)($this, $request);
} catch (Throwable $e) {
$this->error($e);
}

如果 deocde 拋出異常，worker 會被干掉，這樣是不是不太好！
不是守護進程模式，直接echo $exception, 守護進程直接寫入日志文件這樣不是更加好？
這樣退出進程然后輸出到終端有什么原因？
walkor 2023-10-07

協(xié)議解析出問題是致命問題
meows 2023-10-11

$worker->reloadable = false; 本身是不是無效的，親測無效。
$worker->reloadable = true; worker 退出重啟修改代碼文件有效，親測可行。
我感覺reloadable 屬性設(shè)置為false沒有意義呢。

我理解的原理：
master 啟動時候include 所有文件，worker 繼承 master 所有加載的文件，然后重新讀取常駐內(nèi)存。
如果不重啟worker，就還是常駐內(nèi)存之前的效果一樣的吧！
http://www.wtbis.cn/doc/workerman/worker/reloadable.html 這篇文章鏈接reloadable = false 是不是需要改一改？
應(yīng)該是沒有用的，沒辦法更新業(yè)務(wù)代碼。

“設(shè)置gateway進程的reloadable屬性為false則在reload可以做到在不斷開客戶端連接的情況下更新業(yè)務(wù)代碼?！?br /> 這句話是不是應(yīng)該刪除掉，好像沒有用呢。
admin 2023-10-12
哥們是不是閱讀理解有問題，

執(zhí)行php start.php reload時會向所有子進程發(fā)送reload信號(SIGUSR1)。

這個reloadable 屬性是用來人工設(shè)置是否響應(yīng)reload 代碼，gatewayworker模式下gateway不能reload因為用戶長鏈接這個gateway，而bussiness需要reload，register也不需要reload。所以明白了嗎

如果只有一種類型的進程這個reloadable 確實沒啥用，多個不同類型的進程，有些需要reload，有些不需要懂了么。

worker收到信號就會fork_new 然后include_once，因為是剛剛fork的，所以會重新讀入代碼
meows 2023-10-12

感謝，懂了。哈哈哈

meows 2023-10-12

              //  $worker->reloadable = false; 
               // 開始沒有明白這么做為了什么，感謝你的提醒，他就是為了執(zhí)行下onWorkerReload() 業(yè)務(wù)，其它啥也沒做。
                foreach ($workerPidArray as $pid) {
                    // Send reload signal to a worker process which reloadable is false.
                    posix_kill($pid, $sig);
                }