群暉nas可以做網站嗎如何建立網站平臺
最近在學習最基礎的socket網絡編程,在Tcpserver開啟多線程并發(fā)處理時遇到了一些問題!
說明
在linux以及Windows的共享文件夾進行編寫的,所以代碼中有的部分使用
#ifdef WIN64
...
#else
...
#endif
進入正題!!!
先來看看代碼~
#include <string.h>
#include <stdlib.h>
#include <stdio.h>#ifdef _WIN64
#include<windows.h>
#define socklen_t int
#else
#include <sys/types.h>
#include <sys/socket.h>
#include <unistd.h>
#include <arpa/inet.h>
#define closesocket close //因為linux和Windows下不同,所以定義了一個宏
#endif #include <thread>
using namespace std;
class TcpThread //建立一個線程類
{
public:void Main() //入口函數(shù){char buf[1024] = { 0 };for (;;){int recvlen = recv(client, buf, sizeof(buf) - 1, 0);if (recvlen <= 0) break;buf[recvlen] = '\0';//在結尾加\0if (strstr(buf, "quit") != NULL) {char re[] = "quit success\n";send(client, re, strlen(re) + 1, 0);break;}int sendlen = send(client, "ok\n", 4, 0);printf("recv %s\n", buf);}closesocket(client); //關閉delete this;//要確保TcpThread 是new出來的}int client = 0;
};#include<stdio.h>
int main( int argc, char *argv[])
{
#ifdef WIN64WSADATA ws;WSAStartup(MAKEWORD(2, 2), &ws);
#endif // WIN64int sock=socket(AF_INET, SOCK_STREAM, 0);if (sock == -1){printf("create socket failed!\n");return -1;}printf("[%d]", sock);unsigned short port = 8080;if (argc > 1) //如果輸入端口,則使用輸入的,否則用8080{port = atoi(argv[1]);//傳遞端口號}sockaddr_in saddr;saddr.sin_family = AF_INET;saddr.sin_port = htons(port);//小端轉大端saddr.sin_addr.s_addr = htonl(0);if (::bind(sock, (sockaddr*)&saddr, sizeof(saddr)) != 0){printf("bind port %d faild!\n", port);return -2;}else {printf("bind port %d success!\n", port);}listen(sock, 10);for (;;){sockaddr_in caddr;socklen_t len = sizeof(caddr);int client = accept(sock, (sockaddr* ) & caddr, &len);if (client <= 0) break;printf("accept client %d\n", client);char *ip = inet_ntoa(caddr.sin_addr);unsigned short cport = ntohs(caddr.sin_port);printf("client ip is %s,port is %d\n", ip, cport);TcpThread *th = new TcpThread(); //new出來th->client = client;//傳入創(chuàng)建好的clientthread sth(&TcpThread::Main, th);//啟動線程sth.detach();//釋放主線程擁有的子線程的資源}closesocket(sock);
//#if WIN64
// closesocket(sock);
// closesocket(client);
//#else
// close(sock);
// close(sock);
//#endif // WIN64return 0;}
這時候直接在linux在make main
會報錯
這說明我們使用c++11,這里我們需要寫一個makefile,接著我們
vim makefile
在里面我們寫如下代碼:
然后在make
,這里發(fā)現(xiàn)成功了,然后./tcpserver
嘗試創(chuàng)建多個線程, 在主線程發(fā)現(xiàn)成功了
用戶開始連接,就報錯
這時候我們就要注意了,是makefile里面缺少 -pthread
;
接著在編譯運行,發(fā)現(xiàn)成功了!!!
創(chuàng)建多線程,進行測試,
打開兩個端口telnet 192.168.xxx.xxx 8081
連接成功如下:
分別在兩個里面發(fā)送消息1,2,收到了回復
然后主線程收到消息,表示成功了!
注意:
C++是支持多線程,但是需要注意以下三點:
- 必須包含頭文件#include
- 必須有編譯選項-std=c++11
- 必須有編譯選項-pthread,否則運行出現(xiàn)
Enable multithreading to use std::thread: Operation not permitted
。同時-lpthread和-pthread一樣,但是建議使用-pthread。因為編譯選項中指定 -pthread 會附加一個宏定義 -D_REENTRANT,該宏會導致 libc 頭文件選擇那些thread-safe的實現(xiàn);鏈接選項中指定 -pthread 則同 -lpthread 一樣,只表示鏈接 POSIX thread 庫。由于 libc 用于適應 thread-safe 的宏定義可能變化,因此在編譯和鏈接時都使用 -pthread 選項而不是傳統(tǒng)的 -lpthread 能夠保持向后兼容,并提高命令行的一致性。
小白初次學習,希望大佬們多多指教!!!