C++项目——集群聊天服务器项目(九）客户端异常退出业务

服务器端应检测到客户端是否异常退出，因此本节来实现客户端异常退出，项目流程见后文

一、客户端异常退出业务流程

（1）在业务模块定义处理客户端异常退出的函数

（2）集群聊天服务器项目(八）提到，哈希表_userConnMap存储用户的id和通信连接，若客户端异常退出，表示该客户端登录用户已经下线，那么需要对_userConnMap中对应用户的在线连接进行删除。由于_userConnMap是线程不安全的，操纵需加互斥锁访问。

（3）依次遍历哈希表_userConnMap，判断是否有通信连接同退出的客户端连接一致

若一致，则依据通信连接对应的用户id，删除_userConnMap中通信连接

由于客户端异常退出，表示登录用户已经下线，更新用户状态为offline

二、客户端异常退出业务代码实现

在include/server/chatservice.hpp中创建public公有权限函数，处理客户端异常退出服务

#ifndef CHATSERVICE_H
#define CHATSERVICE_H#include <muduo/net/TcpConnection.h>
#include <unordered_map>//一个消息ID映射一个事件处理 
#include <functional>
#include <mutex>
using namespace std;
using namespace muduo;
using namespace muduo::net;#include "usermodel.hpp"
#include "json.hpp"
using json = nlohmann::json;//表示处理消息的事件回调方法类型，事件处理器，派发3个东西 
using MsgHandler = std::function<void(const TcpConnectionPtr &conn, json &js, Timestamp)>;//聊天服务器业务类
class ChatService
{
public://获取单例对象的接口函数static ChatService *instance();//处理登录业务void login(const TcpConnectionPtr &conn, json &js, Timestamp time);//处理注册业务void reg(const TcpConnectionPtr &conn, json &js, Timestamp time);//处理客户端异常退出void clientCloseException(const TcpConnectionPtr &conn);//获取消息对应的处理器MsgHandler getHandler(int msgid);
private:ChatService();//单例 //存储消息id和其对应的业务处理方法，消息处理器的一个表，写消息id对应的处理操作 unordered_map<int, MsgHandler> _msgHandlerMap;//存储用户的通信连接unordered_map<int,TcpConnectionPtr> _userConnMap;//定义互斥锁，保证_userConnMap的线程安全mutex _connMutex;//数据操作类对象UserModel _userModel;offlineMsgModel _offlineMsgModel;};#endif

在chatservice.cpp中进行实现

// 处理客户端异常退出
void ChatService::clientCloseException(const TcpConnectionPtr &conn)
{User user;{lock_guard<mutex> lock(_connMutex);for (auto it = _userConnMap.begin(); it != _userConnMap.end(); it++){if (it->second == conn){user.setId(it->first);// 从map表中删除用户的连接信息_userConnMap.erase(it);break;}}}// 更新用户的状态信息if (user.getId() != -1){user.setState("offline");_userModel.updateState(user);}
}