socket C/C++程式設計（8）server端多執行緒處理clients佇列
阿新 • • 發佈：2019-02-08
1. 採用C++11的標準執行緒庫(linux之pthread為例)實現多執行緒(test.cpp)
#include <stdio.h>
#include <string.h>
#ifdef WIN32
#include <windows.h>
#else
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <stdlib.h>
#include <arpa/inet.h> makefile如下：
test: test.cpp
g++ test.cpp -o test -std=c++11 -lpthread
server端編譯執行sudo make，如下圖，
clients端連線併發送資料，如下圖，
linux server伺服器端收到的資料，如下圖，
2. 採用C++11的標準執行緒庫(windows 10為例)實現多執行緒(test.cpp)
#include <stdio.h>
#include <string.h>
#include <thread>
#ifdef WIN32
#include <windows.h>
#define socklen_t int
#else
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <stdlib.h>
#include <arpa/inet.h>
//#include <thread>
#endif
using namespace std;
class TcpThread{ // 多執行緒類
public:
void Main(){ // 每一個執行緒的入口函式
char buf[1024] = {0};
for(;;){
int lenRecv = recv(client,buf, sizeof(buf)-1,0); // server讀取client端鍵入的資料(第二類socket的控制代碼，儲存資料的地方,flag)
if(lenRecv <= 0) break;
buf[lenRecv] = '\0'; // 客戶端鍵入資料的末尾兩位賦值‘、0’
if(strstr(buf,"quit")!= NULL){
break; // 字串匹配函式，匹配到使用者傳送了"quit"
}
printf("Recvd data: %s \n Len: %d \n", buf, lenRecv); // 伺服器顯示客戶端鍵入的字串長度
}
#ifdef WIN32 // 讀取資料的第二類socket建立後要記得關閉
closesocket(client);
#else
close(client);
#endif
delete this; // 呼叫完後，自己清理調第二類socket的物件
}
int client;// 每一個客戶端的第二類socket
};
int main(int argc, char *argv[]){
// 初始化”ws2_32.lib”
#ifdef WIN32
WSADATA ws;
WSAStartup(MAKEWORD(2,2), &ws);
#endif
// 建立第一類socket
int sock = socket(AF_INET,SOCK_STREAM,0);
if(sock == -1){
printf("create sock error!\n");
return -1;
}
// TCP Server指定埠並設定服務端埠的屬性，返回(sockaddr*)&saddr
unsigned short port = 8080; // 預設埠號
if(argc > 1){
port = atoi(argv[1]);
}
sockaddr_in saddr; // 宣告埠
saddr.sin_family = AF_INET; // TCPIP協議
saddr.sin_port = htons(port); // 繫結埠號, htons()之host-to-network
saddr.sin_addr.s_addr = 0; //或htonl(0) 伺服器接受的IP地址 0表示接受任意內外網IP
// 繫結埠到指定的socket，輸入(sockaddr*)&saddr
if(::bind(sock, (sockaddr*)&saddr, sizeof(saddr))!=0){
printf("OS bind socks to this port %d failed\n", port);
return -2;
}
printf("OS bind this port %d to sockets successfully!\n", port);
listen(sock, 10); // 允許使用者連線函式（客戶socket（一個客戶一個socket），最大請求數佇列的長度，）
for(;;){ // 支援多個客戶端第二類socket
sockaddr_in caddr; // 結構體：儲存客戶端的相關資訊:埠號和IP地址s
socklen_t len = sizeof(caddr);
int client = accept(sock,(sockaddr*)&caddr,&len); // 第二類socket: 建立一個socket專門讀取緩衝區clients（這裡緩衝區大小如上行listen程式碼所示為10）
if(client<=0)break;
printf("accept client %d", client);
char *ip = inet_ntoa(caddr.sin_addr); // 客戶端IP地址轉字串
unsigned short cport = ntohs(caddr.sin_port);// 客戶端埠號（網路位元組序轉本地位元組序）
printf("client ip: %s, port is %d\n", ip, cport); // 列印客戶端連線資訊
TcpThread *th = new TcpThread(); // 建立第二類socket物件
th->client = client; // 傳遞client到TcpThread物件
thread sth(&TcpThread::Main,th); // 啟動執行緒的入口函式main(),引數為thread，函式庫為thread sth()
sth.detach();
}
#ifdef WIN32 // 埠的第一類socket，不再互動後也要記得關閉,先二後一時堆疊思想
closesocket(sock);
#else
close(sock);
#endif
getchar();
return 0;
}
Visual Studio2012中”除錯”->”執行”。
clients端連線併發送資料，如下圖，
windows 10 server伺服器端收到的資料，如下圖，
