C++搭建集群聊天室(八):網絡層代碼與業務層代碼(登錄注册)解耦

看,未來 2021-08-15 21:59:15 阅读数:544

本文一共[544]字,预计阅读时长:1分钟~
c++ 搭建 集群 群聊 聊天室

請添加圖片描述

放碼過去

多餘的廢話就不多說了,直接放碼上來吧。

網絡層代碼

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

一猜就是這麼用的。

版权声明:本文为[看,未來]所创,转载请带上原文链接,感谢。 https://gsmany.com/2021/08/20210815215911512E.html