Darlingの妙妙屋

C++项目 | 集群聊天服务器 | 添加好友业务添加好友后，每次用户登录会返回离线消息和好友列表 这里的添加好友功能就是单方面的，我只要通过你的id加上你，就是加上了，不用同意或者拒绝 1.数据库层的封装friend表： friendmodel.hpp 12345678910111213141516171819#ifndef FRIENDMODEL_H#define FRIENDMODEL_H#include<vector>#include"user.hpp"using namespace std;//维护好友信息的操作接口方法class FriendModel{public: //添加好友关系 void insert(int userid,int frinedid); //返回用户好友列表 每次下线更新，每次上线返回给用户 vector<User> query(int userid);}; ...

C++项目 | 集群聊天服务器 | 服务器异常退出本次主要处理服务器程序因为ctrl+c退出的异常，会将所有online的改为offline 1.main.cpp捕获ctrl+c信号，进行处理 12345678910111213141516171819202122232425#include"chatserver.hpp"#include"chatservice.hpp"#include<iostream>#include<signal.h>using namespace std;//处理器ctrl + c结束后，重置user 的状态信息，把登录变成未登录void resetHandler(int){ ChatService::instance()->reset(); exit(0);}int main(){ signal(SIGINT,resetHandler); EventLoop loop; InetAddress...

C++项目 | 集群聊天服务器 | 点对点聊天业务 && 离线消息存储业务1.点对点聊天业务业务逻辑：用户给用户发消息，如果目的用户在线，那就找到对应的连接，然后发送消息即可 如果目的用户不在线，那就存到离线消息表，等到下次上线的时候服务器再发过去 123456789101112131415161718//一对一聊天业务void ChatService::oneChat(const TcpConnectionPtr& conn,json &js,Timestamp time){ //目的用户 int to=js["to"].get<int>(); { lock_guard<mutex> lock_(_connMutex); auto it=_userConnMap.find(to); if(it!=_userConnMap.end()) { //to在线，转发消息 ...

C++项目 | 集群聊天服务器 | Model数据层代码框架设计以及用户注册代码数据库代码要和业务层分离开 我们希望在业务层看到的都是对象 在数据层操作具体的sql语句 1.User根据user表封装User对象 就是一些set和get方法，一个User对象对应user表中的一条记录 12345678910111213141516171819202122232425262728293031323334//user.hpp#ifndef USER_H#define USER_H#include<string>using namespace std;class User{public: User(int id=-1,string name="",string pwd="",string state="offline") { this->id=id; this->name=name; this->password=pwd;...

C++项目 | 集群聊天服务器 | 客户端异常退出业务1.clientCloseExecption客户端异常退出处理函数要干两件事： 1.从map中删除用户的连接信息，因为要把底层的socket资源释放掉 2.更新用户状态信息 user表中状态改为offline 1234567891011121314151617181920212223242526//chatservice.cpp//处理客户端异常退出void ChatService::clientCloseExecption(const TcpConnectionPtr &conn){ User user; //1.从map中删除用户的连接信息 { lock_guard<mutex> lock(_connMutex); for(auto it=_userConnMap.begin();it!=_userConnMap.end();++it) { if(it->second==conn) ...

C++项目 | 集群聊天服务器 | 用户登录业务 && 记录用户的连接信息以及线程安全问题1.query函数功能：根据用户号码查询用户信息 封装sql的select查询语句 把查询结果封装到User中返回 没查询到就返回默认结果(id==-1) 12345678910111213141516171819202122232425262728293031323334353637//usermodel.cpp//根据用户号码查询用户信息User UserModel::query(int id){ //根据用户号码查询用户信息 //1.组装sql语句 char sql[1024]={0}; sprintf(sql,"select * from user where id = %d", id); MySQL mysql; //建立连接 if(mysql.connect()) { //获取结果 MYSQL_RES...

C++集群聊天服务器项目总概述技术栈Json序列化和反序列化 muduo网络库开发 nginx源码编译安装和环境部署 nginx的tcp负载均衡器配置 redis缓存服务器编程实践 基于发布-订阅的服务器中间件redis消息队列编程实践 MySQL数据库编程 CMake构建编译环境 Github托管项目 项目需求 客户端新用户注册 客户端用户登录 添加好友和添加群组 好友聊天 群组聊天 离线消息 nginx配置tcp负载均衡 集群聊天系统支持客户端跨服务器通信 项目目标 掌握服务器的网络I/O模块，业务模块，数据模块分层的设计思想 掌握C++ muduo网络库的编程以及实现原理 掌握Json的编程应用 掌握nginx配置部署tcp负载均衡器的应用以及原理 掌握服务器中间件的应用场景和基于发布-订阅的redis编程实践以及应用原理 掌握CMake构建自动化编译环境 掌握Github管理项目 开发环境 ubuntu linux环境 安装Json开发库 安装boost +...

C++项目 | 集群聊天服务器 | MYSQL数据库代码封装本篇博客介绍如何把MYSQL相关代码整合到项目中来 数据层和业务层也要解耦合，就像网络层和业务层一样 业务层不要出现任何的mysql的增删改查 要在业务层和数据层中间加入一层中间层，完成对sql语句的封装 对于业务层要看到的直接操作对象，而不是sql语句 数据层封装了数据库所有的操作 1.检查有没有相应动态库1sudo find /usr -name "libmysqlclient*" 没有的话说明只是装了mysql server，没装开发包，执行这个命令安装即可 1sudo apt-get install libmysqlclient-dev 2.MYSQL相关代码123456789101112131415161718192021222324252627282930//db.h#ifndef DB_H#define BD_H#include<mysql/mysql.h>#include<string>using namespace std;// 数据库操作类class...

C++项目 | 集群聊天服务器 | Mysql1.MySQL环境安装设置ubuntu环境安装mysql-server和mysql开发包，包括mysql头文件和动态库文件，命令如下： 12sudo apt-get install mysql-server =》 安装最新版MySQL服务器sudo apt-get install libmysqlclient-dev =》 安装开发包 ubuntu默认安装最新的mysql，但是初始的用户名和密码是自动生成的，按下面步骤修改mysql的root用 户密码为123456 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162【step 1 】tony@tony-virtual-machine:~$ sudo cat /etc/mysql/debian.cnf[client]host = localhostuser = debian-sys-maint...

C++项目 | 集群聊天服务器 | 业务模块要达到的目的：完全解耦网络模块的代码和业务模块的代码 通过js[“msgid”]绑定一个回调函数，对应获得一个业务处理器handler（handler就是回调函数） 只要解析出来msgid就可以回调对应的函数，而不用写什么if(msgid==1)就怎么样怎么样这样的代码 1.头文件使用单例模式实现聊天服务器业务类 用函数对象表示回调函数 123456789101112131415#ifndef PUBLIC_H#define PUBLIC_H/*server和client的公共文件*/enum EnMsgType{ LOGIN_MSG=1, //登录消息 REG_MSG //注册消息};#endif 12345678910111213141516171819202122232425262728293031323334353637//chatservice.hpp#ifndef CHATSERVICE_H#define...