chat集群聊天室项目 代码+讲解(一):网络模块

举报
看,未来 发表于 2021/09/14 21:12:47 2021/09/14
【摘要】 @[toc] 前言准备翻新一下我那个C++集群聊天室项目的讲解博客,那个系列刚开始讲的还比较有点耐心,后面就直接堆代码了,大家互相理解理解,那确实有点触碰到我目前的极限了,能写下来就不错了。勉强把项目整好之后我就去看muduo了(好像还有最后一篇《TCPServer》还没放出来哈,真的是因为VScode坏了,然后又有一件不得不做的事情拖住了几天时间。)目前已经粗略的捋了一遍muduo的源码,...

请添加图片描述


@[toc]

前言

准备翻新一下我那个C++集群聊天室项目的讲解博客,那个系列刚开始讲的还比较有点耐心,后面就直接堆代码了,大家互相理解理解,那确实有点触碰到我目前的极限了,能写下来就不错了。

勉强把项目整好之后我就去看muduo了(好像还有最后一篇《TCPServer》还没放出来哈,真的是因为VScode坏了,然后又有一件不得不做的事情拖住了几天时间。)目前已经粗略的捋了一遍muduo的源码,这周就把项目和源码两个系列好好的整理出来,再背背八股文,把以前的基础找回来,准备面试了。

然后,祝我大莆田无恙吧,这次的事情是突然了点。(就不放张伟了,换妈祖像。)

github地址:chat


简单架构图

请添加图片描述


代码

#pragma

#include<muduo/net/TcpServer.h>
#include<muduo/net/EventLoop.h>

#include<iostream>

using namespace std;
using namespace muduo;
using namespace muduo::net;


class ChatServer{
private:
    TcpServer _server;
    EventLoop* _loop;

public:
    ChatServer(EventLoop* loop,
            const InetAddress& listenAddr,
            const string& nameArg);
    
    void start();

private:
    void onConnection(const TcpConnectionPtr& conn);
    void onMessage(const TcpConnectionPtr& conn,Buffer* buff,Timestamp time);
};
#include "chatserver.hpp"
#include "chatservice.hpp"
#include "json.hpp"

#include <functional>
#include <string>

using json = nlohmann::json;
using namespace std;
using namespace placeholders;

ChatServer::ChatServer(EventLoop *loop,
                       const InetAddress &listenAddr,
                       const string &nameArg) : _server(loop, listenAddr, nameArg),
                                                _loop(loop)
{
    //注册连接回调
    _server.setConnectionCallback(std::bind(&ChatServer::onConnection, this, _1));

    //注册消息回调
    _server.setMessageCallback(std::bind(&ChatServer::onMessage, this, _1, _2, _3));

    //设置线程数
    _server.setThreadNum(5);
}

void ChatServer::start()
{
    _server.start();
}


void ChatServer::onMessage(const TcpConnectionPtr &conn, Buffer *buff, Timestamp time){
    string buf = buff->retrieveAllAsString();

    json js = json::parse(buf);

    //通过msgid获取业务回调,进行网络模块和任务模块之间的解耦合
    auto msgHandler = ChatService::instance()->getHandle(js["msgid"].get<int>());
    
    //回调消息绑定好的事件处理器,执行相应的业务处理
    msgHandler(conn,js,time);

    //成功解耦
}

void ChatServer::onConnection(const TcpConnectionPtr &conn){
    if(!conn->connected()){ //用户断开连接

        ChatService::instance()->clientCloseException(conn);
        conn->shutdown();
    }
}

讲解

无奈,有段时间没有画类图了,不然这里放张类图可能会好看点。讲业务层的时候是需要放类图了,那个牵扯有点多了。

setConnectionCallback

_server.setConnectionCallback(std::bind(&ChatServer::onConnection, this, _1));

这个_server是一个TcpServer对象,我们就直接去看源码吧。

void setConnectionCallback(const ConnectionCallback& cb)
{ 
	connectionCallback_ = cb; 
}

一个简单的赋值。

typedef std::function<void (const TcpConnectionPtr&)> ConnectionCallback;

ConnectionCallback 是一个函数对象,需要传入一个TcpConnection对象的指针。

typedef std::shared_ptr<TcpConnection> TcpConnectionPtr;

再多久不用说啦,说下去没完没了的了。

这行代码的意思是:用户注册一个连接回调,当收到连接状态变更消息时,一并调用此回调。
就是说,不写也可以,muduo库内部有默认的连接回调,不过效果可能没那么理想化,想定制就自己写一个连接回调。

那个_1是预留参数位,调用者为muduo网络库。


setMessageCallback

_server.setMessageCallback(std::bind(&ChatServer::onMessage, this, _1, _2, _3));

概念同上,注册一个用户自己的消息回调,参数有muduo网络库传入,不过位置要注意不要乱了。

// the data has been read to (buf, len)
typedef std::function<void (const TcpConnectionPtr&,
                            Buffer*,
                            Timestamp)> MessageCallback;

这个回调函数需要的参数就比较多了,不过也合理。

什么是回调?。。。
观察者模式。


//通过msgid获取业务回调,进行网络模块和任务模块之间的解耦合
auto msgHandler = ChatService::instance()->getHandle(js["msgid"].get<int>());
    
//回调消息绑定好的事件处理器,执行相应的业务处理
msgHandler(conn,js,time);

//成功解耦

这一段就等业务层里面在看吧。

虽然好一段时间没有看设计模式了,不过 “松耦合,高内聚” 的思想还是深入我心的。

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。