- Visual Studio 2022
- MySQL 5.7
- 用户信息表(暂定TODO)
CREATE TABLE `t_user` (
`uuid` bigint(20) unsigned NOT NULL AUTO_INCREMENT,
`username` varchar(255) NOT NULL,
`password` varchar(255) NOT NULL,
`tel` varchar(255) DEFAULT NULL,
`icon` blob,
`feeling` varchar(255) DEFAULT NULL,
PRIMARY KEY (`uuid`)
) ENGINE=InnoDB AUTO_INCREMENT=8 DEFAULT CHARSET=utf8;- 好友关系表(暂定TODO)
CREATE TABLE `t_friendship` (
`uuid` bigint(20) unsigned NOT NULL,
`friend_id` bigint(20) unsigned NOT NULL,
KEY `uuid` (`uuid`),
KEY `t_friendship_ibfk_1` (`friend_id`),
CONSTRAINT `t_friendship_ibfk_1` FOREIGN KEY (`friend_id`) REFERENCES `t_user` (`uuid`) ON DELETE CASCADE ON UPDATE CASCADE,
CONSTRAINT `uuid` FOREIGN KEY (`uuid`) REFERENCES `t_user` (`uuid`) ON DELETE CASCADE ON UPDATE CASCADE
) ENGINE=InnoDB DEFAULT CHARSET=utf8;// 协议头
#define _DEF_PROTOCOL_BASE (100)
#define _DEF_PROTOCOL_COUNT (100)
// 注册
#define _DEF_PACK_REGISTER_RQ (_DEF_PROTOCOL_BASE + 0 )
#define _DEF_PACK_REGISTER_RS (_DEF_PROTOCOL_BASE + 1 )
//登录
#define _DEF_PACK_LOGIN_RQ (_DEF_PROTOCOL_BASE + 2 )
#define _DEF_PACK_LOGIN_RS (_DEF_PROTOCOL_BASE + 3 )
//好友信息
#define _DEF_PACK_FRIEND_INFO (_DEF_PROTOCOL_BASE + 4 )
//添加好友
#define _DEF_PACK_ADDFRIEND_RQ (_DEF_PROTOCOL_BASE + 5 )
#define _DEF_PACK_ADDFRIEND_RS (_DEF_PROTOCOL_BASE + 6 )
//聊天
#define _DEF_PACK_CHAT_RQ (_DEF_PROTOCOL_BASE + 7 )
#define _DEF_PACK_CHAT_RS (_DEF_PROTOCOL_BASE + 8 )
//离线
#define _DEF_PACK_OFFLINE_RQ (_DEF_PROTOCOL_BASE + 9 )classDiagram
class INet {
<<Interface>>
+ virtual bool InitNet()
+ virtual void UnInitNet()
+ virtual bool SendData(unsigned long lSendIP, const char* buf, int nLen)
# virtual void RecvData()
}
class TcpServer {
- SOCKET m_socket
- std::list~HANDLE~ m_hThreadHandleLst
- std::map~unsigned int, SOCKET~ m_mapThreadIdToSocket
- bool m_isStop
- static unsigned int __stdcall AcceptThread(LPVOID lpParameter)
- static unsigned int __stdcall RecvThread(LPVOID lpParameter)
}
class TcpClient {
- SOCKET m_socket
- HANDLE m_hThreadHandle
- bool m_isStop
- static unsigned int __stdcall RecvThread(LPVOID lpParameter)
}
INet <|.. TcpServer
INet <|.. TcpClient
class INetMediator {
# INet* m_pNet
- virtual bool OpenNet()
- virtual void CloseNet()
- virtual bool SendData(unsigned long lSendIP, const char* buf, int nLen)
- virtual void DealData(unsigned long lSendIP, const char* buf, int nLen)
}
INetMediator <|.. TcpServerMediator
INetMediator <|.. TcpClientMediator
INetMediator --> INet
- UDP是用户数据报协议, 在UDP协议中, 每个数据报都是不可拆分的, 发多少就接受多少, 接受不了的就直接扔掉
- TCP是基于字节流的传输控制协议, 每个数据包是没有明显边界的, 一个数据包可以完整的发出, 也可以被分散到不同的数据包组合成一个包发出, 应用层需要解决粘包问题
bool TcpServer::SendData(unsigned long lSendIP, const char* buf, int nLen)
{
if (!buf || nLen <= 0) return false;
// TODO: 防止粘包, 解决办法: 先发包大小, 再发数据包
send(lSendIP, (char*)&nLen, sizeof(int), 0);
if (send(lSendIP, buf, nLen, 0) <= 0) return false;
return true;
}
void TcpServer::RecvData()
{
Sleep(100);
SOCKET sockWaiter = m_mapThreadIdToSocket[GetCurrentThreadId()];
if (!sockWaiter || sockWaiter == INVALID_SOCKET) return;
int nPackSize = 0; // 存储包大小
int iResult = 0;
while (!m_isStop) {
// 先接受包大小 再接受数据包
iResult = recv(sockWaiter, (char*)&nPackSize, sizeof(int), 0);
if (iResult <= 0) break;
int offset = 0; //从buf开始起始偏移多少
char* recvbuf = new char[nPackSize];
while (nPackSize) {
if ((iResult = recv(sockWaiter, recvbuf + offset, sizeof(recvbuf), 0)) > 0) {
// TODO: 处理数据
nPackSize -= iResult;
offset += iResult;
sockaddr_in client_addr;
int addrSize = sizeof(client_addr);
getpeername(sockWaiter, (sockaddr*)&client_addr, &addrSize);
std::cout << "ip[" << inet_ntoa(client_addr.sin_addr) << "] says: " << recvbuf << std::endl;
}
}
m_pMediator->DealData(sockWaiter, recvbuf, offset);
}
}flowchart TD
subgraph net
subgraph inet
TcpServer --> INet
TcpClient -->INet
end
subgraph mediator
TcpServerMediator --> INetMediator
TcpClientMediator --> INetMediator
end
INetMediator --> INet
INet --> INetMediator
end
subgraph mysql
CMySql
end
Kernel --> CMySql
Kernel --> INetMediator
std::function()与std::bind()双剑合璧
-
std::function() 一个可调用对象包装器。可以容纳除了类成员函数指针之外的所有可调用对象，它可以用统一的方式处理函数、函数对象、函数指针，并允许保存和延迟它们的执行。 std::function可以取代函数指针的作用，因为它可以延迟函数的执行，特别适合作为回调函数使用。它比普通函数指针更加的灵活和便利。
-
std::bind()
类成员函数有一个默认的this参数, 所以类成员函数不能直接赋值给std::function.需要结合std::bind()使用.
可将std::bind()函数看作一个通用的函数适配器, 它接受一个可调用对象, 生成一个新的可调用对象来"适用"原对象的参数列表
- 作用:
- 将可调用对象和其参数绑定成一个仿函数
- 只绑定部分参数，减少可调用对象传入的参数
- 作用:
static std::map<int, std::function<void(unsigned long, const char*, int)> > m_deal_items;
#define XX(str, func) {\
auto call = std::bind(&Kernel::func, this, std::placeholders::_1, std::placeholders::_2, std::placeholders::_3); \
m_deal_items.insert({ str, call });}
XX(_DEF_PACK_LOGIN_RQ, dealLoginRq);
XX(_DEF_PACK_REGISTER_RQ, dealRegisterRq);
#undef XX QMenu类
用于菜单栏、上下文菜单和其他弹出菜单。
-
动作：
addActions（）-->原型：void QWidget::addActions(const QList<QAction *> &actions)
追加动作actions到此小部件的操作列表。
-
信号：
void QMenu::triggered(QAction *action)触发此菜单中的操作时会发出此信号。action是导致发出信号的动作。
服务器在客户端之间转发聊天请求。
如果To客户端不在线，构建回复包给From
/**
* @brief 聊天内容请求块
*/
typedef struct STRU_CHAT_RQ
{
typedef int PackType;
STRU_CHAT_RQ() :type(_DEF_PACK_CHAT_RQ), userid(0), friendid(0)
{
memset(content, 0, _DEF_CONTENT_SIZE);
}
/**
* @brief 数据包类型: _DEF_PACK_CHAT_RQ
*/
PackType type;
/**
* @brief 用户唯一id
*/
int userid;
/**
* @brief 好友id
*/
int friendid;
/**
* @brief 聊天内容
*/
char content[_DEF_CONTENT_SIZE];
}STRU_CHAT_RQ;
/**
* @brief 聊天内容回复块
*/
typedef struct STRU_CHAT_RS
{
typedef int PackType;
STRU_CHAT_RS() :type(_DEF_PACK_CHAT_RS), userid(0), friendid(0), result(0) {}
/**
* @brief 数据包类型: _DEF_PACK_CHAT_RS
*/
PackType type;
/**
* @brief 用户唯一id
*/
int userid;
/**
* @brief 好友id
*/
int friendid; //方便找是哪个人不在线
/**
* @brief 回复结果
*/
int result;
}STRU_CHAT_RS;窗口关闭事件（QCloseEvent）是当鼠标点击窗口右上角的关闭按钮时，所触发的函数。如果你没有重写virtual closeEvent(QCloseEvent*event);这个虚函数的话，系统是默认接受关闭事件的，所以就会关闭窗体。但有的时候，我们可能需要保存文本或做一些其他的处理，旧需要重写该函数，用来在窗口关闭之前处理自己需要的事情。
客户端离线向服务器发送离线请求
- 服务器将map中的记录删掉
- 服务器查询数据库，向所有好友发送好友离线通知
所有用户界面对象的基类
对话框窗口的基类
- 作用:主要用于短期任务以及和用户进行简要通讯的顶级窗口
- 模态对话框，就是会阻塞同一应用程序中其它窗口的输入。
- 非模态对话框则在弹出后，可以继续操作主窗口。
-
发送文件头
- 包括协议头, 文件唯一标识, 文件名和文件大小.
- 协议头: 标识该数据包是干什么的
- 文件唯一标识: 区分不同文件的唯一标识
- 方法：
- MD5
- 文件名_时间(时间精确到毫秒)
- 方法：
- 包括协议头, 文件唯一标识, 文件名和文件大小.
-
接收端返回确认信息
- 包括协议头, 文件唯一标识和结果.
- 文件唯一标识: 告诉对方这是对哪个文件的确认信息
- 结果: 同意接受或不同意
- 包括协议头, 文件唯一标识和结果.
-
发送文件块
- 包括协议头, 文件唯一标识, 文件内容和发送的长度
- 文件唯一标识: 标识发送的是哪一个文件
- 发送的长度: 标识此次发送的长度(发送缓冲区默认大小是64K)
- 包括协议头, 文件唯一标识, 文件内容和发送的长度
-
文件读取结束
- 写入的文件大小等于文件实际大小, 结束接受和发送
- 文件信息请求
- 文件信息回复
- 文件块请求
- 文件块接受回复
- 文件信息
- 获取文件信息
创建一个 “打开 ”对话框，允许用户指定要打开的文件或文件集的名称、目录和名称。 BOOL GetOpenFileNameA( [in, out] LPOPENFILENAMEA unnamedParam1 ); 返回值： 类型: BOOL 如果用户指定文件名并单击“ 确定 ”按钮，则返回值为非零。 OPENFILENAME 结构的 lpstrFile 成员指向的缓冲区包含用户指定的完整路径和文件名。 如果用户取消或关闭 “打开 ”对话框或发生错误，则返回值为零。 typedef struct tagOFNA { // OPENFILENAME 结构体 DWORD lStructSize; // 结构体长度 HWND hwndOwner; // 当前窗口的父窗口, 0 居中显示 ...... LPCSTR lpstrFilter; // 过滤器, 显示的文件的类型 ...... LPSTR lpstrFile; // 指向一块缓冲区, 存放被选择文件的完整路径 DWORD nMaxFile; // lpstrFile 指向的缓冲区的大小 ...... DWORD Flags; // 一组可用于初始化对话框的位标志 ...... } OPENFILENAMEA, *LPOPENFILENAMEA;
-
发送文件信息请求
-
从文件路径中获取文件名
-
发送消息块
- 处理文件信息请求
创建“ 保存 ”对话框，允许用户指定要保存的文件的驱动器、目录和名称。 BOOL GetSaveFileNameA( [in, out] LPOPENFILENAMEA unnamedParam1 );
void Kernel::DealFileInfoRq(unsigned long lSendIP, const char* buf, int nLen);
- 处理文件块请求
void Kernel::DealFileBlockRq(unsigned long lSendIP, const char* buf, int nLen);
-
getOpenFileName返回一个被用户选中的文件的路径，前提是这个文件是存在的。
-
getSaveFileName返回一个被用户选中的文件的路径，这个文件可以是不存在的。
-
getOpenFileNames返回一个或多个被用户选中的文件的路径，前提是这些文件是存在的。
-
getOpenFileName返回一个被用户选中的文件的路径，前提是这个文件是存在的。
-
getSaveFileName返回一个被用户选中的文件的路径，这个文件可以是不存在的。
-
getOpenFileNames返回一个或多个被用户选中的文件的路径，前提是这些文件是存在的。
- 如果好友在同意接受后突然下线, 需要保存断点
添加好友字符集
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent