关于AsyncTcpConnection充当客户端掉线问题？

先梳理一下代码整体的逻辑吧

代码有bug吧。
1、你代码里用的self::$ws_connection，就是所有前端用户共用一个 self::$ws_connection，但是你代码里又是在onMessage里不断重置 self::$ws_connection。应该是在onWorkerStart里设置self::$ws_connection才对。

2、没有人保证连接永远不断开，所以要在onClose里加一个reconnect()逻辑，断开自动重连。前端代码也是一样。

其他都就是连接数超过1024要装event扩展，优化linux内核

onWorkerStart干的事情

/**
 * 进程启动时
 * @param Worker $worker
 * @return void
 */
public function onWorkerStart(Worker $worker): void
{
    try {
        $this->startChannel();
        $this->startCrontab();

        $this->startPublic();
        $this->startPrivate();
        //实时交易
        TradeOrderHelper::start($this->websocket_api->getConfig());
    } catch (Throwable $throwable) {
        print_r(['【onWorkerStart系统异常】' . date('Y-m-d H:i:s') . ' 文件：' . __FILE__ . ' 行号：' . __LINE__, $throwable->getMessage()]);
        sleep(2);
        Worker::stopAll();
    }
}

启动公共连接：

/**
 * @return void
 * @throws Exception
 */
private function startPublic(): void
{
    [$http, $public, $private] = $this->service_url;
    $connection = new AsyncTcpConnection($public, $this->getContextOption());
    $connection->setLabel(AsyncTcpConnection::LABEL_PUBLIC);
    $this->bindConnection($connection);
    $connection->connect();
}

设置异步连接：

/**
 * 设置异步连接
 * @param AsyncTcpConnection $con
 * @return void
 */
private function bindConnection(AsyncTcpConnection $con): void
{
    $con->setStartTime(time());
    $con->account_name = $this->websocket_api->getConfig()->title;
    $con->api_key = $this->websocket_api->getConfig()->api_key;
    // 设置以ssl加密方式访问
    $con->transport = 'ssl';
    $con->onError = function (AsyncTcpConnection $connection, $err_code, $err_msg) {
        //echo "$err_code, $err_msg\n";
    };
    $con->onClose = function (AsyncTcpConnection $connection) {
    };
    $con->onConnect = function (AsyncTcpConnection $con) {
        $con->send(json_encode($this->websocket_api->login()));
        $con->send('ping');
    };
    $con->onMessage = function (AsyncTcpConnection $con, $data) {
        if (!$data) {
            return;
        }
        try {
            switch ($data) {
                case 'pong':    //心跳回应
                    $filename = 'pong_' . $con->getLabel() . '_' . $con->api_key . '.log';
                    $account_name = $this->websocket_api->getConfig()->title;
                    file_put_contents($this->logsPath() . $filename, $account_name . ' 最后收到pong：' . date('Y-m-d H:i:s'));
                    $con->setLastPongTime(time());
                    break;
                default:
                    $event = json_decode($data, true);
                    if (isset($event['event'])) {
                        //事件
                        //WssMessageService::listenEvent($event, $data, $this->websocket_api, $con);
                        $handler = EventFactory::make($event);
                        $handler->handle($event, $this->websocket_api, $con);
                    } else if (isset($event['arg']['channel'])) {
                        //频道
                        //WssMessageService::listenChannel($event, $data, $this->websocket_api, $con);
                        $handler = ChannelFactory::make($event);
                        $handler->handle($event, $this->websocket_api, $con);
                    } else if (isset($event['id']) && isset($event['op'])) {
                        //交易
                        //WssMessageService::listenOp($event, $data, $this->websocket_api, $con);
                        $handler = OperationFactory::make($event);
                        $handler->handle($event, $this->websocket_api, $con);
                    }
                    break;
            }
        } catch (Throwable $throwable) {
            fileDebug([($con->isPublicChannel() ? '【公共频道】' : '【私有频道】') . date('Y-m-d H:i:s'), '【onMessage业务异常】 文件：' . __FILE__ . ' 行号：' . __LINE__, $throwable->getMessage(), $data], 'logs', 'onMessage_Throwable');
        }
    };
}

断线重连逻辑：

/**
 * 检查ping状态，超时断线重连
 * @param AsyncTcpConnection $con
 * @return void
 * @throws Exception
 */
private function checkStatus(AsyncTcpConnection $con): void
{
    try {
        $ttl = config('okx.ping_interval', 20);
        $last_pong_time = $con->getLastPongTime();
        $start_time = $con->getStartTime();
        if (empty($last_pong_time) && ($start_time + $ttl > time())) {
            //刚启动，还没收到pong
            return;
        }

        //超时判断
        if (($last_pong_time + $ttl * 1.3) < time()) {
            RobotNotify::send('ping状态异常正在重连', 'checkStatus：' . $con->getLabel() . PHP_EOL . ($con->account_name ?? ''));
            //重连
            $con->close();
            if ($con->isPrivateChannel()) {
                $this->startPrivate();
            } else {
                $this->startPublic();
            }
        }
    } catch (Throwable $throwable) {
        //通知开发者
        RobotNotify::send('重连异常', 'reconnect：' . $con->getLabel() . PHP_EOL . ($con->account_name ?? '') . PHP_EOL . $throwable->getMessage());
        Worker::stopAll();
    }
}

你看看这个https://www.workerman.net/q/11278