您当前的位置： 首页 > 学无止境 > 心得笔记 网站首页心得笔记

web端聊天系统开发经验-连接中断处理

发布时间：2020-11-05 15:26:08编辑：雪饮阅读（）

 用户端

对于用户端重新连接后只需要获取该用户所在组的消息列表（需求时一个用户仅有一个聊天组且要保证唯一），所以仅仅只是一个http请求，所以直接可以同步请求即可。

伪代码如
async function socketReconnect(params){
    layer.closeAll();

    var data=await login();
    if(typeof(data)=="undefined"){
        return false;
    }
    var connectData=await createWssConnect();
    socketUrl=`wss://${connectData.socketDomain}/chat?id=${connectData.connectionId}&access_token=${userData.AccessToken}`;
    var socketRes=await createWebSocket(socketUrl);
    user_addMember();
    user_reduce_member();
    groupMessageSeen();

    var tmpList=await getGroupMessage({});
    for(var i in tmpList){
        messageAppend(messageItemInit(tmpList[i]));
    }

}
客服端
对于客服端有两种情况区分：
(1)   由于每个客服可以有若干个聊天组，那么重连后要获取当前客服之前已经加载的聊天组，也有可能有产生新增的组（有新用户进入聊天时），
(2)   以及断开连接之前是否有选中某个聊天组的情况（该情况则重新连接时要优先获取该组的最新消息）

总结：重新连接后要获取最新组列表以及各个组的最新信息。
那么伪代码如：

async function socketReconnect(params){
    layer.closeAll();
    reconnectNum++;
    if(typeof(params.close)!="undefined"){
        layer.close(params.close);
    }
    if(typeof(appData)=="undefined"){
        return init({});
    }


    await login();
    var connectData=await createWssConnect();
    socketUrl=`wss://${connectData.socketDomain}/chat?id=${connectData.connectionId}&access_token=${userData.AccessToken}`;
    await createWebSocket(socketUrl);



    if(appData.selectGroupIndex>-1){
        //异步获取当前选中聊天组消息
        getGroupMessageAsync({groupId:groups[appData.selectGroupIndex].ID});
        //异步读取当前选中聊天组消息
        groupMessageSeen(groups[appData.selectGroupIndex].ID);
    }
    //异步加载最新聊天组
    await getGroupsAsync(20);
    //异步获取断开连接前已有聊天组消息
    for(var i in groups){
        getGroupMessageAsync({groupId:groups[i].ID});
    }
}