集群聊天服务器项目【C++】（五）网络模块和业务模块

经过前面介绍相关的库和工具，比如Json、CMake、muduo等，我们可以开始编写本项目的代码了。

1.项目目录创建

一般一个项目由以下结构组成：
在这里插入图片描述

  1. bin文件夹存放：可执行程序
  2. build文件夹存放：编译过程中的临时文件
  3. include文件夹存放：头文件
  4. src文件夹存放：源代码
  5. test文件夹存放：测试用例，我们前面几章的测试代码就在这
  6. thirdparty文件夹存放：使用的别人的源代码，本项目使用了Json库
  7. CMakeLists.txt存放：CMake编译的文件夹，在 需要编译的目录都有一个
  8. autobuild.sh存放：编译的自动脚本
  9. README.md存放：项目的介绍，比如环境配置、编译、运行。

接下来介绍每一级目录的CMakeLists.txt文件的内容：

  1. 项目根目录下：
cmake_minimum_required(VERSION 3.0)
project(chat)# 配置编译选项
set(CMAKE_CXX_FLAGS ${CMAKE_CXX_FLAGS} -g)# 配置最终的可执行文件输出的路径
set(EXECUTABLE_OUTPUT_PATH ${PROJECT_SOURCE_DIR}/bin)# 配置头文件的搜索路径
include_directories(${PROJECT_SOURCE_DIR}/include)
include_directories(${PROJECT_SOURCE_DIR}/include/server)
include_directories(${PROJECT_SOURCE_DIR}/thirdparty)# 加载子目录
add_subdirectory(src)
  1. 在子目录src中：
add_subdirectory(server)  ##加载子目录
  1. 在server文件夹中：
#定义了一个SRC_LIST变量，包含了该目录下的所有源文件
aux_source_directory(. SRC_LIST)# 指定生成可执行文件
add_executable(ChatServer ${SRC_LIST})
# 指定可执行文件链接时需要依赖的库文件
target_link_libraries(ChatServer muduo_net muduo_base pthread)

2.网络模块代码ChatServer

这部分代码和muduo库介绍相似：muduo库简单介绍,本次会更详细介绍。
这次把实现放到.cpp中，声明放到.hpp中。
先看整体代码：
在include/server/中编写chatserver.hpp：

#ifndef CHATSERVER_H
#define CHATSERVER_H#include <muduo/net/TcpServer.h>
#include <muduo/net/EventLoop.h>
using namespace muduo;
using namespace muduo::net;// 聊天服务器的主类
class ChatServer
{
public:// 初始化聊天服务器对象ChatServer(EventLoop *loop,const InetAddress &listenAddr,const string &nameArg);// 启动服务void start();private:// 上报链接相关信息的回调函数void onConnection(const TcpConnectionPtr &);// 上报读写事件相关信息的回调函数void onMessage(const TcpConnectionPtr &,Buffer *,Timestamp);TcpServer _server; // 组合的muduo库，实现服务器功能的类对象EventLoop *_loop;  // 指向事件循环对象的指针
};#endif

在/src/server/中实现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));// 注册消息回调_server.setMessageCallback(std::bind(&ChatServer::onMessage, this, _1, _2, _3));// 设置线程数量_server.setThreadNum(4);
}// 启动服务
void ChatServer::start()
{_server.start();
}// 上报链接相关信息的回调函数
void ChatServer::onConnection(const TcpConnectionPtr &conn)
{// 客户端断开链接if (!conn->connected()){ChatService::instance()->clientCloseException(conn);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  timeauto msgHandler = ChatService::instance()->getHandler(js["msgid"].get<int>());//Json的数据类型转换到int型// 回调消息绑定好的事件处理器，来执行相应的业务处理msgHandler(conn, js, time);
}

接下来介绍为什么这样写：
首先TcpServer这个类，它在muduo/net/TcpServer.h下声明，它用来编写网络服务器，接受客户机链接。

  1. 它只有一个构造函数：
  TcpServer(EventLoop* loop,const InetAddress& listenAddr,const string& nameArg,Option option = kNoReusePort);
  1. 它有一个start()函数，用来启动服务,开始监听新客户链接。
void ChatServer::start()
{_server.start();
}
  1. 针对不同的事件，TcpServer 保存着不同事件发生时要调用的回调函数，比如接收到链接的回调函数，和接收到消息的回调函数：
  void setConnectionCallback(const ConnectionCallback& cb){ connectionCallback_ = cb; }void setMessageCallback(const MessageCallback& cb){ messageCallback_ = cb; }void setWriteCompleteCallback(const WriteCompleteCallback& cb){ writeCompleteCallback_ = cb; }
  1. TcpServer网络模块需要我们设置线程数量，如果大于1，会自动1个主线程监听新客户链接，其余处理已连接的消息处理。
_server.setThreadNum(4);

因此我们的链接处理函数和消息处理函数如下：

    // 上报链接相关信息的回调函数void onConnection(const TcpConnectionPtr &);// 上报读写事件相关信息的回调函数void onMessage(const TcpConnectionPtr &,Buffer *,Timestamp);

然后注册消息回调和链接回调：

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

其中ChatServer::onConnection和ChatServer::onMessage就是需要我们写的回调函数，在这实现

// 上报链接相关信息的回调函数
void ChatServer::onConnection(const TcpConnectionPtr &conn)
{// 客户端断开链接if (!conn->connected()){ChatService::instance()->clientCloseException(conn);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  timeauto msgHandler = ChatService::instance()->getHandler(js["msgid"].get<int>());// 回调消息绑定好的事件处理器，来执行相应的业务处理msgHandler(conn, js, time);
}

这样当 ChatServer 接收到连接相关事件时，会调用我们写的ChatServer::onConnection函数。如果是客户端连接断开的事件，我们会关闭连接。

3.业务模块代码ChatService

对于ChatServer::onMessage实现中，我们不能根据对应的消息就使用对应的处理方法，比如

if (message == Login) { //登录消息LoginHandler();
} else if (message == Register) {  //注册消息RegisterHandler();
} else if (...)

这样就相当与网络模块代码中间包含了业务模块代码。我们希望模块解耦，每个模块之间应该是独立的。我们希望实现一个统一的调用，对于任何业务都只用调用一个方法即可，然后这个函数会有着不同的实现。

因此，我们还会创建一个 ChatService 类来专门提供不同的服务，ChatService使用function容易保存不同的回调函数，我们使用 Json 解析数据时得到数据类型，然后直接调用对应的函数（这些回调函数最开始已经被注册过了），既不同的数据类型调用不同的回调函数。

在include/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

在include/中定义一个枚举类型，用来回调对应的业务方法。
在include/public.hpp编写头文件:

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

在include/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!!!";
}

使用单例模式保证只有一个实例化对象，在_msgHandlerMap存放id和对应的业务函数，在构造函数中完成的注册。

4.main函数编写

在src/server/中编写main.cpp

#include "chatserver.hpp"int main(){EventLoop loop;InetAddress addr("127.0.0.1",6000);ChatServer server(&loop,addr,"ChatServer");server.start();loop.loop();return 0;
}

总结

这是本项目的关键一章，网络模块怎么使用回调函数完成新链接和消息的回调，以及怎么解耦网络模块和业务模块等，在后面章节，大部分只是在此基础上增加业务功能，网络模块就不需要改了。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.rhkb.cn/news/425462.html

如若内容造成侵权/违法违规/事实不符，请联系长河编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

电子竞技信息交流平台|基于java的电子竞技信息交流平台系统小程序(源码+数据库+文档)

电子竞技信息交流平台|基于java的电子竞技信息交流平台系统小程序(源码+数据库+文档)

电子竞技信息交流平台系统小程序 目录 基于java的电子竞技信息交流平台系统小程序 一、前言 二、系统设计 三、系统功能设计 四、数据库设计 五、核心代码 六、论文参考 七、最新计算机毕设选题推荐 八、源码获取&#xff1a; 博主介绍&#xff1a;✌️大厂码农|毕设…
阅读更多...
“拍照赚钱”的任务定价（2017数学建模国赛b题）

“拍照赚钱”的任务定价（2017数学建模国赛b题）

文章目录 题目说明解题思路第一问第二问第三问第四问 部分结果图项目地址 题目 赛题地址 说明 数模国赛前的练手题。其实我个人感觉这道题很散&#xff0c;都是找一些规律进行总结统计&#xff0c;最多结合一些机器学习算法进行预测拟合之类的我刚开始用matlab&#xff0c;后…
阅读更多...
【演化博弈论】：双方演化博弈的原理与过程

【演化博弈论】：双方演化博弈的原理与过程

目录 一、演化博弈的原理1. 基本概念2. 参与者的策略3.演化过程 二、MATLAB 代码解读&#xff08;博弈参与主体&#xff08;双方&#xff09;策略选择的动态演化讨程&#xff09;三、MATLAB 代码解读&#xff08;博弈主体随着时间策略选择的动态演化讨程&#xff09;四、结论 演…
阅读更多...
Java 枚举 新特性

Java 枚举 新特性

Java 枚举&#xff08;enum&#xff09;自JDK 1.5引入以来&#xff0c;随着版本的升级不断增强。本文将回顾枚举的演进&#xff0c;尤其是结合switch语句的应用&#xff0c;展示枚举如何在现代Java中变得更加灵活。 1. JDK 1.5&#xff1a;Java 枚举的诞生 在JDK 1.5之前&…
阅读更多...
TAG：BladeLLM 的纯异步推理架构

TAG：BladeLLM 的纯异步推理架构

作者&#xff1a;张子鹏 PAI引擎团队 随着 GQA/MLA/MoE 等模型结构不断发展&#xff0c;大语言模型的推理逐步解除了显存限制&#xff0c;逐渐向着高并发、高吞吐的方向发展。推理引擎的运行时开销也变得不可忽视。主流 LLM 推理框架的运行时开销大致来自&#xff1a; Python …
阅读更多...
黑马十天精通MySQL知识点

黑马十天精通MySQL知识点

一. MySQL概述 安装使用 MySQL安装完成之后&#xff0c;在系统启动时&#xff0c;会自动启动MySQL服务&#xff0c;无需手动启动。 也可以手动的通过指令启动停止&#xff0c;以管理员身份运行cmd&#xff0c;进入命令行执行如下指令&#xff1a; 1 、 net start mysql80…
阅读更多...
Excel图片批量插入单元格排版处理插件【图片大师】

Excel图片批量插入单元格排版处理插件【图片大师】

为了方便大家在图片的插入排版的重复工作中解放出来&#xff0c;最近发布了一款批量插入图片的插件&#xff0c;欢迎大家下载&#xff0c;免费试用。 这是图片的文件夹&#xff1a; 主要功能如下: 1&#xff0c;匹配单元格名称的多张图批量插入到一个单元格 该功能支持设置图…
阅读更多...
学LabVIEW编程，看编程书有些看不懂怎么办？

学LabVIEW编程，看编程书有些看不懂怎么办？

自学LabVIEW编程时&#xff0c;如果发现编程书籍内容难以理解&#xff0c;可以尝试以下几种方式来提高学习效果&#xff1a; 1. 从基础入手&#xff0c;逐步深入&#xff1a; LabVIEW是一种基于图形化编程的工具&#xff0c;不同于传统的编程语言&#xff0c;因此从基础概念开…
阅读更多...
尤雨溪推荐的拖拽插件，支持Vue2/Vue3 VueDraggablePlus

尤雨溪推荐的拖拽插件，支持Vue2/Vue3 VueDraggablePlus

大家好，我是「前端实验室」爱分享的了不起~ 今天在网上看到尤雨溪推荐的这款拖拽组件，试了一下非常不错，这里推荐给大家。 说到拖拽工具库，非大名鼎鼎的的 Sortablejs 莫属。它是前端领域比较知名的，且功能强大的工具。但我们直接使用Sortablejs的情况很少，一般都是使用…
阅读更多...
【Redis】之Geo

【Redis】之Geo

概述 Geo就是Geolocation的简写形式&#xff0c;代表地理坐标。在Redis中&#xff0c;构造了能够存储地址坐标信息的一种数据结构&#xff0c;帮助我们根据经纬度来检索数据。 命令行操作方法 GEOADD 可以用来添加一个或者多个地理坐标。 GEODIST 返回一个key中两个成员之…
阅读更多...
【专题】2024跨境出海供应链洞察-更先进供应链报告合集PDF分享（附原数据表）

【专题】2024跨境出海供应链洞察-更先进供应链报告合集PDF分享（附原数据表）

原文链接&#xff1a;https://tecdat.cn/?p37665 当前&#xff0c;全球化商业浪潮促使跨境电商行业飞速发展&#xff0c;产业带与跨境电商接轨、平台半托管模式涌现、社交电商带来红利机会以及海外仓不断扩张&#xff0c;这使得产业带外贸工厂、内贸工厂、传统进出口企业和品…
阅读更多...
自制一键杀死端口进程程序# tomcat 如何杀死tomcat进程

自制一键杀死端口进程程序# tomcat 如何杀死tomcat进程

直接cmd 窗口执行如下命令即可 netstat -ano | findstr :8080 taskkill /F /PID <PID>简简单单的两个指令,总是记不住,也懒的记, 每次端口冲突的时候, 都是直接查百度,很苦逼, 如果有一个程序,直接输入端口号,点击按钮直接杀死进程,岂不爽歪歪. 跟我一起制作一个屠猫的…
阅读更多...
【D3.js in Action 3 精译_022】3.2 使用 D3 完成数据准备工作

【D3.js in Action 3 精译_022】3.2 使用 D3 完成数据准备工作

当前内容所在位置 第一部分 D3.js 基础知识 第一章 D3.js 简介&#xff08;已完结&#xff09; 1.1 何为 D3.js&#xff1f;1.2 D3 生态系统——入门须知1.3 数据可视化最佳实践&#xff08;上&#xff09;1.3 数据可视化最佳实践&#xff08;下&#xff09;1.4 本章小结 第二章…
阅读更多...
【网络原理】❤️Tcp 常用机制❤️ —— 延时应答，捎带应答， 面向字节流， 异常情况处理。保姆式详解 ， 建议收藏 ！！！

【网络原理】❤️Tcp 常用机制❤️ —— 延时应答，捎带应答， 面向字节流， 异常情况处理。保姆式详解 ， 建议收藏 ！！！

本篇会加入个人的所谓鱼式疯言 ❤️❤️❤️鱼式疯言:❤️❤️❤️此疯言非彼疯言 而是理解过并总结出来通俗易懂的大白话, 小编会尽可能的在每个概念后插入鱼式疯言,帮助大家理解的. &#x1f92d;&#x1f92d;&#x1f92d;可能说的不是那么严谨.但小编初心是能让更多人…
阅读更多...
[数据集][目标检测]无人机识别检测数据集VOC+YOLO格式6986张1类别

[数据集][目标检测]无人机识别检测数据集VOC+YOLO格式6986张1类别

数据集格式&#xff1a;Pascal VOC格式YOLO格式(不包含分割路径的txt文件&#xff0c;仅仅包含jpg图片以及对应的VOC格式xml文件和yolo格式txt文件) 图片数量(jpg文件个数)&#xff1a;6986 标注数量(xml文件个数)&#xff1a;6986 标注数量(txt文件个数)&#xff1a;6986 标注…
阅读更多...
‌内网穿透技术‌总结

‌内网穿透技术‌总结

内网穿透是一种网络技术&#xff0c;通过它可以使外部网络用户访问内部网络中的设备和服务。一般情况下&#xff0c;内网是无法直接访问的&#xff0c;因为它位于一个封闭的局域网中&#xff0c;无法从外部访问。而通过内网穿透&#xff0c;可以将内部网络中的设备和服务暴露在…
阅读更多...
数据稀缺条件下的时间序列微分：符号回归(Symbolic Regression)方法介绍与Python示例

数据稀缺条件下的时间序列微分：符号回归(Symbolic Regression)方法介绍与Python示例

时间序列概况在日常生活和专业研究中都很常见。简而言之,时间序列概况是一系列连续的数据点 y(0), y(1), …, y(t) ,其中时间 t 的点依赖于时间 t-1 的前一个点(或更早的时间点)。 在许多应用中,研究者致力于预测时间序列概况的未来行为。存在各种建模方法。这些模型通常基于过…
阅读更多...
Unity让摄像机跟随物体的方法（不借助父子关系）

Unity让摄像机跟随物体的方法（不借助父子关系）

在Unity中&#xff0c;不使用子对象的方式让相机跟随物体移动&#xff0c;我们通过编写脚本来实现。下面放一个从工程中摘出来的的C#脚本示例&#xff0c;用于将相机绑定到一个Target对象上并跟随其移动&#xff1a; using UnityEngine; public class FollowCamera : MonoBeh…
阅读更多...
DPDK基础入门（十）：虚拟化

DPDK基础入门（十）：虚拟化

I/O虚拟化 全虚拟化&#xff1a;宿主机截获客户机对I/O设备的访问请求&#xff0c;然后通过软件模拟真实的硬件。这种方式对客户机而言非常透明&#xff0c;无需考虑底层硬件的情况&#xff0c;不需要修改操作系统。 半虚拟化&#xff1a;通过前端驱动/后端驱动模拟实现I/O虚拟…
阅读更多...
【STM32】CAN总线基础入门

【STM32】CAN总线基础入门

CAN总线基础入门 一、CAN简介二、主流通信协议对比三、CAN物理层1、CAN硬件电路2、CAN电平标准3、CAN收发器 – TJA1050&#xff08;高速CAN&#xff09;4、CAN物理层特性 四、帧格式1、CAN总线帧格式2、数据帧&#xff13;、数据帧各部分用途简介&#xff14;、数据帧的发展历…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023