#include #include #include #include #include #include #include #include #include #include #define MAXLINE 512 #define NAMELEN 20 #define PORT 8080 int sockfd; //發送消息的函數snd void snd() { char name[NAMELEN]; char buff[MAXLINE]; gets(name); write(sockfd,name,strlen(name)); while(1) { gets(buff); write(sockfd,buff,strlen(buff)); if(strcmp("bye",buff)==0) { exit(0); } } } int main(int argc,char **argv) { pthread_t thread; struct sockaddr_in servaddr; if(argc != 2) { printf("usage: echo ip\n"); return -1; } //調用socket函數創建客戶端的套接字 sockfd=socket(AF_INET,SOCK_STREAM,0); if(sockfd<0) { printf("Socket create failed\n"); return -1; } //初始化服務器端的地址 servaddr.sin_family=AF_INET; servaddr.sin_port=htons(PORT); if(inet_aton(argv[1],&servaddr.sin_addr)<0) { printf("inet_aton error.\n"); return -1; } //調用connect函數實現與服務器端建立連接 printf("Connecting...\n"); if(connect(sockfd,(struct sockaddr*)&servaddr,sizeof(servaddr))<0) { printf("Connect server failed.\n"); return -1; } //從此處開始程序分做兩個線程 //創建發送消息的線程，調用了發送消息的函數snd pthread_create(&thread,NULL,(void*)(&snd),NULL); //從此處開始向下為接收消息的線程 char buff[MAXLINE]; int len; while(1) { if((len=read(sockfd,buff,MAXLINE))>0) { buff[len]=0; printf("\n%s\n\n",buff); } } return 0; }