大学课设项目,Windows端基于UDP的网络聊天程序的服务端和客户端

文章目录

  • 前言
  • 项目需求介绍
  • 一、服务端
    • 1.对Udp套接字进行一个封装
    • 2. UdpServer的编写
    • 3. Task.h
    • 4.protocol.h的编写
    • 5.线程池的编写
    • 6.main.cc
  • 二、客户端
    • 1. Socket.h
    • 2.protocol.h
    • 3.UdpClient
    • 4.menu.h
    • 5.main.cpp
  • 三、运行图


前言

本次项目可以作为之前内容的一个扩展,学会在Windows端进行网络通信。
该项目需要用到的知识手段较多,在编写该项目的同时也可以对之前C++方面的知识进行一个不错的回顾。

项目需求介绍

在这里插入图片描述

本次项目用到 Windows网络套接字编程,多线程,线程池,线程安全,互斥锁,IO流,文件管理,数据结构设计,序列化,反序列化,自定义协议,STL等相关知识和技术。


提示:以下是本篇文章正文内容,下面案例可供参考

一、服务端

1.对Udp套接字进行一个封装

//Socket.h
#pragma once
#include<iostream>
#include<string>
#include<WinSock2.h>
#include<Windows.h>
#include<thread>
#include<functional>
#pragma comment(lib, "ws2_32.lib") // 链接库文件#pragma warning(disable:4996)      //防止VS发出4996号警告enum Erro
{Sock_Error = 1,Bind_Error,Listen_Error
};
class Socket
{
public:Socket(){}void Init(){_listensock = socket(AF_INET, SOCK_DGRAM, 0);if (_listensock == SOCKET_ERROR){//套接字创建失败std::cout << "Socket Create Error..." << std::endl;exit(Sock_Error);}}void Bind(const std::string& ip, const int port){memset(&_sockaddr, 0, sizeof _sockaddr);_sockaddr.sin_family = AF_INET;_sockaddr.sin_addr.s_addr = inet_addr(ip.c_str());_sockaddr.sin_port = htons(port);int n = bind(_listensock, (const struct sockaddr*)&_sockaddr, sizeof _sockaddr);if (n < 0){std::cout << "Bind Error..." << std::endl;//std::cout << errno << " " << strerror(errno) << std::endl;exit(Bind_Error);}}~Socket(){closesocket(_listensock);}public:SOCKET _listensock;  struct sockaddr_in _sockaddr;
};

Windows OS 和 Linux OS 所提供的网络套接字接口函数有一点点的不同,但是实际的使用差别并不是很大! 所以这里就不细讲了。

2. UdpServer的编写

// UdpServer.h
class UdpServer
{
public:UdpServer(){_tp = ThreadPool<Task>::GetInstance();_user_map = new std::unordered_map<std::string, std::string>;_online_map = new std::unordered_map<std::string, struct sockaddr_in>;_buffer = new std::unordered_map<std::string, std::string>;_mutex = new std::mutex;}void Init(){//初始化网络环境WSADATA wsd;WSAStartup(MAKEWORD(2, 2), &wsd);_host.Init();_host.Bind(server_ip, server_port);ReadUser();}void ReadUser(){std::ifstream in("User.txt");if (!in.is_open()){//文件打开失败std::cout << "Open FIle Error..." << std::endl;}std::string line;while (std::getline(in, line)){//"username passwd\n"size_t pos = line.find(' ');std::string username = line.substr(0, pos);std::string passwd = line.substr(pos + 1);_user_map->insert(std::pair<std::string,std::string>(username,passwd));}std::cout << "--------------------------------------------------------------" << std::endl;std::cout << "所有已注册账号密码" << std::endl;for (auto& e : *_user_map){std::cout << e.first << " " << e.second << std::endl;}std::cout << "--------------------------------------------------------------" << std::endl;}void Start(){_tp->Start();struct sockaddr_in client;char inbuffer[1024];std::string recvmes;while (true){int len = sizeof client; // unsigned intmemset(&client, 0, sizeof client);// 服务器接受数据//std::cout << "开始等待数据" << std::endl;int n = recvfrom(_host._listensock, inbuffer, sizeof inbuffer - 1, 0, (sockaddr*)&client, &len);if (n > 0){inbuffer[n] = '\0';recvmes = inbuffer;while (!recvmes.empty()){Request rq;if (!rq.deserialize(recvmes)){//报文错误,丢弃所有报文std::cout << "报文错误" << std::endl;break;}Task task(rq, client,_user_map,_mutex,_host._listensock,_online_map,_buffer);_tp->Push(task);}}else{std::cout << "Read Error..." << std::endl;exit(1);}}}~UdpServer(){WSACleanup();   //清理网络环境}
private:Socket _host;ThreadPool<Task>* _tp;std::unordered_map<std::string, std::string>* _user_map;std::unordered_map<std::string, struct sockaddr_in>* _online_map;std::unordered_map<std::string, std::string>* _buffer;std::mutex* _mutex;
};

我们也对UdpServer也进行了一个封装,这里如果想要的话还可以继续接着完善,加入守护线程单例模式,大家感兴趣可以下来试一试。

主线程老老实实打印数据,其他线程就去处理客户端发来的命令。

我们可以看到类里面有许多成员变量, 这里对这些变量都进行解释一下。

Socket _host; 毫无疑问,服务端必须要申请一个套接字
ThreadPool* _tp; 这个是线程池的实例指针
std::unordered_map<std::string, std::string>* _user_map; 这个是服务器维护所有注册用户的哈希map
std::unordered_map<std::string, struct sockaddr_in>* _online_map; 这个是服务器维护所有在线用户的哈希map
std::unordered_map<std::string, std::string>* _buffer; 这个是存放所有注册用户离线消息的缓冲区
std::mutex* _mutex; 这个是为了保证线程安全提供的互斥锁

既然服务器想要维护所有用户信息,那么文件管理的IO就必不可少,所以这里也提供了 ReadUser函数

    void ReadUser(){std::ifstream in("User.txt");if (!in.is_open()){//文件打开失败std::cout << "Open FIle Error..." << std::endl;}std::string line;while (std::getline(in, line)){//"username passwd\n"size_t pos = line.find(' ');std::string username = line.substr(0, pos);std::string passwd = line.substr(pos + 1);_user_map->insert(std::pair<std::string,std::string>(username,passwd));}std::cout << "--------------------------------------------------------------" << std::endl;std::cout << "所有已注册账号密码" << std::endl;for (auto& e : *_user_map){std::cout << e.first << " " << e.second << std::endl;}std::cout << "--------------------------------------------------------------" << std::endl;}

作为初始化_user_map的函数。

3. Task.h

//Task.h
#pragma once#include<iostream>
#include<string>
#include<unordered_map>
#include<mutex>
#include<fstream>#include"protocol.h"
#include"Socket.h"std::string offline_message =
"-------------------------------------------------------------------------------\n\离线消息\n";enum Code {Login_Err = -1,Normal = 0,Online_User,All_User
};
class Task
{
public:Task(){}Task(const Request& rq, struct sockaddr_in client, std::unordered_map<std::string, std::string>* user_map ,std::mutex* mutex, SOCKET host, std::unordered_map<std::string, struct sockaddr_in>* online_map,std::unordered_map<std::string, std::string>* buffer):_rq(rq), _client(client),_user_map(user_map),_mutex(mutex) ,_host(host),_online_map(online_map),_buffer(buffer) {}void SendOneMessage(int code, const std::string& info, const struct sockaddr_in client){Respond rs(info, code);std::string mes;rs.serialize(&mes);sendto(_host, mes.c_str(), mes.size(), 0, (const struct sockaddr*)(&client), sizeof client);}void SendEveryoneMessage(const std::string& info){Respond rs(info);std::string mes;rs.serialize(&mes);for (auto& user : *_online_map){sendto(_host, mes.c_str(), mes.size(), 0, (const struct sockaddr*)&(user.second), sizeof(user.second));}}bool CheckUser(const std::string& name, const std::string& mes){auto a_it = _user_map->find(name);if (a_it == _user_map->end()){//不存在该用户SendOneMessage(Login_Err, std::string("该用户未注册,请输入/quit退出聊天框"), _client);return false;}auto o_it = _online_map->find(name);if (o_it == _online_map->end()){//该用户不在线SendOneMessage(0, std::string("该用户未上线,您可以继续发送离线消息,对方在上线后可查看"), _client);Respond rs(mes,0);std::string tmp;rs.serialize(&tmp);_mutex->lock();(*_buffer)[name] += tmp;_mutex->unlock();return false;}return true;}void SendSpecifiedUser(const std::string& client_name, const std::string& name, const std::string& info){std::string mes = "<";mes += client_name;mes += ">: ";mes += info;if (!CheckUser(name,mes)){return;}struct sockaddr_in spc_user = (*_online_map)[name];SendOneMessage(0, mes, spc_user);}void GetOnlineUser(std::string* out){std::string tmp;for (auto& e : *_online_map){tmp += e.first;tmp += '\n';}*out = tmp;}void GetAllUser(std::string* out){std::string tmp;for (auto& e : *_user_map){tmp += e.first;tmp += '\n';}*out = tmp;}void WriteUser(const std::string& name, const std::string& passwd){std::ofstream file("User.txt", std::ios::app);if (file){file << name << " " << passwd << std::endl;file.close();}else{std::cout << "写入失败" << std::endl;}}bool UserRegisterCheck(std::string& name, std::string& passwd){auto it = _user_map->find(name);if (it == _user_map->end()){//没找到,可以进行注册_mutex->lock();(*_user_map)[name] = passwd;_mutex->unlock();WriteUser(name, passwd);std::string mes = "Sign Up Succeed!";SendOneMessage(0, mes,_client);mes = "用户<";mes += name;mes += "> 已上线,快来找他聊天吧";SendEveryoneMessage(mes);_mutex->lock();(*_online_map)[name] = _client;_mutex->unlock();return true;}else{std::string mes = "Sign Up Failed, The Same UserName Already Exists";SendOneMessage(Login_Err, mes, _client);return false;}}bool UserLoginCheck(std::string& name, std::string& passwd){std::string mes;auto it = _user_map->find(name);if (it == _user_map->end()){//没找到直接Passmes = "Sign In Failed, Your Account Is Wrong";SendOneMessage(Login_Err, mes, _client);return false;}if ((*_user_map)[name] != passwd){//密码错误mes = "Sign In Failed, Your Password Is Wrong";SendOneMessage(Login_Err, mes, _client);return false;}if (_online_map->find(name) != _online_map->end()){//当前用户已经在线了mes = "The User has Signed In";SendOneMessage(Login_Err, mes, _client);return false;}mes = "Sign In Succeed! Weclome Back ";mes += name;mes += "!";SendOneMessage(0, mes, _client);mes = "用户<";mes += name;mes += "> 已上线,快来找他聊天吧";SendEveryoneMessage(mes);_mutex->lock();(*_online_map)[name] = _client;_mutex->unlock();//发送离线消息if (_buffer->find(name) != _buffer->end()){//离线buffer有它的信息SendOneMessage(Normal, offline_message, _client);sendto(_host, (*_buffer)[name].c_str(), (*_buffer)[name].size(), 0, (const struct sockaddr*)(&_client), sizeof _client);_mutex->lock();_buffer->erase(name);_mutex->unlock();}return true;}void LogOut(const std::string& name){auto o_it = _online_map->find(name);if (o_it == _online_map->end()){//该用户不在线return;}_mutex->lock();_online_map->erase(name);_mutex->unlock();std::string mes;mes = "用户<";mes += name;mes += "> 已下线";SendEveryoneMessage(mes);}void run(){//根据类型处理信息if (_rq._type == "/signup"){//注册流程UserRegisterCheck(_rq._info1, _rq._info2);}else if (_rq._type == "/signin"){//登录流程UserLoginCheck(_rq._info1, _rq._info2);}else if (_rq._type == "/getonline"){//给客户端发在线用户表std::string online;GetOnlineUser(&online);SendOneMessage(Online_User, online, _client);}else if (_rq._type == "/getall"){std::string all;GetAllUser(&all);SendOneMessage(All_User, all, _client);}else if (_rq._type == "/exit"){//下线LogOut(_rq._info1);}else if (_rq._type.find("/info") != std::string::npos){std::string client_name = _rq._type.substr(5);SendSpecifiedUser(client_name,_rq._info1, _rq._info2);}}void operator()(){run();}~Task(){}private:Request _rq;struct sockaddr_in _client;std::unordered_map<std::string, std::string>* _user_map;std::unordered_map<std::string, struct sockaddr_in>* _online_map;std::unordered_map<std::string, std::string>* _buffer;std::mutex* _mutex;SOCKET _host;};

Task.h其实才是重中之重,所有服务器的需求我都写在了这里面,可以根据函数名和成员变量来分析每个函数都是实现了一个怎样的功能。 该项目服务器所有功能的实现,我都进行了接近完美的封装。

4.protocol.h的编写

#pragma once#include <iostream>
#include <string>const char blank_space_sep = ' ';
const char protocol_sep = '&';class Request
{
public:Request() {} // 提供一个无参构造Request(const std::string& type, const std::string& info1 = "", const std::string& info2 = ""): _type(type), _info1(info1), _info2(info2) {}Request(const char* type, const  char* info1, const  char* info2): _type(type), _info1(info1), _info2(info2) {}bool serialize(std::string* out_str){// 协议规定 字符串格式应序列化为"len\n_type _info1 _info2\n"std::string main_body = _type;main_body += blank_space_sep;main_body += _info1;main_body += blank_space_sep;main_body += _info2;*out_str = std::to_string(main_body.size());*out_str += protocol_sep;*out_str += main_body;*out_str += protocol_sep;return true;}bool deserialize(std::string& in_str){// 协议规定 in_str的格式应为"len&_type _info1 _info2&"size_t pos = in_str.find(protocol_sep);if (pos == std::string::npos){// 说明没找到'&'return false;}std::string sl = in_str.substr(0, pos);int len = std::stoi(sl); // 如果这里的sl不是一串数字,stoi就会抛异常! BUG?  严格限制客户端行为!size_t total_len = sl.size() + 1 + len + 1;if (in_str.size() < total_len){return false;}if (in_str[total_len - 1] != protocol_sep){return false;}std::string main_body = in_str.substr(pos + 1, len);// main_body"_type _info1 _info2"size_t left = main_body.find(blank_space_sep);if (left == std::string::npos){// 说明没找到' 'return false;}size_t right = main_body.rfind(blank_space_sep);if (left == right){// 说明只有一个' 'return false;}_type = main_body.substr(0, left);   _info2 = main_body.substr(right + 1);_info1 = main_body.substr(left + 1, right - left - 1);in_str.erase(0, total_len);return true;}void print(){std::cout << _type << " " << _info1 << " " << _info2 << std::endl;}~Request() {}public:std::string _type;std::string _info1;std::string _info2;
};class Respond
{
public:Respond() {} // 提供一个无参构造Respond(std::string info, int code = 0): _info(info), _code(code) {}bool serialize(std::string* out_str){// 协议规定 字符串格式应序列化为"len&_code _info"std::string main_body = std::to_string(_code);main_body += blank_space_sep;main_body += _info;*out_str = std::to_string(main_body.size());*out_str += protocol_sep;*out_str += main_body;*out_str += protocol_sep;return true;}bool deserialize(std::string& in_str){// 协议规定 in_str的格式应为"len&_code _info"size_t pos = in_str.find(protocol_sep);if (pos == std::string::npos){// 说明没找到'&'return false;}std::string sl = in_str.substr(0, pos);int len = std::stoi(sl); // 如果这里的sl不是一串数字,stoi就会抛异常! BUG?  严格限制客户端行为!size_t total_len = sl.size() + 1 + len + 1;if (in_str.size() < total_len){return false;}if (in_str[total_len - 1] != protocol_sep){return false;}std::string main_body = in_str.substr(pos + 1, len);// main_body"_code _info"size_t blank = main_body.find(blank_space_sep);if (blank == std::string::npos){// 说明没找到' 'return false;}_code = std::stoi(main_body.substr(0, blank));_info = main_body.substr(blank + 1);in_str.erase(0, total_len);return true;}void print(){std::cout << _code << " " << _info << std::endl;}~Respond() {}public:int _code; // 表示结果可信度  0表示可信std::string _info;
};

序列化和反序列化,我们之前也有写过。 因为我们这里服务器跟客户端的需求过多,所以就需要对提交来的数据进行分析。
class Request
{
_type 作为客户端想要执行的命令
_info1 作为客户端发来的信息1
_info 2 作为客户端发来的信息2
}

class Respond{
_code 作为服务端向客户端数据的标识符(解释)
_info 作为服务端向客户端发送的信息
}

5.线程池的编写

#pragma once#include<iostream>
#include<thread>
#include<string>
#include<mutex>
#include<vector>
#include<queue>
#include<condition_variable>static const int defalutnum = 10;template <class T>
class ThreadPool
{
public:void Wakeup(){_cond.notify_one();}void ThreadSleep(std::unique_lock<std::mutex>& lock){_cond.wait(lock);}bool IsQueueEmpty(){return _tasks.empty();}public:static void HandlerTask(ThreadPool<T>* tp){while (true){T t;{std::unique_lock<std::mutex>lock(_mutex);while (tp->IsQueueEmpty()){tp->ThreadSleep(lock);}t = tp->Pop();}t();}}void Start(){size_t num = _threads.size();for (int i = 0; i < num; i++){_threads[i] = std::thread(HandlerTask, this);}}T Pop(){T t = _tasks.front();_tasks.pop();return t;}void Push(const T& t){std::unique_lock<std::mutex>lock(_mutex);_tasks.push(t);Wakeup();}static ThreadPool<T>* GetInstance(){if (nullptr == _tp) {std::unique_lock<std::mutex>lock(_lock);if (nullptr == _tp){_tp = new ThreadPool<T>();}}return _tp;}private:ThreadPool(int num = defalutnum) : _threads(num){}~ThreadPool() {}ThreadPool(const ThreadPool<T>&) = delete;const ThreadPool<T>& operator=(const ThreadPool<T>&) = delete;
private:std::vector<std::thread> _threads;std::queue<T> _tasks;static std::mutex _mutex;std::condition_variable _cond;static ThreadPool<T>* _tp;static std::mutex _lock;
};template <class T>
ThreadPool<T>* ThreadPool<T>::_tp = nullptr;template <class T>
std::mutex ThreadPool<T>::_lock;template <class T>
std::mutex ThreadPool<T>::_mutex;

这里的线程池,我直接采用了C++11提供的Thread类,并进行了完美的封装。

6.main.cc

这个我是不太想贴出来的,有点侮辱大家的智商,不过考虑到广大大学生…

#include"UdpServer.h"int main()
{UdpServer us;us.Init();us.Start();return 0;
}

二、客户端

1. Socket.h

与服务端Socket.h代码一致

2.protocol.h

与服务端protocol.h代码一致

3.UdpClient

#pragma once#include<string>
#include<thread>#include"protocol.h"
#include"Socket.h"
#include"menu.h"
#pragma comment(lib, "ws2_32.lib") // 链接库文件
#pragma warning(disable:4996)      //防止VS发出4996号警告const int server_port = 8080;
const std::string server_ip = "127.0.0.1"; //提前写好服务器IPstd::string yourname = "";enum Code {Login_Err = -1,Normal = 0,Online_User,All_User
};struct Thread_Data
{SOCKET socket_fd;struct sockaddr_in server;
};void GetOnlineUser(const Thread_Data& data)
{Request rq("/getonline");std::string info;rq.serialize(&info);sendto(data.socket_fd, info.c_str(), (int)info.size(), 0, (const struct sockaddr*)&data.server, sizeof(data.server));
}void GetAllUser(const Thread_Data& data)
{Request rq("/getall");std::string info;rq.serialize(&info);sendto(data.socket_fd, info.c_str(), (int)info.size(), 0, (const struct sockaddr*)&data.server, sizeof(data.server));
}void Exit(const Thread_Data& data)
{Request rq("/exit", yourname);std::string info;rq.serialize(&info);sendto(data.socket_fd, info.c_str(), (int)info.size(), 0, (const struct sockaddr*)&data.server, sizeof(data.server));exit(0);
}void recv_mes(const Thread_Data& data)
{char buffer[1024];std::string message;while (true){memset(buffer, 0, sizeof(buffer));struct sockaddr_in tmp;int tmp_len = sizeof(tmp);int n = recvfrom(data.socket_fd, buffer, sizeof(buffer) - 1, 0, (struct sockaddr*)&tmp, &tmp_len);if (n > 0){buffer[n] = 0;message = buffer;while (!message.empty()){Respond rs;if (!rs.deserialize(message)){//报文错误,丢弃所有报文std::cout << "报文错误" << std::endl;break;}if (rs._code == Online_User){PrintOnline(rs._info);continue;}else if (rs._code == All_User){PrintAll(rs._info);continue;}std::cout << rs._info << std::endl;}}else{std::cout << "Recv Error..." << std::endl;exit(1);}}
}void LoginPage(const Thread_Data& data)
{std::string name;while (true){std::cout << sign_page << std::endl;std::string login;std::cin >> login;std::string passwd;if (login == "1"){//登录std::cout << "请输入你的账号@";std::cin >> name;std::cout << "请输入你的密码@";std::cin >> passwd;Request rq("/signin", name.c_str(), passwd.c_str());std::string mes;rq.serialize(&mes);sendto(data.socket_fd, mes.c_str(), (int)mes.size(), 0, (const struct sockaddr*)&data.server, sizeof(data.server));break;}else if (login == "2"){//注册while (true){std::cout << "请输入你要注册的账号@";std::cin >> name;std::cout << "请输入你要注册的密码@";std::cin >> passwd;std::string confirm;std::cout << "请重新输入你的密码@";std::cin >> confirm;if (confirm != passwd){std::cout << "两次输入的密码不正确,请重新注册" << std::endl;continue;}break;}Request rq("/signup", name.c_str(), passwd.c_str());std::string mes;rq.serialize(&mes);sendto(data.socket_fd, mes.c_str(), (int)mes.size(), 0, (const struct sockaddr*)&data.server, sizeof(data.server));break;}else{//用户输入错误std::cout << "输入错误,请重新输入" << std::endl;continue;}}yourname = name;
}void HandRequest(const Thread_Data& data)
{std::string message;std::cout << ico << std::endl;while (true){LoginPage(data);//回应请求char buffer[1024];memset(buffer, 0, sizeof(buffer));struct sockaddr_in tmp;int tmp_len = sizeof tmp;int n = recvfrom(data.socket_fd, buffer, sizeof(buffer) - 1, 0, (struct sockaddr*)&tmp, &tmp_len);if (n > 0){buffer[n] = 0;message = buffer;Respond rs;rs.deserialize(message);std::cout << rs._info << std::endl;if (rs._code == Login_Err){std::cout << "请重新登录/注册" << std::endl;continue;}break;}else{std::cout << "Hand Recv Error..." << std::endl;exit(1);}}}void ConnectUser(const Thread_Data& data, const std::string& name)
{std::string mes;std::cout << "------------------------------------------------------------------------------------------" << std::endl;std::cout << "                                          聊天框" << std::endl;std::cout << "小帮手: 想要退出聊天框请输入/quit" << std::endl;while (true){std::cout << "Send A Message@";std::cin >> mes;if (mes == "/help"){HelpMenu();continue;}else if (mes == "/quit"){break;}else if (mes == "/online"){GetOnlineUser(data);continue;}else if (mes == "/all"){GetAllUser(data);continue;}else if (mes == "/clear"){system("cls");}else if (mes == "/exit"){Exit(data);}std::string cmd = "/info";cmd += yourname;Request rq(cmd.c_str(), name, mes.c_str());std::string info;rq.serialize(&info);sendto(data.socket_fd, info.c_str(), (int)info.size(), 0, (const struct sockaddr*)&data.server, sizeof(data.server));std::cout << "成功发送消息" << std::endl;}std::cout << "------------------------------------------------------------------------------------------" << std::endl;
}void send_mes(const Thread_Data& data)
{HelpMenu();std::string command;std::string name;while (true){std::cin >> command;//根据if(command == "/online"){ GetOnlineUser(data);continue;}else if (command == "/all"){GetAllUser(data);continue;}else if (command == "/help"){HelpMenu();continue;}else if (command == "/go"){GetOnlineUser(data);std::cout << "你想要和谁聊天?" << std::endl;std::cin >> name;if (name == yourname){std::cout << "不可与自己聊天,退出" << std::endl;continue;}ConnectUser(data, name);std::cout << "你已离开与 " << name << " 的聊天," << "可以输入/online ,查看当前在线用户" << std::endl;}else if (command == "/clear"){system("cls");}else if (command == "/exit"){Exit(data);}else{std::cout << "未知命令,输入/help来查看所有命令" << std::endl;}}
}class UdpClient {
public:UdpClient() {}void Init(){WSADATA wsd;WSAStartup(MAKEWORD(2, 2), &wsd);_host.Init();}void Start(){struct sockaddr_in server;memset(&server, 0, sizeof server);server.sin_family = AF_INET;server.sin_addr.s_addr = inet_addr(server_ip.c_str());server.sin_port = htons(server_port);std::thread threads[2];Thread_Data data;data.server = server;data.socket_fd = _host._listensock;//等待第一次握手请求HandRequest(data);threads[1] = std::thread(send_mes, std::ref(data));threads[0] = std::thread(recv_mes, std::ref(data));threads[0].join();threads[1].join();}~UdpClient() {WSACleanup();   //清理网络环境}
private:Socket _host;
};

客户端的设计,我是分为两个部分,第一个部分我称为客户端的握手请求,
让客户端进行登录或注册。 然后再进入第二个部分,从这里开始读取数据和写数据就使用多线程让两个模块进行分离。

写数据的进程 可以让用户自由选择交互命令,读数据的进程分析服务器发来的数据,并进行响应。

4.menu.h

#pragma once#include<string>
#include<iostream>
#include<vector>
//#pragma execution_character_set("utf-8")const std::string ico =
"  ______                      _                 _   _        _____ _           _  \n\|  ____|                    | |               (_) ( )      / ____| |         | | \n\| |__ ___ _ __   __ _       | |_   _ _ __  _____  |/ ___  | |    | |__   __ _| |_ \n\|  __/ _ \\ '_ \\ / _` |  _   | | | | | '_ \\|_  / |   / __| | |    | '_ \\ / _` | __|\n\| | |  __/ | | | (_| | | |__| | |_| | | | |/ /| |   \\__ \\ | |____| | | | (_| | |_ \n\|_|  \\___|_| |_|\\__, |  \\____/ \\__,_|_| |_/___|_|   |___/  \\_____|_| |_|\\__,_|\\__|\n\__/ |                                                            \n\|___/                                                             \n";const std::string sign_page =
" ------------------------------------------------------------------------------------------\n\
|           1.sign in(登录)                                2. sign up(注册)               |\n\
|                                       请输入序号                                        |\n\
|                                                                                         |\n\------------------------------------------------------------------------------------------";const std::vector<std::string> OKword = { "" };void PrintOnline(const std::string& online)
{std::cout << "------------------------------------------------------------------------------------------" << std::endl;std::cout << "                                        当前在线用户" << std::endl;std::cout << online << std::endl;std::cout << "------------------------------------------------------------------------------------------" << std::endl;
}void PrintAll(const std::string& all)
{{std::cout << "------------------------------------------------------------------------------------------" << std::endl;std::cout << "                                        所有注册用户" << std::endl;std::cout << all << std::endl;std::cout << "------------------------------------------------------------------------------------------" << std::endl;}}void HelpMenu()
{printf(" --------------------------------------------------------------------------------------------------------------------\n\
|                                                  小帮手                                                            |\n\
| 输入/online  可以查看当前在线用户                                                                                  |\n\
| 输入/all     可以查看所有注册用户                                                                                  |\n\
| 输入/help    可以再次召唤小帮手                                                                                    |\n\
| 输入/go      进入一个指定用户的聊天窗口,在聊天窗口内不可使用/go命令,期间可以收到其他用户发来的消息               |\n\
| 输入/quit    可以离开与当前用户的聊天窗口                                                                          |\n\
| 输入/clear   可以清理界面                                                                                          |\n\
| 输入/exit    关闭客户端,下线                                                                                      |\n\
|                                                                                                                    |\n\
| WARNING: 由于该程序采用UDP协议,为无连接传输协议,请登录后务必使用/exit退出程序,不要直接关闭客户端,否则后果自负  |\n\
| WARNING: 由于该程序采用UDP协议,为无连接传输协议,请登录后务必使用/exit退出程序,不要直接关闭客户端,否则后果自负  |\n\
| WARNING: 由于该程序采用UDP协议,为无连接传输协议,请登录后务必使用/exit退出程序,不要直接关闭客户端,否则后果自负  |\n\--------------------------------------------------------------------------------------------------------------------\n");
}

这个头文件就主要是在命令行界面一定程度上做一些仿图形界面,方便美观。

5.main.cpp

#include"UdpClient.h"int main()
{UdpClient uc;uc.Init();uc.Start();return 0;
}

三、运行图

这里我就不放出服务器运行的图片了,因为服务器运行的时候,我没有写什么输出屏幕语句,所以啥也没有。

在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/352260.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

《数据安全产品及服务购买决策参考》

“新全球化”下的数据安全威胁态势与挑战 随着中国企业数字化转型和数字经济的高速发展&#xff0c;数据要素和数据安全的战略价值正不断提升。 同时&#xff0c;在“脱钩”与“新全球化”的全球政治经济博弈中&#xff0c;中国作为全球重要的数据安全市场之一&#xff0c;其…

LeetCode esay mid 记录

1486. 数组异或操作 感觉一般也用不到 emmm 灵茶山艾府传送门 推导过程可以结合官网部分观看 重点由两部分的结合 将特定部分转换为常见部分 0到n的异或和表示 2595. 奇偶位数 0x555是十六进制数&#xff0c;转换为二进制为 0101 0101 0101 class Solution {public int[…

90. 子集 II

90. 子集 II 原题链接&#xff1a;完成情况&#xff1a;解题思路&#xff1a;参考代码&#xff1a;_90子集II_递归法求子集_90子集II_迭代法求子集 错误经验吸取 原题链接&#xff1a; 90. 子集 II https://leetcode.cn/problems/subsets-ii/ 完成情况&#xff1a; 解题思路…

代码解读 | Hybrid Transformers for Music Source Separation[07]

一、背景 0、Hybrid Transformer 论文解读 1、代码复现|Demucs Music Source Separation_demucs架构原理-CSDN博客 2、Hybrid Transformer 各个模块对应的代码具体在工程的哪个地方 3、Hybrid Transformer 各个模块的底层到底是个啥&#xff08;初步感受&#xff09;&#xff1…

Vue48-ref属性

一、需求&#xff1a;操作DOM元素 1-1、使用原生的id属性 不太好&#xff01; 1-2、使用 ref属性 原生HTML中&#xff0c;用id属性给元素打标识&#xff0c;vue里面用ref属性。 给哪个元素加了ref属性&#xff0c;vc实例对象就收集哪个元素&#xff01;&#xff01;&#xff0…

WebSocket 详解--spring boot简单使用案例

一、什么是WebSocket WebSocket 是一种网络通信协议&#xff0c;专为在单个 TCP 连接上进行全双工通信而设计。WebSocket 允许客户端和服务器之间的消息能够实时双向传输。这与传统的 HTTP 请求-响应模式有很大的不同。 二、WebSocket 的关键特性 双向通信&#xff1a;WebSocke…

Novartis诺华制药社招综合能力性格动机问卷入职测评笔试题库答案及包过助攻

【华东同舟求职】由资深各行业从业者建立的一站式人才服务网络平台&#xff0c;现阶段目标是“提升全市场各行业岗位信息的流动性和透明度”。我们接受众多行业机构的直接委托发布&#xff0c;并尽力通过各种方法搜寻高价值岗位信息。事实上&#xff0c;我们以发现不为人知的优…

网站改成HTTPS方法

网站改成HTTPS只要网站没有特殊性的要求&#xff0c;绝大部分网站很轻松的就可以完成&#xff0c;尤其是CMS类似的网站系统或者自助搭建的网站&#xff08;比如&#xff1a;这种网站可以在网站后台一次性安装并且生效&#xff09;。 基本要求 将网站改成HTTPS有2个前提&#…

HQChart实战教程73-仿tradingview指标MACD

HQChart实战教程73-仿tradingview指标MACD MACD![在这里插入图片描述](https://img-blog.csdnimg.cn/direct/84d180b5620940f6b9fe08c6f10eb0f3.png)麦语法脚本实心MACD指标脚本效果 空心MACD指标脚本效果图 自定义指标添加到系统指标里HQChart插件源码地址 MACD tradingview中…

智能不锈钢氮气柜温湿度氧含量控制介绍

智能不锈钢氮气柜通过集成精密的温湿度和氧含量控制系统&#xff0c;确保内部环境稳定在适宜存储敏感物料的条件。具体实现方式如下&#xff1a; 温度控制&#xff1a;智能氮气柜通常配备有精确的温度传感器以及加热或冷却系统。当内部温度偏离设定值时&#xff0c;系统会自动启…

ue5创建地图瓦片

先在虚幻商城下载免费的paperzd插件&#xff0c;并启用。 导入资源后&#xff0c;先通过应用paper2d纹理资源&#xff0c;将去掉导入ue时产生的边缘模糊&#xff0c;再点击下面的创建瓦片集&#xff0c; 打开瓦片集&#xff0c;发现选中不对&#xff0c; 改变瓦片大小为16*…

Nature 苏浩团队发表创新人工智能“仿真中学习”框架,实现外骨骼的智能性和通用性

北京时间2024年6月12日23时&#xff0c;美国北卡罗来纳州立大学与北卡罗来纳大学教堂山分校的苏浩团队在《自然》&#xff08;Nature&#xff09;上发表了一篇关于机器人和人工智能算法相结合服务人类的突破性研究论文&#xff0c;标题为“Experiment-free Exoskeleton Assista…

振动分析-3-基于Python的FFT幅值修正与能量修正

幅值修正与能量修正过程&#xff08;更正&#xff09; 参考什么是泄漏&#xff1f; 参考什么是窗函数? 参考使用python实现快速傅里叶变换&#xff08;FFT&#xff09; 参考频谱泄露和窗函数以及加窗后幅度修正和python代码实现 1 快速傅里叶变换(FFT) 离散傅里叶变换(discr…

configure: error: library ‘crypto‘ is required for OpenSSL

1、执行命令&#xff1a;./configure --prefix/opt/app/postgresql --with-openssl 报错&#xff1a; 2、解决办法 执行命令&#xff1a;yum install openssl-devel 重新执行 ./configure --prefix/opt/app/postgresql --with-openssl

Springboot 开发之任务调度框架(一)Quartz 简介

一、引言 常见的定时任务框架有 Quartz、elastic-job、xxl-job等等&#xff0c;本文主要介绍 Spirng Boot 集成 Quartz 定时任务框架。 二、Quartz 简介 Quartz 是一个功能强大且灵活的开源作业调度库&#xff0c;广泛用于 Java 应用中。它允许开发者创建复杂的调度任务&…

C++ 03 之 命名空间

game_kun.cpp #include "game_kun.h"void kun::atk() {cout << "吃鸡的攻击"<< endl; } game_lol.cpp #include "game_lol.h"void lol::atk() {cout << "lol的攻击"<< endl; } game_kun.h #include <…

Linux驱动开发-01配置开发环境

一、配置网络环境 使用桥接网卡时 Ubuntu 就是使用一个真实的网卡 &#xff1a;开发板的网线也连接到这个真实的网卡上&#xff0c;这样 Windows 、 Ubuntu 、开发板就都可以用过这个网卡互通了。 NAT 网卡&#xff1a; Ubuntu 通过它上网&#xff0c;只要 Windows 能上网&…

电商客服的得力助手:快捷回复软件

随着技术的进步&#xff0c;传统的人工打字已经逐渐不能满足快节奏的电商服务需求。如今&#xff0c;市面上涌现出众多快捷回复辅助软件&#xff0c;它们以高效率的特点&#xff0c;成为电商客服人员的必备工具。 作为一名拥有五年经验的电商客服&#xff0c;我深刻体会到了这类…

使用 cx_Oracle 在 Oracle 中等待记录并执行操作

问题背景&#xff1a; 在第一个 Python 项目中&#xff0c;需要等待记录被插入 Oracle 表中&#xff0c;一旦记录存在&#xff0c;就调用 Python 函数。目前使用 cx_Oracle 库&#xff0c;采用一种无限循环的方式来查询表。如果记录存在&#xff0c;就调用函数&#xff0c;然后…

【leetcode刷题】面试经典150题 , 27. 移除元素

leetcode刷题 面试经典150 27. 移除元素 难度&#xff1a;简单 文章目录 一、题目内容二、自己实现代码2.1 方法一&#xff1a;直接硬找2.1.1 实现思路2.1.2 实现代码2.1.3 结果分析 2.2 方法二&#xff1a;排序整体删除再补充2.1.1 实现思路2.1.2 实现代码2.1.3 结果分析 三、…