多執行緒實現伺服器與多個客戶端通訊,客戶端之間相互不干擾
1,服務端建立ServerSocket繫結埠號,迴圈呼叫accept()方法
2,客戶端建立一個socket並請求和伺服器端連線
3,伺服器端接受客戶端請求,建立socket與該客戶建立連線
4,兩個socket在一個單獨的執行緒上通話
5,伺服器端繼續等待新的連線
也就是說當有一個新的客戶端與服務端連線,就建立一個新的socket並在這個執行緒裡面通訊。
客戶端主要程式碼:
char name[30]={0};
printf("請輸入伺服器的主機名或者ip\n");
scanf("%s",name);
struct hostent *h;
//獲取伺服器資訊
h=gethostbyname(name);
if(NULL==h)
{
perror("geyhostbyname");
exit(1);
}
//初始化套接字
int sockfd=socket(AF_INET,SOCK_STREAM,0);
if(-1==sockfd)
{
perror("socket");
exit(2);
}
struct sockaddr_in server_addr;
server_addr.sin_family=AF_INET;
server_addr.sin_port=htons(portnum);
server_addr.sin_addr=*((struct in_addr *)h->h_addr_list[0]);
if(-1==connect(sockfd,(struct sockaddr *)&server_addr,sizeof(server_addr)))
{
perror("connect");
exit(3);
}
伺服器主要程式碼:
//初始化套接字
int sockfd=socket(AF_INET,SOCK_STREAM,0);
if(-1==sockfd)
{
perror("socket");
exit(1);
}
//繫結埠和ip;
struct sockaddr_in server_addr; //struct sockaddr_in為結構體型別 ,server_addr為定義的結構體
server_addr.sin_family=AF_INET; //Internet地址族=AF_INET(IPv4協議)
server_addr.sin_port=htons(portnum); //將主機位元組序轉化為網路位元組序 ,portnum是埠號
(server_addr.sin_addr).s_addr=htonl(INADDR_ANY);//IP地址
if(-1==bind(sockfd,(struct sockaddr *)&server_addr,sizeof(server_addr))) //套接字與埠繫結
{
perror("bind");
exit(6);
}
//開啟監聽
if(-1==listen(sockfd,5)) //5是最大連線數,指伺服器最多連線5個使用者
{
perror("listen");
exit(7);
}
while(1)
{
struct sockaddr_in client_addr;
int size=sizeof(client_addr);
int new_fd=accept(sockfd,(struct sockaddr *)&client_addr,&size); //sockfd伺服器的socket描述字,&client_addr指向struct sockaddr *的指標,&size指向協議地址長度指標
if(-1==new_fd)
{
perror("accept");
continue; //進行下一次迴圈
}
printf("accept client ip:%s:%d\n",inet_ntoa(client_addr.sin_addr),client_addr.sin_port);
//inet_ntoa將一個十進位制網路位元組序轉換為點分十進位制IP格式的字串。
int ret;
int pthread_id;
pthread_create((pthread_t *)&pthread_id,NULL,net_thread,(void *)&new_fd);
if(-1==ret)
{
perror("pthread_create");
close(new_fd);
continue;
}
}
close(sockfd);