代碼：
#include <sys/types.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#define PORT 6666 //1024~49151
#define IP "192.168.122.130" //ifconfig查看本機IP
#include <pthread.h>
//需要傳入分之線程的數據類型
struct Climsg
{int newfd;struct sockaddr_in cin;
};
void *deal_cli_msg(void *arg);
int main(int argc, const char *argv[])
{//創建流式套接字int sfd = socket(AF_INET,SOCK_STREAM,0);if(sfd < 0){ERRO_MES("socket");return -1;}printf("sfd = %d\n",sfd);//綁定服務器的IP和端口--->必須綁定//填充地址信息結構體，真實的地址信息結構體根據地質族制定//AF_INET： man 7 ip;struct sockaddr_in sin;sin.sin_family = AF_INET;//必須填AF_INET;sin.sin_port = htons(PORT); //端口號：1024~49151;sin.sin_addr.s_addr = inet_addr(IP); //本機IP ifconfig查看;if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin)) < 0){ERRO_MES("bind");return -1;}printf("bind success\n");//將套接字設置為被動監聽狀態if(listen(sfd,10) < 0){ERRO_MES("listen");return -1;}printf("listen success\n");//設置允許端口號被快速復用int reuse = 1;if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0){ERRO_MES("setsockopt");return -1;}printf("允許端口快速重用成功\n");//從已完成鏈接的隊列中獲取一個客戶端信息，生成一個新的文件//該文件描述符才是與客戶端通信的文件描述符struct sockaddr_in cin;socklen_t addrlen = sizeof(cin);int newfd = -1;pthread_t tid;struct Climsg info;while(1){ //主線程只負責連接newfd = accept(sfd,(struct sockaddr*)&cin,&addrlen);if(newfd < 0){ERRO_MES("accept");return -1;}printf("[%s : %d] newfd = %d,客戶端鏈接成功\n",\inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),newfd);info.newfd = newfd;info,cin =cin;if(pthread_create(&tid,NULL,deal_cli_msg,(void *)&info) != 0){fprintf(stderr,"pthread_create failed __%d__",__LINE__);return -1;}pthread_detach(tid); //分離線程}close(sfd);return 0;
}
void *deal_cli_msg(void *arg)
{int newfd = ((struct Climsg*)arg)->newfd;struct sockaddr_in cin = ((struct Climsg*)arg)->cin;//分之線程只負責交互//從指定的文件套接字char buf[128]="";ssize_t res = 0;while(1){bzero(buf,sizeof(buf));//接收數據res = recv(newfd,buf,sizeof(buf),0);if(res < 0){ERRO_MES("recv");break;}else if(0 == res){printf("[%s : %d] newfd = %d,客戶下線\n",\inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),newfd);break;}printf("newfd :%d\t buf = %s\n",newfd,buf);//發送數據strcat(buf,"----");if(send(newfd,buf,sizeof(buf),0) < 0){ERRO_MES("send");break;}printf("send success\n");}close(newfd);pthread_exit(NULL);
}
一、多線程中的newfd，能否修改成全局，為什么？
答：不能修改成全局；
當使用全局變量時，線程中的newfd會發生覆蓋；
二、多線程中分支線程的newfd能否不另存，直接用指針間接訪問主線程中的newfd，為什么？
答：不能
?現象表明，線程中的newfd會發生覆蓋，只保留最后一次newfd的值
)
