C++项目——集群聊天服务器项目(五)网络模块与业务模块

news2024/11/15 18:26:53

今天来正式书写集群聊天服务器网络模块与部分业务模块的代码

环境搭建C++项目——集群聊天服务器项目(一)项目介绍、环境搭建、Boost库安装、Muduo库安装、Linux与vscode配置-CSDN博客

Json第三方库

muduo网络库

MySQL数据库

一、工程目录创建

项目通过CMake编译，书写CMakeLists.txt文件，分别书写三级，从项目目录中一级一级往下找

（1）项目根目录下CHAT

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)

（2）子目录src中

add_subdirectory(server)

（3）src目录中server目录


#定义了一个SRC_LIST变量，包含了该目录下的所有源文件
aux_source_directory(. SRC_LIST)

# 指定生成可执行文件
add_executable(ChatServer ${SRC_LIST})
# 指定可执行文件链接时需要依赖的库文件
target_link_libraries(ChatServer muduo_net muduo_base pthread)

二、网络模块代码编写

同前述集群聊天服务器项目(三)中服务器代码步骤一致，即

1.组合TcpServer对象

2.创建EventLoop事件循环对象的指针

3.明确TcpServer构造函数需要什么参数，输出ChatServer的构造函数

4.在当前服务器类的构造函数中，注册处理连接和读写事件的回调函数

5.设置合适的服务端线程数量，muduo会自动划分I/O线程和worker线程

由于是项目编写，因此将头文件与源文件区分开

在项目根目录/include/server下编写chatserver.hpp头文件

#ifndef CHATSERVER_H
#define CHATSERBER_H

#include <muduo/net/EventLoop.h>
#include <muduo/net/TcpServer.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));//绑定器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);
}

在这里，网络模块与业务模块彻底解耦

msgHandler是事件处理器，定义在业务模块，通过js["msgid"] 获取=》业务handler处理器（在业务模块事先绑定好的）=》conn  js  time

三、业务模块代码编写

目前先暂且编写登录和注册回调函数测试程序是否正常运转，后续进行完善

在项目根目录/include/server下编写chatservice.hpp头文件

定义聊天服务器业务类对象，绑定相应的事件回调函数，由于只需要一个构造函数，进行单例化操作

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/server下编写public.hpp头文件

public.hpp

#ifndef PUBLIC_H
#define PUBLIC_H

/*
    Server 和 Client 的 公共文件
*/
enum enMsgType{
    LOGIN_MSG = 1,//登录消息
    REG_MSG, //注册消息
};


#endif

相应的，在项目根目录/src/server下编写chatservice.cpp源文件

在服务器业务类将事件处理函数与枚举量插入定义的容器中，以便后续通过msgid进行索引

#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!!!";
}

登录和注册业务仅打印日志信息

四、main函数

#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;
}

五、功能测试

监听127.0.0.1 6000端口

可以看到msgid为1时，触发登录回调函数、msgid为2时，触发注册回调函数，由于msgid为3时没有定义，在哈希表中查不到相应的值，打印：找不到相应的处理器，返回空处理对象

功能验证成功！

如果有错误还请联系我，请期待后续的项目更新吧~感谢~

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

C语言例4-2：判断某些字符型变量中存放的是否为大写字母或数字字符。

C语言例4-2：判断某些字符型变量中存放的是否为大写字母或数字字符。

代码如下&#xff1a; //判断某些字符型变量中存放的是否为大写字母或数字字符。 #include<stdio.h> int main(void) {int x1, x2, x3, x4; //数据定义语句char c1a, c2B, c31, c4!; //数据定义语句x1c1>A&&c1<Z; //表达式判断c1是否…
阅读更多...
安卓studio连接手机之后，一两秒之后就自动断开了。问题解决。

安卓studio连接手机之后，一两秒之后就自动断开了。问题解决。

太坑了&#xff0c;安卓studio链接手机之后。几秒之后就断开了。我以为是adb的问题&#xff0c;就重新安装了一下adb。并且在环境变量中配置了Path的路径。然而并没有什么用啊。 经过排查原来是数据心虚了。线的接触不良。导致你刚接通的瞬间有相对较强的电流是因为有瞬间高电压…
阅读更多...
精酿啤酒：酿造工艺的细节与品质的关联

精酿啤酒：酿造工艺的细节与品质的关联

啤酒的酿造工艺是一个复杂而精细的过程&#xff0c;每一个环节都可能影响的品质和口感。Fendi Club啤酒作为一家注重品质和口感的品牌&#xff0c;在酿造工艺的细节方面有着严格的要求和杰出的技艺。 原料的选择是决定啤酒品质的重要因素之一。Fendi Club啤酒选用上好的大麦、水…
阅读更多...
【日常记录】【CSS】css实现汉堡菜单

【日常记录】【CSS】css实现汉堡菜单

文章目录 1、介绍2、布局3、鼠标移入变成 X 1、介绍 在移动端或者响应式中&#xff0c;可能会遇到 三个横线 鼠标移动到的时候&#xff0c;会变成 一个 X 符号&#xff0c;这个就是汉堡菜单 2、布局 <style>* {margin: 0;padding: 0;box-sizing: border-box;}body {displ…
阅读更多...
ros找不到生成的可执行文件[rosrun] Couldn‘t find executable named hello_world_cpp below

ros找不到生成的可执行文件[rosrun] Couldn‘t find executable named hello_world_cpp below

catkin_make之后source ./devel/setup.bash source之后运行节点的时候,ros找不到可执行文件&#xff08;其实tab键补不齐就没找到了&#xff09; 手动查找发现生成的可执行文件在build下不在devel/lib下&#xff0c;所以白source&#xff0c;压根找不到。 查找原因说是因为CMa…
阅读更多...
基于 C++ STL 的图书管理系统213行

基于 C++ STL 的图书管理系统213行

定制魏&#xff1a;QTWZPW&#xff0c;获取更多源码等 目录 一、实践项目名称 二、实践目的 三、实践要求 四、实践内容 五、代码框架参考 六、代码效果展示 七、完整代码主函数展示 一、实践项目名称 基于 C STL 的图书管理系统 二、实践目的 通过设计和实现一个基于…
阅读更多...
NAT---网络地址转换技术

NAT---网络地址转换技术

Network Address Translation 1、起源&#xff1a;ip地址不够用 2、作用&#xff1a;让私网地址映射成公网地址&#xff0c;进而访问网络。 3、私网Ip地址的范围&#xff1a; A类&#xff1a;10.0.0.0-10.255.255.255 B类&#xff1a;172.16.0.0-172.31.255.255 C类&…
阅读更多...
【八股】Java 线程状态转化

【八股】Java 线程状态转化

线程一共有六种状态 1. NEW - 新建 public static void main(String[] args) throws ExecutionException, InterruptedException {Thread t new Thread(() -> {System.out.println("running");}, "t1");System.out.println(t.getState()); // 线程创…
阅读更多...
【MySQL系列】Public Key Retrieval is not allowed

【MySQL系列】Public Key Retrieval is not allowed

&#x1f49d;&#x1f49d;&#x1f49d;欢迎来到我的博客&#xff0c;很高兴能够在这里和您见面&#xff01;希望您在这里可以感受到一份轻松愉快的氛围&#xff0c;不仅可以获得有趣的内容和知识&#xff0c;也可以畅所欲言、分享您的想法和见解。 推荐:kwan 的首页,持续学…
阅读更多...
简单学习下MQTT（2）

简单学习下MQTT（2）

MQTT 简介 MQTT 是非常简单的协议&#xff0c;最初由 IBM 的两位工程师 Andy Stanford-Clark 以及 Arlen Nipper 在 1999 年为监控输油管道设计的。它被设计的场景就是有限的带宽、轻量级以及很小的耗电量&#xff0c;在那个时候&#xff0c;卫星宽带就是那么小&#xff0c;且…
阅读更多...
RPA使用Native Messaging 协议实现浏览器自动化

RPA使用Native Messaging 协议实现浏览器自动化

RPA 即机器人流程自动化&#xff0c;是一种利用软件机器人或人工智能来自动化业务流程中规则性、重复性任务的技术。RPA 技术可以模拟和执行人类在计算机上的交互操作&#xff0c;从而实现自动化处理数据、处理交易、触发通知等任务。帮助企业或个人实现业务流程的自动化和优化…
阅读更多...
基于ssm的医院住院管理系统论文

基于ssm的医院住院管理系统论文

摘 要 随着时代的发展&#xff0c;医疗设备愈来愈完善&#xff0c;医院也变成人们生活中必不可少的场所。如今&#xff0c;已经2021年了&#xff0c;虽然医院的数量和设备愈加完善&#xff0c;但是老龄人口也越来越多。在如此大的人口压力下&#xff0c;医院住院就变成了一个问…
阅读更多...
计算机软考初级含金量高吗？

计算机软考初级含金量高吗？

并不是说软考初级就没有含金量&#xff0c;对于想评初级职称的考生来说还是很有用处的。根据 国人部 发[2003]39号&#xff1a;通过考试获得证书的人员&#xff0c;表明其已具备从事相应专业岗位工作的水平和能力&#xff0c;用人单位可根据工作需要从获得证书的人员中择优聘任…
阅读更多...
技术复盘:Flash Memory揭秘(1)

技术复盘:Flash Memory揭秘(1)

目录 1.Flash基本原理概述 1.1 Non-volatile Memory的分类 1.2 Flash编程\擦除原理 2.小结 1.Flash基本原理概述 1.1 Non-volatile Memory的分类 Flash在嵌入式领域是非常重要的角色&#xff0c;主要用于存储数据代码&#xff0c;为代码的执行提供基础保证等。 实际上&a…
阅读更多...
marvelous designer打开发现gizmo(变换控制器）只有一个方向上有面控制器，缺另外两个面控制器

marvelous designer打开发现gizmo(变换控制器）只有一个方向上有面控制器，缺另外两个面控制器

出现这种问题&#xff0c;其实是因为选中了屏幕坐标系 在3D界面下空白处点右键&#xff0c;选择gizmo&#xff0c;然后选择屏幕坐标系之外别的选项就能恢复到常规有多个面的控制器。
阅读更多...
不能从所选图层建立3d模型--模大狮模型网

不能从所选图层建立3d模型--模大狮模型网

在Revit中&#xff0c;从所选图层直接创建3D模型并不是一个常规的操作方式。通常情况下&#xff0c;你需要手动创建文字或者图形&#xff0c;然后将其转换为3D模型。 如果你有一个平面上的文字或图形&#xff0c;想要将其转换为3D模型&#xff0c;你可以使用以下步骤&#xff1…
阅读更多...
【包远程安装运行】SpringBoot+Mysql实现的美食分享菜谱制作平台+演示视频+开发文档(论文模板)

【包远程安装运行】SpringBoot+Mysql实现的美食分享菜谱制作平台+演示视频+开发文档(论文模板)

今天发布的是由【猿来入此】的优秀学员独立做的一个基于springboot脚手架的美食分享菜谱制作平台系统&#xff0c;该系统分为前台和后台&#xff0c;多用户分享平台。主要实现了 除脚手架功能以外下面是系统的功能&#xff1a; 前台普通用户&#xff1a;注册、登录、首页、美食…
阅读更多...
波奇学Linux：网络接口

波奇学Linux：网络接口

127.0.0.1本地回环ip&#xff0c;用于本地测试&#xff0c;不会进行网络通信 TCP是面向连接的&#xff0c;服务器比较被动 需要服套接字监听 listen状态 正常通信默认会进行主机序列和网络序列的转换 TcpServer.cc #pragma once#include<iostream> #include<string…
阅读更多...
6、运行时数据区

6、运行时数据区

Java虚拟机在运行Java程序过程中管理的内存区域&#xff0c;称之为运行时数据区。《Java虚拟机规范》中规定了每一部分的作用。 3.1 程序计数器 程序计数器&#xff08;Program Counter Register&#xff09;也叫PC寄存器&#xff0c;每个线程会通过程序计数器记录当前要执行的…
阅读更多...
海外舆情监控的重要性以及云手机的推荐

海外舆情监控的重要性以及云手机的推荐

海外市场不仅有着无尽的商机&#xff0c;同时也存在着各种各样的挑战。例如&#xff0c;海外市场舆情的复杂变化给企业带来了潜在风险&#xff0c;尤其在新媒体技术快速发展的时代&#xff0c;舆论对企业品牌形象的影响日益巨大。本文将详细探讨海外舆情监控的重要性以及为大家…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023