我已经在https://github.com/orgs/reactphp/discussions/502中写了一个答案，但为了更好的可见性，我也将在这里发布相同的答案。
我不是100%确定，但我认为问题出在你的命名空间上。如果promise中出现错误，你应该在rejection处理程序的帮助下回显消息，但我认为它不能匹配抛出的特定Exception。这一切都发生在promise内部，如果处理不正确，promise目前正在吞下当前版本中的异常和错误。我们意识到了这种行为，并正在努力通过ReactPHP v3更好地处理错误，您可以在我们的ReactPHP v3愿望列表讨论中阅读更多关于这一点的信息。
在这个例子中我看不到你的use语句，所以我不能确定这是否是确切的问题，但我认为你想在这里使用\Exception而不是Exception。让我知道这是否解决了你的问题。

这个很好用！

public function start($socket) {
    $connector = new \React\Socket\Connector();
    $connector->connect('localhost:1234')->then(
        function (ConnectionInterface $connection) {
            $connection->on('data', function ($data) use ($connection) {
                    ... do all the things ...
            });
            $connection->on('end', function () use ($connection) {
                echo 'end';
            });
            $connection->on('close', function () use ($connection) {
                echo 'close';
                $this->retry($socket);
            });
            $connection->on('error', function () use ($connection) {
                echo 'error'
            });
        },
        function (\Exception $e) {
            echo $e->getMessage();
            $this->retry($socket);
        }
    );
}

3秒后重试...

function retry(&$socket) {
    global $loop;
    $loop->addTimer(3, fn() => $this->start($socket);
}