chat集群聊天室项目 代码+讲解（一）：网络模块

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

#include

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());

//回调消息绑定好的事件处理器，执行相应的业务处理

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 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());

//回调消息绑定好的事件处理器，执行相应的业务处理

msgHandler(conn,js,time);

//成功解耦

这一段就等业务层里面在看吧。
虽然好一段时间没有看设计模式了，不过 “松耦合，高内聚” 的思想还是深入我心的。

最后

自我介绍一下，小编13年上海交大毕业，曾经在小公司待过，也去过华为、OPPO等大厂，18年进入阿里一直到现在。

深知大多数Java工程师，想要提升技能，往往是自己摸索成长，自己不成体系的自学效果低效漫长且无助。

因此收集整理了一份《2024年Java开发全套学习资料》，初衷也很简单，就是希望能够帮助到想自学提升又不知道该从何学起的朋友，同时减轻大家的负担。

既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上Java开发知识点，不论你是刚入门Java开发的新手，还是希望在技术上不断提升的资深开发者，这些资料都将为你打开新的学习之门！

如果你觉得这些内容对你有帮助，需要这份全套学习资料的朋友可以戳我获取！！

由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且会持续更新！
链图片转存中…(img-V9XyAri1-1715623902780)]

既有适合小白学习的零基础资料，也有适合3年以上经验的小伙伴深入学习提升的进阶课程，基本涵盖了95%以上Java开发知识点，不论你是刚入门Java开发的新手，还是希望在技术上不断提升的资深开发者，这些资料都将为你打开新的学习之门！

如果你觉得这些内容对你有帮助，需要这份全套学习资料的朋友可以戳我获取！！

由于文件比较大，这里只是将部分目录截图出来，每个节点里面都包含大厂面经、学习笔记、源码讲义、实战项目、讲解视频，并且会持续更新！