public function onMessage(Connection $conn, Message $msg)
    {
        $this->totalRdyCount--;
        $this->stats["messagesReceived"]++;

        yield $this->handleMessage($msg);
        // 收到消息后更新rdy
        // 李文告知不需要每次收到消息就调整RDY
        // $this->maybeUpdateRDY($conn);
    }