本文共 9363 字,大约阅读时间需要 31 分钟。
又到了每天写日报的时间了。
还是先记录前一天的日报情况。
1号 | https://blog.csdn.net/qq_43762191/article/details/106856827 |
---|---|
2号 | https://blog.csdn.net/qq_45792305/article/details/106870557 |
3号 | https://blog.csdn.net/blackcamouflage/article/details/106865699 |
4号 | https://blog.csdn.net/luyaozhima/article/details/106863462 |
5号 | https://blog.csdn.net/jxy0219/article/details/106865207 |
6号 | 2 |
8号 | https://blog.csdn.net/qq_42151344/article/details/106865571 |
9号 | https://blog.csdn.net/qq_46485161/article/details/106866715 |
昨天大家都走出了第一步,客户端陆陆续续都在画界面,服务器方面我也初步建设好数据库和解压包两个模块,其他人也在抓紧学习,呈现出明显的分化,努力的人越努力。
昨天还做出了一个调整,鉴于大家压力都比较大,所以决定将之后的一个项目日分为两天,天天开会大家会觉得没什么好讲的了。相应的改动便是将项目周期由12个工作日改为10个项目日,实际时间由原先的16天延长为20天。
此外,会议主要讨论了解压包模块应该如何进行,接下来会看到我设计的类图。
//packet_base.h#pragma once#include#define MAX_PACKET_LENTH 1024//设置包最大长度为1024,// ! ! ! 暂时不考虑会太小的情况 ! ! !typedef struct packet_header_st{ int fd;//用于前后端通信即目标客户端fd(服务器用到) int funcId; // 功能号 //登录包0x01,注册包0x02,找回密码0x03,修改密码0x04 //客户端获取文件列表0x11,上传文件0x12,下载文件0x13,共享文件0x14,除获取列表外各种文件业务应答0x15 //心跳0x21 int optid; // 操作码:请求0x00 和 应答0x01 int usrlenth;// 包体的长度 int packet_seq; //包序号 int packet_sum; //包总数 char srcAddr[6]; //预留 char dstAddr[6]; //预留 int syn; // 判断包头是否正确 0x04}packet_header_t;/************接入层数据包尾************/typedef struct packet_tali_st//包尾,用来验证数据包的完整性{ int pack_tail;//设置为0x05}packet_tali_t;/************数据包报文整体************/typedef struct packet_all_st{ packet_header_t Head; char* body; packet_tali_st tail;}packet_all_st;class PacketBase{protected: int m_Size; int Body_Size; //包体大小 packet_header_t Head; packet_tali_t Tail; char* Body; char m_Data[MAX_PACKET_LENTH];public: PacketBase(); ~PacketBase(); bool pack(); bool unpack(); char* getBody(); packet_header_t* getHead(); packet_tali_t* getTail(); char* getData(); int getSize(); void setSize(int size); void setBodySize(int bodysize); PacketBase& operator =(const PacketBase& packet);};
//packet_base.cpp#include "PacketBase.h"#includePacketBase::PacketBase() { memset(&Head, 0, sizeof(Head)); memset(&Tail, 0, sizeof(Tail));}PacketBase::~PacketBase() { delete Body; //如果要用智能指针的话,先测一下大小}bool PacketBase::pack(){ Body = new char[Body_Size]; memcpy(m_Data, &this->Head, sizeof(packet_header_t)); memcpy(m_Data + sizeof(packet_header_t), this->Body, sizeof(Body)); //这个Body长度在封包的时候定 memcpy(m_Data + sizeof(packet_header_t) + sizeof(Body), &this->Tail, sizeof(packet_tali_t)); return true;}bool PacketBase::unpack(){ if (Body_Size <= 0) { //如果数据不足 std::cout << "数据包破损" << std::endl; return false; } Body = new char[Body_Size]; //防止越界可以在这里下手 memcpy(&this->Head, m_Data, sizeof(packet_header_t)); //先将包头读出 memcpy(Body, m_Data + sizeof(packet_header_t), sizeof(Body)); memcpy(&this->Tail, m_Data + sizeof(packet_header_t) + sizeof(Body), sizeof(packet_tali_t)); return true; }char* PacketBase::getBody() { return Body;}packet_header_t* PacketBase::getHead() { return &Head;}packet_tali_t* PacketBase::getTail() { return &Tail;}char* PacketBase::getData() { return m_Data;}int PacketBase::getSize() { return m_Size;}//这个给解包用void PacketBase::setSize(int size) { this->m_Size = size; this->Body_Size = size - sizeof(packet_header_t) - sizeof(packet_tali_t);}//这个给封包用void PacketBase::setBodySize(int bodysize) { this->Body_Size = bodysize; this->m_Size = Body_Size + sizeof(packet_header_t) + sizeof(packet_tali_t);}//这个不知道干嘛用,历史遗留PacketBase& PacketBase::operator =(const PacketBase& packet){ memset(m_Data, 0, MAX_PACKET_LENTH); if (m_Size != packet.m_Size) { m_Size = packet.m_Size; } memcpy(m_Data, packet.m_Data, packet.m_Size); return *this;}
//自定义协议包#pragma once/************业务层数据包体************///客户端登录请求包typedef struct login{ int id; int pwd; //密码}Login_t;//登录应答包typedef struct res_login_st{ int login_ret; //登录结果: 1-登录成功,0-登录失败 int dir_id; //初始文件列表id}res_login_t;//客户端注册请求包typedef struct Register{ int id; //账号 char tel[12]; //11位手机号 int pwd; //密码}Register_t;//注册应答包typedef struct res_register_st{ int register_ret; //注册结果: 0-注册成功,1-注册失败}res_register_t;//客户端修改密码请求包typedef struct Change_PWD{ int id; //账号 int pwd; //密码}c_pwd_t;//改密码应答包typedef struct res_changepwd_st{ int change_ret; //改密码结果: 0-改密码成功,1-改密码失败}res_cpwd_t;//找回密码请求包typedef struct findpwd{ int id; int tel[12];}F_Pwd_t;//找回密码应答包typedef struct res_findpwd_st{ int find_ret; //找回结果: 0-找回成功,1-找回失败 int pwd; //密码}res_fpwd_t;//销户请求包typedef struct deluser{ int id; int pwd;}D_user_t;/**********************************文件相关****************************************///上传文件请求包typedef struct UpFile{ int user_id; int dir_id; int mode; //文件权限位 int pwd; char* file_name;}UpFile_t;//下载文件请求包typedef struct Download_File{ int user_id; //用户ID int pwd; char* file_name; //文件id}Download_t;//文件分享typedef struct Cmode{ int id; int pwd; int mode; int yaoqingma; //邀请码 char* file_name;}C_mode_t;//新建目录typedef struct AddFileList{ int id; int pwd; int father_dir; //挂载在哪一级目录底下 char* dirname;}A_filelist_t;//修改文件目录typedef struct CFileList{ int id; int pwd; int old_dir; int new_dir; char* file_name;}C_filelist_t;//删除文件typedef struct delfile{ int id; int pwd; char* file_name;}D_file_t;//删除目录typedef struct dellist{ int id; int pwd; int dir_id;} D_list_t;//文件、目录总应答typedef struct res_fl{ int stata; //0成1败}res_fl_t;//文件列表请求包typedef struct File_List{ int user_id; //用户ID int pwd; int dir_id; //目录id}FileList_t;//文件列表应答包typedef struct Res_VideoList{ char V[800];}res_filelist_t;//心跳处理typedef struct Heart{ int heart; //占位}res_heart_t;
//packet_command.h#pragma once#include "PacketBase.h"#include "Packet1.h"class PacketCommand1:protected PacketBase{public: PacketCommand1(); bool replyLogin(int state,int dir_id, int fd); bool replyRegist(int state, int fd); bool replyCpwd(int state, int fd); bool replyFpwd(int state,int pwd, int fd); bool replyFL(int state, int fd); bool replyFileList(char* filelist, int fd);};
//packet_command.cpp#include "PacketCommand1.h"PacketCommand1::PacketCommand1():PacketBase(){}bool PacketCommand1::replyLogin(int state, int dir_id,int fd) { Head.funcId = 0x01; Head.optid = 0x01; Head.fd = fd; Head.usrlenth = sizeof(Body); //谁开的包谁封回去,所以大小是相对静止了 Head.syn = 0x04; res_login_t* body = (res_login_t*)Body; body->login_ret = state; body->dir_id = dir_id; Tail.pack_tail = 0x05; return this->pack();}bool PacketCommand1::replyRegist(int state, int fd) { Head.funcId = 0x02; Head.optid = 0x01; Head.fd = fd; Head.usrlenth = sizeof(Body); Head.syn = 0x04; res_register_t* body = (res_register_t*)Body; body->register_ret = state; Tail.pack_tail = 0x05; return this->pack();}bool PacketCommand1::replyFpwd(int state, int pwd, int fd) { Head.funcId = 0x03; Head.optid = 0x01; Head.fd = fd; Head.usrlenth = sizeof(Body); Head.syn = 0x04; res_fpwd_t* body = (res_fpwd_t*)Body; body->find_ret = state; body->pwd = pwd; Tail.pack_tail = 0x05; return this->pack();}bool PacketCommand1::replyCpwd(int state, int fd) { Head.funcId = 0x04; Head.optid = 0x01; Head.fd = fd; Head.usrlenth = sizeof(Body); Head.syn = 0x04; res_cpwd_t* body = (res_cpwd_t*)Body; body->change_ret = state; Tail.pack_tail = 0x05; return this->pack();}bool PacketCommand1::replyFL(int state, int fd) { Head.funcId = 0x15; Head.optid = 0x01; Head.fd = fd; Head.usrlenth = sizeof(Body); Head.syn = 0x04; res_fl_t* body = (res_fl_t*)Body; body->stata = state; Tail.pack_tail = 0x05; return this->pack();}bool PacketCommand1::replyFileList(char* filelist, int fd) { Head.funcId = 0x11; Head.optid = 0x01; Head.fd = fd; Head.usrlenth = sizeof(Body); Head.syn = 0x04; res_filelist_t* body = (res_filelist_t*)Body; memcpy(body->V,filelist,sizeof(filelist)); Tail.pack_tail = 0x05; return this->pack();}
对数据库模块测试之后,做了几个修改,这里主要列几个
//DB_base.cpp//获取查询记录中第n个数据(数据需有效)int DB_base::ireturn_serch(char* sql, int n){ char* errMsg; char** dbResult; int nRow = 0, nColumn = 0; int rc; int result; rc = sqlite3_get_table(db, sql, &dbResult, &nRow, &nColumn, &errMsg); if (nRow == 0 || dbResult[nColumn + n - 1] == NULL) { return 0; //如果没有数据,返回0 } if (rc == SQLITE_OK && n <= nColumn) { result = atoi(dbResult[nColumn + n - 1]); sqlite3_free_table(dbResult); return result; } else { cout<< < <
//DB_command.cpp//获取文件列表下所有目录、文件void DB_command::file_list(int user_id, int pwd, int dir_id, char* ret){ if (login(user_id, pwd)) { char* sql = new char[120]; memset(sql,0,120); sprintf(sql, "select file_name from FileMsg where owner_id = %d and dir_id = %d", user_id, dir_id); My_DB->ret_any(sql, ret); sprintf(sql, "select dir_name from DirMsg where grade = %d",dir_id); My_DB->ret_any(sql, ret); delete sql; } else cout << "can't get file list" << endl;}
测试代码:解压包模块与epoll模型
由于应邀出席某个毕业班的评审嘉宾,所以下午就没时间了。所以今天将epoll模块也设计好,尽量争取把代码也敲了。
这两个模块的测试只能留待明天了,因为测试是未知数,谁也不知道会测出什么问题来。一定是可以实现的!!!