C++基于UDP協(xié)議的群聊服務器開發(fā)實現(xiàn)
服務器
在服務器架構設計中,模塊解耦是保障系統(tǒng)可維護性的核心準則。本方案采用分層架構將核心功能拆解為通信層與業(yè)務處理層兩大模塊。值得注意的是,當使用TCP協(xié)議時,開發(fā)者往往需要額外設計協(xié)議抽象層來解決其字節(jié)流特性導致的消息邊界模糊問題(如粘包/拆包處理),并通過重傳機制強化傳輸可靠性。而UDP的面向報文特性天然規(guī)避了消息邊界問題,其無狀態(tài)傳輸模型大幅簡化了基礎通信層的設計復雜度——這正是我們選擇UDP構建輕量化實時群聊系統(tǒng)的關鍵原因。話不多說,我們直接開始!
框架設計
創(chuàng)建核心文件:UdpServer.hpp、UdpServer.cc、UdpClient.cc,當然不止于這些,在完成這些文件的過程中會延伸出更多文件,如果在這里寫顯得有些突兀。
- UdpServer.hpp:服務器相關的類以及類方法的實現(xiàn)——主要完成通信功能。
- UdpServer.cc:服務器主函數(shù)(main)的實現(xiàn)——對服務器接口的調用,即啟動服務器。
- UdpClient.cc:客戶端主函數(shù)(main)的實現(xiàn)——啟動客戶端,與服務器通信。
一、通信
上來直接創(chuàng)建一個class UdpServer類,而對于成員變量和成員函數(shù)的設定。我們得理一理進行通信需要完成什么,它完全是套路式的,模板化的。即:打開網(wǎng)絡文件,綁定端口,收數(shù)據(jù)_處理數(shù)據(jù)_發(fā)數(shù)據(jù)。(針對UDP協(xié)議通信)
根據(jù)這三點我們設計成員函數(shù):
- int _socketfd:網(wǎng)絡文件描述符。
- uint16_t _port:端口號。對于IP地址我們不期望從外部傳入,所以暫且不用設。
- 數(shù)據(jù)處理函數(shù):這個成員到后文數(shù)據(jù)處理再設計。
對于成員函數(shù)
- void Init():完成打開網(wǎng)絡文件,綁定端口。
- void Start():啟動服務,完成收數(shù)據(jù)_處理數(shù)據(jù)_發(fā)數(shù)據(jù),其中處理數(shù)據(jù)以回調的方式完成(為了讓模塊解耦,方便模塊之間的拼接和替換)。
如下:
class UdpServer { public: UdpServer(uint16_t port) : _socketfd(-1), _port(port) { } void Init(); void Start(); private: int _socketfd; uint16_t _port; //...... };
void Init ()
1.打開網(wǎng)絡文件
socket的使用
socket函數(shù)的聲明:
int socket(int domain, int type, int protocol);
功能:打開網(wǎng)絡文件(套接字)。
參數(shù)domain:確定IP地址類型,如IPv4還是IPv6。
AF_INET
: IPv4。AF_INET6:
IPv6。
參數(shù)type:確定數(shù)據(jù)的傳輸方式。
SOCK_STREAM
: 流式套接字(TCP)。SOCK_DGRAM
: 數(shù)據(jù)報套接字(UDP)。
參數(shù)protocol:確定協(xié)議類型,如果前面type已經(jīng)能確定了,這里傳入0即可。
返回值:
- 成功:文件描述符。
- 失敗:一個小于0的數(shù)。
代碼示例:
// 打開網(wǎng)絡文件 IPv4 數(shù)據(jù)包 udp _socketfd = socket(AF_INET, SOCK_DGRAM, 0); if (_socketfd < 0) { LOG(Level::ERROR) << "socket() fail"; exit(1); } else { LOG(Level::INFO) << "socket() succee _socketfd:" << _socketfd; }
說明:LOG是我寫的一個打印日志的接口, 大家把它當作cout理解就行,當然需要日志源碼的可以私信我。
2.綁定ip地址與端口號
sockaddr_in結構
首先我們需要了解sockaddr_in結構,IP地址和端口號等信息要包裝在這個結構里面,然后使用bind函數(shù)綁定。
sockaddr_in是用于 IPv4 網(wǎng)絡編程 的一個核心數(shù)據(jù)結構,用于存儲套接字地址信息(IP地址和端口號),除此之外還有sockaddr_in6(IPv6),sockaddr_un(本地通信),sockaddr(用來屏蔽包括但不止于以上三種結構的底層實現(xiàn))。
sockaddr_in結構如下:
#include <netinet/in.h> struct sockaddr_in { sa_family_t sin_family; // 地址族(Address Family) in_port_t sin_port; // 端口號(Port Number) struct in_addr sin_addr; // IPv4 地址(IP Address) char sin_zero[8]; // 填充字段(Padding) }; // IPv4 地址結構(嵌套在 sockaddr_in 中) struct in_addr { in_addr_t s_addr; // 32位IPv4地址(網(wǎng)絡字節(jié)序) };
創(chuàng)建 sockaddr_in 對成員進行設定:
- sin_family:我們設為
AF_INET,即IPv4。
- sin_port:使用成員變量_port,但需要使用函數(shù)htons轉為網(wǎng)絡字節(jié)序(即大端)。
- sin_addr:IP地址通常都是點分十進制的字符串,所以需要把IP轉成4字節(jié),然后4字節(jié)轉成網(wǎng)絡序列,庫提供了inet_addr函數(shù),可以完成這個功能。不過這里我們把它直接設為INADDR_ANY,表示本主機上的所有IP都綁定到服務器,這樣的話外部客戶端連接任意IP都能連接到該主機。
- 最后一個成員暫且用不著,不用管。
bind函數(shù)的使用
bind聲明
int bind(int sockfd, const struct sockaddr *addr,socklen_t addrlen);
功能:用來綁定端口。
參數(shù)sockfd:要綁定的套接字描述符(由 socket()
函數(shù)創(chuàng)建)。
參數(shù)sockaddr:指向地址結構體的指針,包含綁定的IP地址和端口號。
參數(shù)addrlen:地址結構體的長度(單位:字節(jié))。
返回值:
- 0:成功。
- 非0:失敗。
代碼示例:
sockaddr_in sd; bzero(&sd, sizeof(sd));//初始化為0 sd.sin_family = AF_INET; sd.sin_port = htons(_port); // sd.sin_addr.s_addr = inet_addr(_ip.c_str()); sd.sin_addr.s_addr = INADDR_ANY; // 綁定ip地址與端口號 int n = bind(_socketfd, (const sockaddr *)&sd, sizeof(sd)); if (n != 0) { LOG(Level::FATAL) << "bind fial"; exit(1); } else { LOG(Level::INFO) << "bind success"; }
由于后面會對sockaddr_in頻繁操作,所以在這里封裝一個InetAddr類放在InetAddr文件里,這里就不講解具體的細節(jié)了,如下:
class InetAddr { public: InetAddr(){} InetAddr(sockaddr_in &peer) : _addr(peer) { _port = ntohs(peer.sin_port);//網(wǎng)絡序列轉為主機序列 _ip = inet_ntoa(peer.sin_addr);//4字節(jié)轉為點分十進制 } InetAddr(uint16_t port, string ip) : _port(port), _ip(ip) { _addr.sin_family = AF_INET; _addr.sin_port = htons(_port); _addr.sin_addr.s_addr = inet_addr(_ip.c_str()); } string tostring_port() { return to_string(_port); } string tostring_ip() { return _ip; } bool operator==(InetAddr addr) { return _port == addr._port && _ip == addr._ip; } sockaddr_in &getaddr() { return _addr; } private: uint16_t _port; string _ip; sockaddr_in _addr; };
void start ()
3.接收信息
UDP協(xié)議數(shù)據(jù)的接收使用的是recvfrom函數(shù),recvfrom函數(shù)的使用:
recvfrom函數(shù)聲明:
ssize_t recvfrom( int sockfd, // 套接字描述符 void *buf, // 接收數(shù)據(jù)的緩沖區(qū) size_t len, // 緩沖區(qū)最大長度 int flags, // 標志位(通常設為0) struct sockaddr *src_addr, // 發(fā)送方的地址信息(可選) socklen_t *addrlen // 地址結構體的長度(輸入輸出參數(shù)) );
sockfd | UDP套接字的網(wǎng)絡文件描述符(需已綁定端口)。 |
buf | 指向接收數(shù)據(jù)的緩沖區(qū),用于存儲接收到的數(shù)據(jù)。 |
len | 緩沖區(qū)的最大容量(單位:字節(jié)),防止數(shù)據(jù)溢出。 |
flags | 控制接收行為的標志位,常用值: 0(默認阻塞)、MSG_DONTWAIT(非阻塞)。 |
src_addr | 指向 struct sockaddr 的指針,用于存儲發(fā)送方的地址信息(IP和端口)。若不需要可設為 NULL。 |
addrlen | 輸入時為 src_addr 結構體的長度,輸出時為實際地址長度。需初始化為 sizeof(struct sockaddr)。 |
返回值 | 含義 |
---|---|
>0 | 成功接收的字節(jié)數(shù)。 |
0 | (僅TCP有意義,UDP一般不會返回0)。 |
-1 | 發(fā)生錯誤,檢查 errno 獲取具體原因 |
注:千萬不要把時間花在記函數(shù)參數(shù)列表上,這么多函數(shù)你是記不了的,只需要看懂就行,函數(shù)的參數(shù)列表在編譯器上通常都會有提示的。只需要把鼠標指針停留在對應的函數(shù)名上,如下:
代碼示例:
while (true) { // 收各個客戶端發(fā)來的消息 sockaddr_in client; socklen_t len = sizeof(client); char buffer[1024]; int n = recvfrom(_socketfd, buffer, sizeof(buffer), 0, (sockaddr *)&client, &len); buffer[n] = '\0'; //回調函數(shù)處理數(shù)據(jù) //...... }
到這里為止通信問題就解決了,只需要靜等客戶端發(fā)數(shù)據(jù)就行。接下來就是數(shù)據(jù)處理。
二、數(shù)據(jù)處理
別忘了我們要做的是群聊服務器,剛才我們不管三七二十一先把通信問題解決,這個的做法是很正確的,因為通信本來就是一個模板化的問題,其次它和其他模塊是解耦的,在編寫過程中并不用考慮數(shù)據(jù)怎么處理。
群聊服務器如何實現(xiàn)?
原理很簡單,把一個客戶發(fā)來的消息再發(fā)送給與它連接的所有客戶。
我們需要做什么呢?
把與它連接的所有客戶的IP和端口號(InetAddr)都存儲起來,當有客戶給它服務器發(fā)信息,服務器再把信息轉發(fā)給所有客戶。
這個功能我們單獨做一個類Route,用來做消息路由,放在新建頭文件Route.hpp里。
Route的實現(xiàn)很簡單,只需要一個成員函數(shù)用來收發(fā)數(shù)據(jù),一個成員變量用來存儲與它連接的客戶端信息。如下:
class Route { public: Route(){} void Handler(int socketfd,string message,InetAddr client); private: vector<InetAddr> _data; };
因為收數(shù)據(jù)的功能在通信模塊已經(jīng)做了,直接讓它把網(wǎng)絡文件描述符,數(shù)據(jù)和客戶端信息傳給Handler就行。其次做兩個小函數(shù),Push:把客戶端信息插入數(shù)組,Pop:把客戶端信息移除數(shù)組。
代碼示例:
class Route { private: void Push(InetAddr peer) { for (auto val : _data) { //如果已經(jīng)有了,就直接退出 if (val == peer) return; } _data.push_back(peer); LOG(Level::INFO)<<peer.tostring_ip()<<'|'<<peer.tostring_port()<<" online"; } bool Pop(InetAddr peer) { //用戶退出連接后,把它移除數(shù)組 _data.erase(peer); return true; } public: Route(){} void Handler(int socketfd,string message,InetAddr client) { Push(client); // 誰發(fā)的信息要知道吧?所以添加客戶的信息 string send_message = client.tostring_ip() + " | " + client.tostring_port() + ": "; send_message += message; // 發(fā)給所有在線的客戶端 for (auto val : _data) { if(val == client) continue; sendto(socketfd, send_message.c_str(), send_message.size(), 0, (sockaddr *)&val.getaddr(), sizeof(val.getaddr())); } } private: vector<InetAddr> _data; };
sendto接口和recvfrom很類似,如下:
sendto的聲明:
ssize_t sendto( int sockfd, // 套接字描述符 const void *buf, // 待發(fā)送數(shù)據(jù)的緩沖區(qū) size_t len, // 數(shù)據(jù)長度(字節(jié)) int flags, // 控制標志(通常設為0) const struct sockaddr *dest_addr, // 目標地址(IP和端口) socklen_t addrlen // 目標地址結構體的長度 );
參數(shù)詳解
sockfd | UDP 套接字的描述符(無需提前連接)。 |
buf | 指向待發(fā)送數(shù)據(jù)的緩沖區(qū)(如字符串、二進制數(shù)據(jù))。 |
len | 數(shù)據(jù)的實際長度(單位:字節(jié))。 |
flags | 控制發(fā)送行為的標志位,常用值: 0(默認阻塞)、MSG_DONTWAIT(非阻塞)。 |
dest_addr | 指向目標地址的結構體(如 sockaddr_in),需強制轉換為 sockaddr*。 |
addrlen | 目標地址結構體的長度(如 sizeof(struct sockaddr_in))。 |
返回值
返回值 | 含義 |
---|---|
>0 | 成功發(fā)送的字節(jié)數(shù)(可能與 len 不同,需檢查是否完全發(fā)送)。 |
-1 | 發(fā)送失敗,檢查 errno 獲取具體錯誤原因。 |
這里有個很尷尬的事,服務器并不知道客戶端什么時候退出,可以說是UDP協(xié)議的特點吧,所以Pop函數(shù)什么時候調用并不知道,除非客戶在退出時給服務器發(fā)一條特殊信息表明客戶要退出。這里先這樣。
現(xiàn)在為止服務器相關的通信接口和數(shù)據(jù)處理方法已經(jīng)準備好了,接下來實現(xiàn)UdpClient.cc文件,即main函數(shù),把服務器調用起來。
主要實現(xiàn)以下幾點:
- 要給服務器設定端口號,需要從程序外部傳入,即命令行參數(shù)。
- 創(chuàng)建數(shù)據(jù)處理的類(Route)。
- 創(chuàng)建服務器,把端口號和數(shù)據(jù)處理方法(即回調方法)傳入,啟動服務器。
1,2比較簡單,接下來講解第3點。
還記得開頭在UdpServer里我們缺少的成員變量數(shù)據(jù)處理函數(shù)嗎?現(xiàn)在我們知道它是誰了,即:
- void Handler(int socketfd,string message,InetAddr client)
這里我們寫規(guī)范一點,聲明一個類型:
- using funcType = function<void(int, string, InetAddr)>;
然后添加成員變量funcType _func,并在構造函數(shù)的參數(shù)列表進行初始化。
最后在Start中調用_func函數(shù)(即回調),如下:
void Start() { while (true) { // 收各個客戶端發(fā)來的消息 sockaddr_in client; socklen_t len = sizeof(client); char buffer[1024]; int n = recvfrom(_socketfd, buffer, sizeof(buffer), 0, (sockaddr *)&client, &len); buffer[n] = '\0'; _func(_socketfd,string(buffer),InetAddr(client)); } }
可優(yōu)化點:把_func當作任務,推入線程池。
現(xiàn)在創(chuàng)建UdpServer兩個參數(shù),一個是port(端口號),另一個是func(數(shù)據(jù)處理方法),對于func我們可以以lambda表達式的方式傳入。如下:
int main(int argc, char *argv[]) { if (argc != 2) { std::cerr << "Usage" << argv[0] << "port" << std::endl; return 1; } std::string port = argv[1]; // 路由 Route rt; // 通信 unique_ptr<UdpServer> us = make_unique<UdpServer>(stoi(port), [&](int socketfd, string meassge, InetAddr client) { rt.Handler(socketfd, meassge, client); }); us->Init(); us->Start(); return 0; }
客戶端
框架設計
客戶端將來是要連接服務器的,所以需要傳入服務器IP和端口,而且是從程序外部出入。即給main函數(shù)傳入命令行參數(shù)。注意判斷參數(shù)是否合法。
然后和服務器一樣需要打開網(wǎng)絡文件。如下:
int main(int argc, char *argv[]) { if (argc != 3) { std::cerr << "Usage: " << argv[0] << " server_op server_port" << std::endl; return 1; } int socketfd = socket(AF_INET, SOCK_DGRAM, 0); if (socketfd < 0) { LOG(Level::ERROR) << "socket() fail"; exit(1); } else { LOG(Level::INFO) << "socket() succee _socketfd:" << socketfd; } //包裝客戶端信息 InetAddr addr(std::stoi(argv[2]), argv[1]); //信息收發(fā) //...... return 0; }
三、端口綁定
客戶端的實現(xiàn)可比服務器簡單多了,因為它不需要我們手動綁定IP和端口號,系統(tǒng)幫我們做了。但要清楚我們是可以自己綁定的,不過會有很多問題,比如主機里有很多進程,可能端口號會綁重,讓系統(tǒng)自動分配比較安全。
那服務器的端口號為什么不也讓系統(tǒng)動態(tài)分配呢?我們自己綁多麻煩。其實是這樣的,服務器是需要供給很多客戶去使用,需要客戶端填寫服務器端口。所以服務器端口一定要明確,系統(tǒng)動態(tài)分配的話,在程序外部就無法知道服務器端口號了。
四、收發(fā)信息
收發(fā)信息是一個不斷重復的操作,所以寫成一個死循環(huán),但要注意不要把收信息和發(fā)信息寫在一起,要不然發(fā)信息阻塞時就收不到信息,收信息阻塞時也發(fā)不了信息。
所以它們應該并發(fā)地進行,即使用兩個子線程。
代碼示例:
void Write(int socketfd, InetAddr &addr) { //提前發(fā)一條信息告訴服務器我已經(jīng)上線 string str="online"; sendto(socketfd, str.c_str(), sizeof(str), 0, (const sockaddr *)&addr.getaddr(), sizeof(addr.getaddr())); while (true) { std::string message; cout<<"Please Enter# "; std::getline(std::cin, message); sendto(socketfd, message.c_str(), sizeof(message), 0, (const sockaddr *)&addr.getaddr(), sizeof(addr.getaddr())); } } void Read(int socketfd) { while (true) { sockaddr_in sd; char buffer[1024]; socklen_t len = sizeof(sd); int n = recvfrom(socketfd, buffer, sizeof(buffer) - 1, 0, (sockaddr *)&sd, &len); buffer[n] = '\0'; std::cout << buffer << std::endl; } }
main函數(shù)中
thread td_read([&](){ Write(socketfd,addr); }); thread td_write([&](){ Read(socketfd); }); td_read.join(); td_read.join();
到這里這個工程就完成了,下面是運行結果。
效果展示:
五、源碼
UdpServer.hpp
// 用條件編譯,防止頭文件重復包含 #ifndef UDP_SERVER #define UDP_SERVER #include <iostream> #include <sys/socket.h> #include <netinet/in.h> #include <netinet/ip.h> #include <strings.h> #include <string> #include <assert.h> #include <arpa/inet.h> #include <functional> #include "InetAddr.hpp" #include "Log.hpp" using namespace std; using namespace my_log; using funcType = function<void(int, string, InetAddr)>; class task { public: task() {} task(funcType func, int socketfd, string message, InetAddr client) : _func(func), _socketfd(socketfd), _message(message), _client(client) { } void operator()() { assert(_socketfd != -1); _func(_socketfd, _message, _client); } private: funcType _func; int _socketfd; string _message; InetAddr _client; }; class UdpServer { public: UdpServer(uint16_t port, const funcType &func) : _socketfd(-1), _port(port), _func(func) { } void Init() { // 打開網(wǎng)絡文件 IPv4 數(shù)據(jù)包 udp _socketfd = socket(AF_INET, SOCK_DGRAM, 0); if (_socketfd < 0) { LOG(Level::ERROR) << "socket() fail"; exit(1); } else { LOG(Level::INFO) << "socket() succee _socketfd:" << _socketfd; } sockaddr_in sd; bzero(&sd, sizeof(sd)); sd.sin_family = AF_INET; sd.sin_port = htons(_port); // sd.sin_addr.s_addr = inet_addr(_ip.c_str()); sd.sin_addr.s_addr = INADDR_ANY; // 綁定ip地址與端口號 int n = bind(_socketfd, (const sockaddr *)&sd, sizeof(sd)); if (n < 0) { LOG(Level::FATAL) << "bind fial"; exit(1); } else { LOG(Level::INFO) << "bind success"; } } void Start() { while (true) { // 收各個客戶端發(fā)來的消息 sockaddr_in client; socklen_t len = sizeof(client); char buffer[1024]; int n = recvfrom(_socketfd, buffer, sizeof(buffer), 0, (sockaddr *)&client, &len); buffer[n] = '\0'; _func(_socketfd,string(buffer),InetAddr(client)); } } ~UdpServer() { } private: int _socketfd; uint16_t _port; funcType _func; }; #endif
UdpServer.cc
#include <iostream> #include <memory> #include "UdpServer.hpp" #include "InetAddr.hpp" #include "Route.hpp" int main(int argc, char *argv[]) { if (argc < 2) { // LOG(Level::FATAL)<<"input error"; std::cerr << "Usage" << argv[0] << "port" << std::endl; return 1; } std::string port = argv[1]; // 路由 Route rt; // 通信 unique_ptr<UdpServer> us = make_unique<UdpServer>(stoi(port), [&](int socketfd, string meassge, InetAddr client) { rt.Handler(socketfd, meassge, client); }); us->Init(); us->Start(); return 0; }
UdpClient.cc
#include <iostream> #include <sys/socket.h> #include <netinet/in.h> #include <netinet/ip.h> #include <strings.h> #include <arpa/inet.h> #include <thread> #include "InetAddr.hpp" #include "Log.hpp" using namespace my_log; void Write(int socketfd, InetAddr &addr) { string str="online"; sendto(socketfd, str.c_str(), sizeof(str), 0, (const sockaddr *)&addr.getaddr(), sizeof(addr.getaddr())); while (true) { std::string message; cout<<"Please Enter# "; std::getline(std::cin, message); sendto(socketfd, message.c_str(), sizeof(message), 0, (const sockaddr *)&addr.getaddr(), sizeof(addr.getaddr())); } } void Read(int socketfd) { while (true) { sockaddr_in sd; char buffer[1024]; socklen_t len = sizeof(sd); int n = recvfrom(socketfd, buffer, sizeof(buffer) - 1, 0, (sockaddr *)&sd, &len); buffer[n] = '\0'; std::cout << buffer << std::endl; } } int main(int argc, char *argv[]) { if (argc != 3) { std::cerr << "Usage: " << argv[0] << " server_op server_port" << std::endl; return 1; } int socketfd = socket(AF_INET, SOCK_DGRAM, 0); if (socketfd < 0) { LOG(Level::ERROR) << "socket() fail"; exit(1); } else { LOG(Level::INFO) << "socket() succee _socketfd:" << socketfd; } InetAddr addr((uint16_t)std::stoi(argv[2]), argv[1]); thread td_read([&](){ Write(socketfd,addr); }); thread td_write([&](){ Read(socketfd); }); td_read.join(); td_read.join(); return 0; }
InteAddr.hpp
#pragma once #include <iostream> #include <string> #include <sys/socket.h> #include <netinet/in.h> #include <netinet/ip.h> using namespace std; class InetAddr { public: InetAddr(){} InetAddr(sockaddr_in &peer) : _addr(peer) { _port = ntohs(peer.sin_port); _ip = inet_ntoa(peer.sin_addr); } InetAddr(uint16_t port, string ip) : _port(port), _ip(ip) { _addr.sin_family = AF_INET; _addr.sin_port = htons(_port); _addr.sin_addr.s_addr = inet_addr(_ip.c_str()); } string tostring_port() { return to_string(_port); } string tostring_ip() { return _ip; } bool operator==(InetAddr addr) { return _port == addr._port && _ip == addr._ip; } sockaddr_in &getaddr() { return _addr; } private: uint16_t _port; string _ip; sockaddr_in _addr; };
Route.hpp
#pragma once #include <iostream> #include <string> #include <vector> #include "Log.hpp" #include "InetAddr.hpp" using namespace std; using namespace my_log; class Route { private: void Push(InetAddr peer) { for (auto val : _data) { if (val == peer) return; } _data.push_back(peer); LOG(Level::INFO)<<peer.tostring_ip()<<'|'<<peer.tostring_port()<<" online"; } bool Pop() { return true; } public: Route(){} void Handler(int socketfd,string message,InetAddr client) { Push(client); // 處理信息 string send_message = client.tostring_ip() + " | " + client.tostring_port() + ": "; send_message += message; // 發(fā)給所有在線的客戶端 for (auto val : _data) { if(val == client) continue; sendto(socketfd, send_message.c_str(), send_message.size(), 0, (sockaddr *)&val.getaddr(), sizeof(val.getaddr())); } } private: vector<InetAddr> _data; };
到此這篇關于C++基于UDP協(xié)議的群聊服務器開發(fā)實現(xiàn)的文章就介紹到這了,更多相關C++ UDP 群聊內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
Qt創(chuàng)建SQlite數(shù)據(jù)庫的示例代碼
本文主要介紹了Qt創(chuàng)建SQlite數(shù)據(jù)庫的示例代碼,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2022-05-05利用C++實現(xiàn)從std::string類型到bool型的轉換
利用C++實現(xiàn)從std::string類型到bool型的轉換。需要的朋友可以過來參考下。希望對大家有所幫助2013-10-10