摘要：隊(duì)列長(zhǎng)度，拿到客戶端用戶請(qǐng)先登錄用戶身份無(wú)效請(qǐng)重新登錄非法操作發(fā)送數(shù)據(jù)失敗

TP是最新版本的;
大概實(shí)現(xiàn)的有,用戶注冊(cè),注冊(cè)完畢之后跳轉(zhuǎn)到登錄頁(yè)面;
登錄之后生成身份令牌(token)存到Redis;
在聊天界面沒(méi)有任何ajax請(qǐng)求,只要在握手的時(shí)候有一個(gè)http請(qǐng)求,實(shí)在是搞不懂一些人,在聊天界面發(fā)布消息用ajax去發(fā)布,

做了一些處理,一個(gè)瀏覽器里面只能用一個(gè)賬號(hào),所以測(cè)試的時(shí)候必須用兩個(gè)瀏覽器

之后跳轉(zhuǎn)到聊天界面,然后建立WebSocket握手,在握手的同時(shí)攜帶toekn,以及對(duì)方的ID(朋友的ID) ;

后臺(tái)服務(wù)器在OnOpen的時(shí)候做一系列的操作,例如(檢測(cè)token,檢測(cè)朋友的ID,將自己的ID和fd更新到數(shù)據(jù)表,fd綁定uid等..);
這些檢測(cè)都通過(guò)之后獲取聊天記錄,為了效率是拉取和朋友的15條聊天記錄;

在OnMessage中獲取了發(fā)送的數(shù)據(jù)!
在發(fā)送之后檢測(cè)對(duì)方是否在線,如果不在線就不用發(fā)送給對(duì)方,如果對(duì)方在線就將信息push給他!

心跳檢測(cè): 每5秒檢測(cè)一次,如果在100秒沒(méi)有任何操作將斷開連接,斷開連接的同時(shí)將數(shù)據(jù)庫(kù)中的fd清空!

代碼很簡(jiǎn)單,,,但是有個(gè)別的問(wèn)題沒(méi)有解決,比如在線統(tǒng)計(jì)(connections)

下面貼上Socket_Server.php的代碼 其他的都是沒(méi)有什么邏輯的代碼!

完整的等之后寫完了再發(fā)出來(lái)吧,大家共同進(jìn)步!

 4, // 設(shè)置啟動(dòng)的Worker進(jìn)程數(shù) 
        "daemonize" => false, //守護(hù)進(jìn)程化。
        "backlog" => 128, //Listen隊(duì)列長(zhǎng)度，
        "dispatch_mode" => 2,
        "heartbeat_check_interval" => 5,
        "heartbeat_idle_time" => 100,
    ];


    public function onOpen(swoole_websocket_server $server, swoole_http_request $req)
    {
        $fd = $req->fd;
        $token = $req->get["token"] ?? "";    //拿到客戶端用戶ID
        if (!$token) {
            $server->push($fd, Tool::showAjax(["status" => 3, "message" => "請(qǐng)先登錄!"]));
            $server->close($fd);
            return;
        }

        $userData = Cache::get($token);
        if (!$userData) {
            $server->push($fd, Tool::showAjax(["status" => 2, "message" => "用戶身份無(wú)效,請(qǐng)重新登錄!"]));
            $server->close($fd);
            return;
        }

        self::$uid = $req->get["friendId"];
        if (self::$uid == $userData["uid"]) {
            $server->push($fd, Tool::showAjax(["status" => 2, "message" => "非法操作!"]));
            $server->close($fd);
        }
        $server->bind($fd, $userData["uid"]);
        $messages = Message::getMessage($userData["uid"]);

        (new UserModel())->where("id", $userData["uid"])->update(["fd" => $req->fd]);
        $arr = $messages->toArray();
        sort($arr);

        $server->push($fd, Tool::showAjax(["status" => 1, "message" => "success", "data" => $arr]));
    }

    public function onMessage(swoole_websocket_server $server, swoole_websocket_frame $frame)
    {

        $message = $frame->data;
        if (empty($message)) return;
        $data = [
            "uid1" => $server->getClientInfo($frame->fd)["uid"],
            "uid2" => self::$uid,
            "message" => htmlspecialchars($message),
            "send_uid" => $server->getClientInfo($frame->fd)["uid"]
        ];
        try {
            (new Message())->save($data);
        } catch (Exception $e) {
            $server->push($frame->fd, Tool::showAjax(["status" => "2", "message" => "發(fā)送數(shù)據(jù)失敗!"]));
        }

        $messages = Message::getMessage($server->getClientInfo($frame->fd)["uid"]);
        $friendData = UserModel::geUserDataFd(self::$uid);
        $arr = $messages->toArray();
        sort($arr);


        if ($friendData) {
            $server->push($friendData, Tool::showAjax(["status" => 1, "message" => "success", "data" => $arr]));
        }
        $server->push($frame->fd, Tool::showAjax(["status" => 1, "message" => "success", "data" => $arr]));
    }

    function onClose(swoole_server $server, int $fd, int $reactorId)
    {
        (new UserModel())->where("fd", $fd)->update(["fd" => ""]);
    }
}