388-完成业务模块代码ChatService并且和网络模块耦合度降级处理

以你之姓@ 2022-09-03 05:18 12阅读 0赞

## 完成业务模块代码ChatService ##

**我们怎么把网络模块收到的消息派发到业务模块，服务模块。让网络模块的代码和业务模块的代码完全解耦。**  
假设一个用户在做登录业务，messageid，name，passwd  
**我们在include下的server创建头文件：chatservice.hpp**

#ifndef CHATSERVICE_H
    #define CHATSERVICE_H
    
    #include <muduo/net/TcpConnection.h>
    #include <unordered_map>//一个消息ID映射一个事件处理 
    #include <functional>
    using namespace std;
    using namespace muduo;
    using namespace muduo::net;
    
    
    #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);
    
        //获取消息对应的处理器
        MsgHandler getHandler(int msgid);
    private:
        ChatService();//单例 
    
        //存储消息id和其对应的业务处理方法，消息处理器的一个表，写消息id对应的处理操作 
        unordered_map<int, MsgHandler> _msgHandlerMap;
    
    };
    
    #endif

**我们在src的server下创建一个文件：chatservice.cpp**（服务）

#include "chatservice.hpp"
    #include "public.hpp"
    #include <muduo/base/Logging.h>//muduo的日志 
    using namespace std;
    using namespace muduo;
    
    //获取单例对象的接口函数
    ChatService *ChatService::instance()
    {
        
        static ChatService service;
        return &service;
    }
    
    //构造方法，注册消息以及对应的Handler回调操作
    ChatService::ChatService()
    {
        
        //用户基本业务管理相关事件处理回调注册
        _msgHandlerMap.insert({
        LOGIN_MSG, std::bind(&ChatService::login, this, _1, _2, _3)});
        _msgHandlerMap.insert({
        REG_MSG, std::bind(&ChatService::reg, this, _1, _2, _3)});
    
    }
    
    
    //获取消息对应的处理器
    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!";//muduo日志会自动输出endl 
            };
        }
        else//成功的话 
        {
        
            return _msgHandlerMap[msgid];//返回这个处理器 
        }
    }
    
    //处理登录业务  id  pwd   pwd
    void ChatService::login(const TcpConnectionPtr &conn, json &js, Timestamp time)
    {
        
        LOG_INFO<<"do login service!!!";
    }
    
    //处理注册业务  name  password
    void ChatService::reg(const TcpConnectionPtr &conn, json &js, Timestamp time)
    {
        
    	LOG_INFO<<"do reg service!!!";
    }

**我们在include下定义一个文件：public.hpp（公共的文件）**

#ifndef PUBLIC_H
    #define PUBLIC_H
    
    /*
    是属于server和client的公共文件
    */
    enum EnMsgType
    {
        
        LOGIN_MSG = 1,//登录消息
        REG_MSG, //注册消息
    
    };
    
    #endif

## 网络模块耦合度降级处理 ##

**我们完善chatserver.cpp**（服务器）

#include "chatserver.hpp"
    #include "json.hpp"
    #include "chatservice.hpp"
    
    #include <iostream>
    #include <functional>
    #include <string>
    using namespace std;
    using namespace placeholders;//占位符 
    using json = nlohmann::json;
    
    //初始化聊天服务器对象
    ChatServer::ChatServer(EventLoop *loop,
                           const InetAddress &listenAddr,
                           const string &nameArg)
        : _server(loop, listenAddr, nameArg), _loop(loop)
    {
        
        //注册链接回调
        _server.setConnectionCallback(std::bind(&ChatServer::onConnection, this, _1));//绑定器bind
    
        //注册消息回调
        _server.setMessageCallback(std::bind(&ChatServer::onMessage, this, _1, _2, _3));//绑定器bind 
    
        //设置线程数量4
        _server.setThreadNum(4);
    }
    
    //启动服务
    void ChatServer::start()
    {
        
        _server.start();
    }
    
    //上报链接相关信息的回调函数
    void ChatServer::onConnection(const TcpConnectionPtr &conn)
    {
        
        //客户端断开链接
        if (!conn->connected())
        {
        
            conn->shutdown();//关闭文件描述符 
        }
    }
    
    //上报读写事件相关信息的回调函数，收到消息了， 
    void ChatServer::onMessage(const TcpConnectionPtr &conn,
                               Buffer *buffer,
                               Timestamp time)
    {
        
        string buf = buffer->retrieveAllAsString();//转成字符串接收
    
        //测试，添加json打印代码
        cout << buf << endl;
    
        //数据的反序列化
        json js = json::parse(buf);
        //达到的目的：完全解耦网络模块的代码和业务模块的代码
        //通过js["msgid"] 获取=》业务handler处理器（在业务模块事先绑定好的）=》conn  js  time传给你 
        auto msgHandler = ChatService::instance()->getHandler(js["msgid"].get<int>());//转成整型 
        //回调消息绑定好的事件处理器，来执行相应的业务处理，一个ID一个操作 
        msgHandler(conn, js, time);
    }

## 网络模块分发业务事件回调操作功能测试 ##

**因为我们的json.hpp在thirdparty，所以我们要完善一下项目工程最外边的CMakeLists.txt**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70]  
**编译成功。**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 1]  
**我们执行一下**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 2]  
**执行成功！！！**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 3]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70]: /images/20220829/e280cb7c906a45b590169ec8b680950d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 1]: /images/20220829/49846c330af149f7905a3ed89deb60dd.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 2]: /images/20220829/def4529f4a5748a4aba8c3c402aa34e3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L0xJTlpFWVU2NjY_size_16_color_FFFFFF_t_70 3]: /images/20220829/8bfd330ce9964ad7af25a829340b5383.png