Linux网络编程用C语言实现的聊天程序(同步通信).docx

《Linux网络编程用C语言实现的聊天程序(同步通信).docx》由会员分享，可在线阅读，更多相关《Linux网络编程用C语言实现的聊天程序(同步通信).docx（14页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、Linux网络编程：用C语言实现的聊天程序（同步通信）通过TCP协议，用C语言实现的同步聊天程序，注释写的比较详细，个人觉得对字符串处理比较充分，能够正常编译运行，拿出来和大家分享一下！1、客户端源代码：cpp view plaincopyprint?1. #include 2. #include 3. #include 4. #include 5. #include 6. #include 7. #include 8. #include 9. #include 10. 11. #defineBUFLEN10 12. 13. intmain(intargc,char*argv)14. 15.

2、intsockfd;16. structsockaddr_ins_addr;17. socklen_tlen;18. unsignedintport;19. charbufBUFLEN;20. 21. /*建立socket*/22. if(sockfd=socket(AF_INET,SOCK_STREAM,0)=-1)23. perror(socket);24. exit(errno);25. else26. printf(socketcreatesuccess!n);27. 28. /*设置服务器端口*/29. if(argv2)30. port=atoi(argv2);31. else32

3、. port=4567;33. /*设置服务器ip*/34. bzero(&s_addr,sizeof(s_addr);35. s_addr.sin_family=AF_INET;36. s_addr.sin_port=htons(port);37. if(inet_aton(argv1,(structin_addr*)&s_addr.sin_addr.s_addr)=0)38. perror(argv1);39. exit(errno);40. 41. /*开始连接服务器*/42. if(connect(sockfd,(structsockaddr*)&s_addr,sizeof(struc

4、tsockaddr)=-1)43. perror(connect);44. exit(errno);45. else46. printf(conncetsuccess!n);47. 48. while(1)49. /*接收消息*/50. bzero(buf,BUFLEN);51. len=recv(sockfd,buf,BUFLEN,0);52. if(len0)53. printf(服务器发来的消息是：%s,共有字节数是:%dn,buf,len);54. else55. if(len0)85. printf(消息发送成功，本次共发送的字节数是：%dn,len);86. else87. pri

5、ntf(消息发送失败!n);88. break;89. 90. 91. /*关闭连接*/92. close(sockfd);93. 94. return0;95. #include #include #include #include #include #include #include #include #include #define BUFLEN 10int main(int argc, char *argv) int sockfd; struct sockaddr_in s_addr; socklen_t len; unsigned int port; char bufBUFLEN;

6、/*建立socket*/ if(sockfd = socket(AF_INET, SOCK_STREAM, 0) = -1) perror(socket); exit(errno); else printf(socket create success!n); /*设置服务器端口*/ if(argv2) port = atoi(argv2); else port = 4567; /*设置服务器ip*/ bzero(&s_addr, sizeof(s_addr); s_addr.sin_family = AF_INET; s_addr.sin_port = htons(port); if (ine

7、t_aton(argv1, (struct in_addr *)&s_addr.sin_addr.s_addr) = 0) perror(argv1); exit(errno); /*开始连接服务器*/ if(connect(sockfd,(struct sockaddr*)&s_addr,sizeof(struct sockaddr) = -1) perror(connect); exit(errno); else printf(conncet success!n); while(1) /*接收消息*/ bzero(buf,BUFLEN); len = recv(sockfd,buf,BUF

8、LEN,0); if(len 0) printf(服务器发来的消息是：%s,共有字节数是: %dn,buf,len); else if(len 0) printf(消息发送成功，本次共发送的字节数是：%dn,len); else printf(消息发送失败!n); break; /*关闭连接*/ close(sockfd); return 0;2、服务器源代码：cpp view plaincopyprint?1. #include 2. #include 3. #include 4. #include 5. #include 6. #include 7. #include 8. #includ

9、e 9. #include 10. 11. #defineBUFLEN10 12. 13. intmain(intargc,char*argv)14. 15. intsockfd,newfd;16. structsockaddr_ins_addr,c_addr;17. charbufBUFLEN;18. socklen_tlen;19. unsignedintport,listnum;20. 21. /*建立socket*/22. if(sockfd=socket(AF_INET,SOCK_STREAM,0)=-1)23. perror(socket);24. exit(errno);25.

10、else26. printf(socketcreatesuccess!n);27. /*设置服务器端口*/28. if(argv2)29. port=atoi(argv2);30. else31. port=4567;32. /*设置侦听队列长度*/33. if(argv3)34. listnum=atoi(argv3);35. else36. listnum=3;37. /*设置服务器ip*/38. bzero(&s_addr,sizeof(s_addr);39. s_addr.sin_family=AF_INET;40. s_addr.sin_port=htons(port);41. if

11、(argv1)42. s_addr.sin_addr.s_addr=inet_addr(argv1);43. else44. s_addr.sin_addr.s_addr=INADDR_ANY;45. /*把地址和端口帮定到套接字上*/46. if(bind(sockfd,(structsockaddr*)&s_addr,sizeof(structsockaddr)=-1)47. perror(bind);48. exit(errno);49. else50. printf(bindsuccess!n);51. /*侦听本地端口*/52. if(listen(sockfd,listnum)=-

12、1)53. perror(listen);54. exit(errno);55. else56. printf(theserverislistening!n);57. while(1)58. printf(*聊天开始*n);59. len=sizeof(structsockaddr);60. if(newfd=accept(sockfd,(structsockaddr*)&c_addr,&len)=-1)61. perror(accept);62. exit(errno);63. else64. printf(正在与您聊天的客户端是：%s:%dn,inet_ntoa(c_addr.sin_ad

13、dr),ntohs(c_addr.sin_port);65. while(1)66. _retry:67. /*发送消息*/68. bzero(buf,BUFLEN);69. printf(请输入发送给对方的消息：);70. /*fgets函数：从流中读取BUFLEN-1个字符*/71. fgets(buf,BUFLEN,stdin);72. /*打印发送的消息*/73. /fputs(buf,stdout); 74. if(!strncasecmp(buf,quit,4)75. printf(server请求终止聊天!n);76. break;77. 78. /*如果输入的字符串只有n，即回

14、车，那么请重新输入*/79. if(!strncmp(buf,n,1)80. printf(输入的字符只有回车，这个是不正确的！n);81. goto_retry;82. 83. /*如果buf中含有n，那么要用strlen(buf)-1，去掉n*/84. if(strchr(buf,n)85. len=send(newfd,buf,strlen(buf)-1,0);86. /*如果buf中没有n，则用buf的真正长度strlen(buf)*/87. else88. len=send(newfd,buf,strlen(buf),0);89. if(len0)90. printf(消息发送成功，

15、本次共发送的字节数是：%dn,len);91. else92. printf(消息发送失败!n);93. break;94. 95. /*接收消息*/96. bzero(buf,BUFLEN);97. len=recv(newfd,buf,BUFLEN,0);98. if(len0)99. printf(客户端发来的信息是：%s,共有字节数是:%dn,buf,len);100. else101. if(len是；n-否?);112. bzero(buf,BUFLEN);113. fgets(buf,BUFLEN,stdin);114. if(!strncasecmp(buf,y,1)115.

16、printf(server退出!n);116. break;117. 118. 119. /*关闭服务器的套接字*/120. close(sockfd);121. return0;122. #include #include #include #include #include #include #include #include #include #define BUFLEN 10int main(int argc, char *argv) int sockfd, newfd; struct sockaddr_in s_addr, c_addr; char bufBUFLEN; sockle

17、n_t len; unsigned int port, listnum; /*建立socket*/ if(sockfd = socket(AF_INET, SOCK_STREAM, 0) = -1) perror(socket); exit(errno); else printf(socket create success!n); /*设置服务器端口*/ if(argv2) port = atoi(argv2); else port = 4567; /*设置侦听队列长度*/ if(argv3) listnum = atoi(argv3); else listnum = 3; /*设置服务器ip

18、*/ bzero(&s_addr, sizeof(s_addr); s_addr.sin_family = AF_INET; s_addr.sin_port = htons(port); if(argv1) s_addr.sin_addr.s_addr = inet_addr(argv1); else s_addr.sin_addr.s_addr = INADDR_ANY; /*把地址和端口帮定到套接字上*/ if(bind(sockfd, (struct sockaddr*) &s_addr,sizeof(struct sockaddr) = -1) perror(bind); exit(e

19、rrno); else printf(bind success!n); /*侦听本地端口*/ if(listen(sockfd,listnum) = -1) perror(listen); exit(errno); else printf(the server is listening!n); while(1) printf(*聊天开始*n); len = sizeof(struct sockaddr); if(newfd = accept(sockfd,(struct sockaddr*) &c_addr, &len) = -1) perror(accept); exit(errno); e

20、lse printf(正在与您聊天的客户端是：%s: %dn,inet_ntoa(c_addr.sin_addr),ntohs(c_addr.sin_port); while(1) _retry: /*发送消息*/ bzero(buf,BUFLEN); printf(请输入发送给对方的消息：); /*fgets函数：从流中读取BUFLEN-1个字符*/ fgets(buf,BUFLEN,stdin); /*打印发送的消息*/ /fputs(buf,stdout); if(!strncasecmp(buf,quit,4) printf(server 请求终止聊天!n); break; /*如果输

21、入的字符串只有n，即回车，那么请重新输入*/ if(!strncmp(buf,n,1) printf(输入的字符只有回车，这个是不正确的！n); goto _retry; /*如果buf中含有n，那么要用strlen(buf)-1，去掉n*/ if(strchr(buf,n) len = send(newfd,buf,strlen(buf)-1,0); /*如果buf中没有n，则用buf的真正长度strlen(buf)*/ else len = send(newfd,buf,strlen(buf),0); if(len 0) printf(消息发送成功，本次共发送的字节数是：%dn,len);

22、 else printf(消息发送失败!n); break; /*接收消息*/ bzero(buf,BUFLEN); len = recv(newfd,buf,BUFLEN,0); if(len 0) printf(客户端发来的信息是：%s,共有字节数是: %dn,buf,len); else if(len 是；n-否? ); bzero(buf, BUFLEN); fgets(buf,BUFLEN, stdin); if(!strncasecmp(buf,y,1) printf(server 退出!n); break; /*关闭服务器的套接字*/ close(sockfd); return

23、0;3、编译源代码：newnew-desktop:/linux/c$ gcc -Wall sync-client.c -o sync-clientnewnew-desktop:/linux/c$ gcc -Wall sync-server.c -o sync-server4、运行服务器程序：newnew-desktop:/linux/c$ ./sync-server 127.0.0.1 4567socket create success!bind success!the server is listening!*聊天开始*正在与您聊天的客户端是：127.0.0.1: 48639请输入发送给对方

24、的消息：client消息发送成功，本次共发送的字节数是：6客户端发来的信息是：server,共有字节数是: 6请输入发送给对方的消息：5、运行客户端程序：newnew-desktop:/linux/c$ ./sync-client 127.0.0.1 4567socket create success!conncet success!服务器发来的消息是：client,共有字节数是: 6请输入发送给对方的消息：server消息发送成功，本次共发送的字节数是：6linux网络编程：用C语言实现的聊天程序（异步通信）本片文章，在上一篇：linux网络编程：用C语言实现的聊天程序（同步通信）的基础上，

25、增加了IO复用的功能，实现了聊天程序的异步通讯！1、使用IO复用可以在等待的时候加入了超时的时间，如果等待的时间没有达到超时时间，那么该情况与阻塞的情况一致。而当超时的时间到达时，仍没有数据接收到，系统回返回0，不再等待。select函数就实现了这个功能。2、select函数原型int select (int maxfdp1, fd_set *readset, fd_set *writeset,fd_set *exceptset, const struct timeval * timeout);a）返回值0：就绪的描述符-1：出错0 ：超时struct timevallong tv_sec; / secondslong tv_usec; / microsecondsb）具体解释select的参数int maxfdp是一个整数值，是指集合中所有文件描述符的范围，即所有文件描述符的最大值加1；fd_set*readfds 文件描述符集合内，是否有数据可读；fd_set*writefds文件描述符集合内，是否有数据可写；fd_set *errorfds文件描述符集合内，是否有文件发生错误；struct timeval *timeou