[集群聊天服务器]----(三)ChatService模块，解耦网络模块和业务模块

接着上一节[集群聊天服务器]----(二)利用muduo网络库实现网络模块ChatServer的剖析，我们发现需要对网络模块和业务模块进行解耦，引入了ChatService类，接下来我们来看一下业务模块ChatService类具体做了什么。

成员变量

//存储消息id和其对应的事件处理方法 事先就添加好的，不需要考虑线程安全问题
unordered_map<int,MsgHandler> _msgHandlerMap;//定义互斥锁，保证_userConnMap的线程安全
mutex _connMutex;//存储在线用户的通信连接 随着用户的上下线 而改变，需要考虑线程安全问题
unordered_map<int,TcpConnectionPtr> _userConnMap;//数据操作类对象
UserModel _userModel;OfflineMsgModel _offlineMsgModel;FriendModel _friendModel;GroupModel _groupModel;//redis操作对象
Redis _redis;

成员函数

 //获取单例对象的接口函数static ChatService* instance();//处理登录业务void login(const TcpConnectionPtr& conn, json &js, Timestamp time);//处理注册业务void reg(const TcpConnectionPtr& conn, json &js, Timestamp time);// 处理注销业务void loginout(const TcpConnectionPtr &conn, json &js, Timestamp time);//一对一聊天业务void oneChat(const TcpConnectionPtr& conn, json &js, Timestamp time);//添加好友业务void addFriend(const TcpConnectionPtr& conn, json &js, Timestamp time);// 创建群组业务void createGroup(const TcpConnectionPtr &conn, json &js, Timestamp time);// 加入群组业务void addGroup(const TcpConnectionPtr &conn, json &js, Timestamp time);// 群组聊天业务void groupChat(const TcpConnectionPtr &conn, json &js, Timestamp time);//服务器异常退出，业务重置void reset();//获取消息对应的处理器MsgHandler getHandler(int msgid);//处理客户端异常退出void clientCloseException(const TcpConnectionPtr &conn);// 从redis消息队列中获取订阅的消息void handleRedisSubscribeMessage(int, string);

处理消息的事件回调类型

using MsgHandler = std :: function<void(const TcpConnectionPtr& conn, json &js, Timestamp)>;

定义了一个MsgHandler 模板类型，用于处理各类回调

构造函数

ChatService()构造函数被私有化，并给出了单例模式接口，外界只能调用ChatService的静态方法。

//获取单例对象的接口函数
static ChatService* instance();ChatService *ChatService::instance()
{static ChatService service;return &service;
}

static变量会保证全局唯一，多个实例共享一个static变量，若该static变量已经初始化过，就不会再次初始化。static修饰过的成员变量和方法独立于类的任何对象。并且C++ 11 保证 static 成员变量是线程安全的。
注册消息以及对应的handler回调操作

ChatService::ChatService()
{_msgHandlerMap.insert({LOGIN_MSG, std::bind(&ChatService::login, this, _1, _2, _3)});_msgHandlerMap.insert({LOGINOUT_MSG, std::bind(&ChatService::loginout, this, _1, _2, _3)});_msgHandlerMap.insert({REG_MSG, std::bind(&ChatService::reg, this, _1, _2, _3)});_msgHandlerMap.insert({ONE_CHAT_MSG, std::bind(&ChatService::oneChat, this, _1, _2, _3)});_msgHandlerMap.insert({ADD_FRIEND_MSG, std::bind(&ChatService::addFriend, this, _1, _2, _3)});_msgHandlerMap.insert({CREATE_GROUP_MSG, std::bind(&ChatService::createGroup, this, _1, _2, _3)});_msgHandlerMap.insert({ADD_GROUP_MSG, std::bind(&ChatService::addGroup, this, _1, _2, _3)});_msgHandlerMap.insert({GROUP_CHAT_MSG, std::bind(&ChatService::groupChat, this, _1, _2, _3)});/****/}
}

其中_msgHandlerMap是存储消息id和其对应的事件处理方法提前将各个业务模块的代码放入了容器中，其内部有用哈希表记录了各种msgid所对应的回调函数。并且是事先就添加好的，不需要考虑线程安全问题。

unordered_map<int,MsgHandler> _msgHandlerMap;

解耦两个模块的重点就在 ChatServer ::onMessage代码中，调用了getHandler(）

// ChatServer.cpp
auto msgHandler = ChatService::instance()->getHandler(js["msgid"].get<int>());//ChatService.cpp
MsgHandler ChatService::getHandler(int msgid)
{// 记录错误日志 msgid没有对应的事件处理回调auto it = _msgHandlerMap.find(msgid);if (it == _msgHandlerMap.end()){return [=](const TcpConnectionPtr &conn, json &js, Timestamp){LOG_ERROR << "msgid:" << msgid << " can not find handler!";};}else{return _msgHandlerMap[msgid];}
}