关键词:
放码过去
多余的废话就不多说了,直接放码上来吧。
网络层代码
chatserver.hpp,位于include/server目录下、
#ifndef CHATSERVER_H_
#define CHATSERVER_H_
#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); //消息回调
;
#endif
chatserver.cpp,位于 src/server下
#include "chatserver.hpp"
#include <functional>
#include <string>
#include "chatservice.hpp"
#include "json.hpp"
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()) //用户断开连接
conn->shutdown();
一切尽在不言中。
业务层代码
chatservice.hpp,位于include/server下
#ifndef CHATSERVICE_H_
#define CHATSERVICE_H_
#include<muduo/net/TcpConnection.h>
#include<unordered_map>
#include<functional>
#include "json.hpp"
using json = nlohmann::json;
using namespace std;
using namespace muduo;
using namespace muduo::net;
//处理消息的事件回调方法类型
using MsgHandler = std::function<void(const TcpConnectionPtr &conn,json &js,Timestamp time)>;
//聊天服务器业务
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 getHandle(int msgid);
private:
ChatService();
//存储消息id和对应的处理方法
unordered_map<int,MsgHandler> _msgHanderMap;
;
#endif
public.hpp,一个客户端和服务端公用的头,那就放在include下吧,存储各种状态
#ifndef PUBLIC_H
#define PUBLIC_H
enum EnMsgType
LOGIN_TYPE = 1, //正常登录
REG_TYPE //正常注册
;
#endif
chatserver.cpp,置于src/server之下:
#include"chatservice.hpp"
#include"public.hpp"
#include<string>
#include<muduo/base/Logging.h>
using namespace std;
using namespace muduo;
ChatService* ChatService::instance()
static ChatService service;
return &service;
//注册消息以及对应的回调操作
ChatService::ChatService()
_msgHanderMap.insert(LOGIN_TYPE,std::bind(&ChatService::login,this,_1,_2,_3));
_msgHanderMap.insert(REG_TYPE,std::bind(&ChatService::reg,this,_1,_2,_3));
//获取存储消息id和对应的处理方法
MsgHandler ChatService::getHandle(int msgid)
//日志记录
auto it = _msgHanderMap.find(msgid);
if(it == _msgHanderMap.end())
//返回一个lambda表达式,返回一个默认的空处理器,防止业务挂掉,后可做平滑升级处理
return [=](const TcpConnectionPtr &conn,json &js,Timestamp time)
LOG_ERROR<<"msgid:"<<msgid<<"can not find handle!";
;
else
return _msgHanderMap[msgid];
void ChatService::login(const TcpConnectionPtr &conn,json &js,Timestamp time)
LOG_INFO<<"login";
void ChatService::reg(const TcpConnectionPtr &conn,json &js,Timestamp time)
LOG_INFO<<"regist";
主函数
main.cpp,放在src/server之下:
#include<iostream>
#include "chatserver.hpp"
using namespace std;
int main()
EventLoop loop;
InetAddress addr("127.0.0.lsof -i :8083 1234561",7000);
ChatServer server(&loop,addr,"ChatServer");
server.start();
loop.loop();
return 0;
CMake
这里记得将 json.hpp 放置在 thirdparty之下。
最外层的 CMake文件进行一波修改,然后建议写一个运行的 shell 脚本
cmake_minimum_required(VERSION 3.0) # 最低版本
project(main) # 给这个工程一个名字,这不是可执行文件的名字,是工程的名字
# 设置编译选项,不知道最后能不能过
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/json_test)
# 加载子目录
add_subdirectory(src)
运行脚本
以前从没写过,抱着试一试的心态,就很简单,五分钟写一个。
命令:
su root //要有root权限
cd CHAT //自己想办法进去
touch mk.sh
chmod 757 mk.sh
vim mk.sh
i
mk.sh:
#!/bin/sh
rm -rf build/* bin/*
cd build
cmake ..
make
继续命令:
esc
:
wq
回车
# 此刻已经退出vim
./mk.sh
一猜就是这么用的。
c++搭建集群聊天室:登录与注册(代码片段)
前面准备了那么多,这里就直接是水到渠成了。该讲的前面都讲的差不多了,剩下还没讲的都在代码里面。不过由于文档Telnet一直是发送不了数据的状态,就一直没法进一步的测试,等后面写了客户端再说。chatser... 查看详情
c++搭建集群聊天室:登录与注册(代码片段)
前面准备了那么多,这里就直接是水到渠成了。该讲的前面都讲的差不多了,剩下还没讲的都在代码里面。不过由于文档Telnet一直是发送不了数据的状态,就一直没法进一步的测试,等后面写了客户端再说。chatser... 查看详情
c++搭建集群聊天室:muduo网络库(代码片段)
文章目录简介与建议网络服务器编程常用模型muduo的reactor模型muduo库网络编程示例cmake编译简介与建议muduo网络库的编程很容易,要实现基于muduo网络库的服务器和客户端程序,只需要简单的组合TcpServer和TcpClient就可以。所... 查看详情
c++搭建集群聊天室:muduo网络库(代码片段)
文章目录简介与建议网络服务器编程常用模型muduo的reactor模型muduo库网络编程示例cmake编译简介与建议muduo网络库的编程很容易,要实现基于muduo网络库的服务器和客户端程序,只需要简单的组合TcpServer和TcpClient就可以。所... 查看详情
c++搭建集群聊天室:安装muduo网络库(代码片段)
文章目录资源下载安装过程测试muduo是否安装成功资源下载提取码:fid9常规操作啦,前面两三篇都是环境搭建。muduo网络库我就不多做介绍了,一个基于reactor反应堆模型的多线程C++网络库,陈硕大神的作品,... 查看详情
c++搭建集群聊天室:安装muduo网络库(代码片段)
文章目录资源下载安装过程测试muduo是否安装成功资源下载提取码:fid9常规操作啦,前面两三篇都是环境搭建。muduo网络库我就不多做介绍了,一个基于reactor反应堆模型的多线程C++网络库,陈硕大神的作品,... 查看详情
c++搭建集群聊天室(十八):nginx+redis发布订阅升级项目为集群服务器(代码片段)
...中获取订阅的消息环境配置与基本知识C++搭建集群聊天室(十七):ngnix简介及tcp负载均衡配置Redis环境搭建与配置hiredis从安装到实操,一条龙服务redis事务处理机制,但当涉猎了解更多red 查看详情
c++搭建集群聊天室(十八):nginx+redis发布订阅升级项目为集群服务器(代码片段)
...中获取订阅的消息环境配置与基本知识C++搭建集群聊天室(十七):ngnix简介及tcp负载均衡配置Redis环境搭建与配置hiredis从安装到实操,一条龙服务redis事务处理机制,但当涉猎了解更多red 查看详情
c++搭建集群聊天室:客户端||服务器异常退出解决方案(代码片段)
文章目录客户端异常退出服务端异常退出客户端异常退出此前我们对客户端退出的操作仅仅就是将连接释放掉,但是既然加入了新的业务,受业务影响,客户端的退出就不能是这么简单的处理了。打开chatserver.cpp,... 查看详情
c++搭建集群聊天室:客户端||服务器异常退出解决方案(代码片段)
文章目录客户端异常退出服务端异常退出客户端异常退出此前我们对客户端退出的操作仅仅就是将连接释放掉,但是既然加入了新的业务,受业务影响,客户端的退出就不能是这么简单的处理了。打开chatserver.cpp,... 查看详情
chat集群聊天室项目代码+讲解:映射层+持久层(代码片段)
文章目录项目简单架构图db代码讲解这里为什么不用单例?代码代码讲解数据库操作的时候为什么不上锁?项目简单架构图db代码#pragma#include<string>#include<mysql/mysql.h>#include<muduo/base/Logging.h>usingnamespacestd;//数据... 查看详情
chat集群聊天室项目代码+讲解:映射层+持久层(代码片段)
文章目录项目简单架构图db代码讲解这里为什么不用单例?代码代码讲解数据库操作的时候为什么不上锁?项目简单架构图db代码#pragma#include<string>#include<mysql/mysql.h>#include<muduo/base/Logging.h>usingnamespacestd;//数据... 查看详情
c++搭建集群聊天室(十六):代码测试文档(代码片段)
既然客户端都发出来了,总得开始测试一下了,虽然说在整集群,两手抓嘛。测出来一些问题,还有不少问题潜在着。持续更新中文章目录bug1:bug2bug3(待解决)bug4bug5bug1:bug:登录、测试皆失... 查看详情
c++搭建集群聊天室(十六):代码测试文档(代码片段)
既然客户端都发出来了,总得开始测试一下了,虽然说在整集群,两手抓嘛。测出来一些问题,还有不少问题潜在着。持续更新中文章目录bug1:bug2bug3(待解决)bug4bug5bug1:bug:登录、测试皆失... 查看详情
c++搭建集群聊天室:json序列化与反序列化(代码片段)
文章目录玩转json什么是jsonPython中的Json模块获取json中的某个数据json.hpp文件获取序列化实操反序列化代码实操CMake编译最初接触到Json,还是在Python的爬虫里面。玩转json什么是jsonJson是一种轻量级的数据交换格式,具有数... 查看详情
c++搭建集群聊天室:json序列化与反序列化(代码片段)
文章目录玩转json什么是jsonPython中的Json模块获取json中的某个数据json.hpp文件获取序列化实操反序列化代码实操CMake编译最初接触到Json,还是在Python的爬虫里面。玩转json什么是jsonJson是一种轻量级的数据交换格式,具有数... 查看详情
c++搭建集群聊天室:用户单聊及离线消息处理功能实现(代码片段)
单聊单聊功能其实很简单的,就是数据包的发送,接收。public.h现状:#ifndefPUBLIC_H_#definePUBLIC_H_enumEnMsgTypeLOGIN_TYPE=1,//正常登录LOGIN_MSG_ACK,//登录相应消息REG_TYPE,//正常注册REG_MSG_ACK,//注册相应消息ONE_CHAT_MSG,//一对 查看详情
c++搭建集群聊天室:用户单聊及离线消息处理功能实现(代码片段)
单聊单聊功能其实很简单的,就是数据包的发送,接收。public.h现状:#ifndefPUBLIC_H_#definePUBLIC_H_enumEnMsgTypeLOGIN_TYPE=1,//正常登录LOGIN_MSG_ACK,//登录相应消息REG_TYPE,//正常注册REG_MSG_ACK,//注册相应消息ONE_CHAT_MSG,//一对 查看详情