Chinaunix首页 | 论坛 | 博客

石头yanjunlin.blog.chinaunix.net

首页　| 　博文目录　| 　关于我

448395708

  • 博客访问： 341163
  • 博文数量： 213
  • 博客积分： 566
  • 博客等级： 中士
  • 技术积分： 1210
  • 用 户 组： 普通用户
  • 注册时间： 2011-03-21 13:09
文章分类

全部博文（213）

文章存档

2015年（1）

2013年（7）

2012年（128）

2011年（77）

我的朋友
最近访客
推荐博文
socket实例：一个简单的聊天程序

分类：

2012-12-31 21:10:26

原文地址：socket实例：一个简单的聊天程序 作者：lwp225

  我们老师让写一个简单的聊天软件，并且实现不同机子之间的通信，我用的是SOCKET编程。不废话多说了，先附上代码：

服务器端server.c

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include <errno.h>
  5. #include <sys/socket.h>
  6. #include <arpa/inet.h>
  7. #include <netinet/in.h>
  8. #include <sys/types.h>
  9. #include <unistd.h>
  10. #include <sys/time.h>
  11.   
  12. #define BUFLEN 1024
  13. #define PORT 6666
  14. #define LISTNUM 20
  15.   
  16. int main()
  17. {
  18.     int sockfd, newfd;
  19.     struct sockaddr_in s_addr, c_addr;
  20.     char buf[BUFLEN];
  21.     socklen_t len;
  22.     unsigned int port, listnum;
  23.     fd_set rfds;
  24.     struct timeval tv;
  25.     int retval,maxfd;
  26.       
  27.     /*建立socket*/
  28.     if((sockfd = socket(PF_INET, SOCK_STREAM, 0)) == -1){
  29.         perror("socket");
  30.         exit(errno);
  31.     }else
  32.         printf("socket create success!\n");
  33.     memset(&s_addr,0,sizeof(s_addr));
  34.     s_addr.sin_family = AF_INET;
  35.     s_addr.sin_port = htons(PORT);
  36.     s_addr.sin_addr.s_addr = htons(INADDR_ANY);
  37.     
  38.     /*把地址和端口帮定到套接字上*/
  39.     if((bind(sockfd, (struct sockaddr*) &s_addr,sizeof(struct sockaddr))) == -1){
  40.         perror("bind");
  41.         exit(errno);
  42.     }else
  43.         printf("bind success!\n");
  44.     /*侦听本地端口*/
  45.     if(listen(sockfd,listnum) == -1){
  46.         perror("listen");
  47.         exit(errno);
  48.     }else
  49.         printf("the server is listening!\n");
  50.     while(1){
  51.         printf("*****************聊天开始***************\n");
  52.         len = sizeof(struct sockaddr);
  53.         if((newfd = accept(sockfd,(struct sockaddr*) &c_addr, &len)) == -1){
  54.             perror("accept");
  55.             exit(errno);
  56.         }else
  57.             printf("正在与您聊天的客户端是：%s: %d\n",inet_ntoa(c_addr.sin_addr),ntohs(c_addr.sin_port));
  58.         while(1){
  59.             FD_ZERO(&rfds);
  60.             FD_SET(0, &rfds);
  61.             maxfd = 0;
  62.             FD_SET(newfd, &rfds);
  63.             /*找出文件描述符集合中最大的文件描述符*/
  64.             if(maxfd < newfd)
  65.                 maxfd = newfd;
  66.             /*设置超时时间*/
  67.             tv.tv_sec = 6;
  68.             tv.tv_usec = 0;
  69.             /*等待聊天*/
  70.             retval = select(maxfd+1, &rfds, NULL, NULL, &tv);
  71.             if(retval == -1){
  72.                 printf("select出错，与该客户端连接的程序将退出\n");
  73.                 break;
  74.             }else if(retval == 0){
  75.                 printf("waiting...\n");
  76.                 continue;
  77.             }else{
  78.                 /*用户输入信息了*/
  79.                 if(FD_ISSET(0, &rfds)){
  80.             
  81.                     /******发送消息*******/
  82.                     memset(buf,0,sizeof(buf));
  83.                     /*fgets函数：从流中读取BUFLEN-1个字符*/
  84.                     fgets(buf,BUFLEN,stdin);
  85.                     /*打印发送的消息*/
  86.                     //fputs(buf,stdout);
  87.                     if(!strncasecmp(buf,"quit",4)){
  88.                         printf("server 请求终止聊天!\n");
  89.                         break;
  90.                     }
  91.                         len = send(newfd,buf,strlen(buf),0);
  92.                     if(len > 0)
  93.                         printf("\t消息发送成功：%s\n",buf);
  94.                     else{
  95.                         printf("消息发送失败!\n");
  96.                         break;
  97.                     }
  98.                 }
  99.                 /*客户端发来了消息*/
  100.                 if(FD_ISSET(newfd, &rfds)){
  101.                     /******接收消息*******/
  102.                     memset(buf,0,sizeof(buf));
  103.                     /*fgets函数：从流中读取BUFLEN-1个字符*/
  104.                     len = recv(newfd,buf,BUFLEN,0);
  105.                     if(len > 0)
  106.                         printf("客户端发来的信息是：%s\n",buf);
  107.                     else{
  108.                         if(len < 0 )
  109.                             printf("接受消息失败！\n");
  110.                         else
  111.                             printf("客户端退出了，聊天终止！\n");
  112.                         break;
  113.                     }
  114.                 }
  115.             }
  116.         }
  117.         /*关闭聊天的套接字*/
  118.         close(newfd);
  119.         /*是否退出服务器*/
  120.         printf("服务器是否退出程序：y->是；n->否? ");
  121.         bzero(buf, BUFLEN);
  122.         fgets(buf,BUFLEN, stdin);
  123.         if(!strncasecmp(buf,"y",1)){
  124.             printf("server 退出!\n");
  125.             break;
  126.         }
  127.     }
  128.     /*关闭服务器的套接字*/
  129.     close(sockfd);
  130.     return 0;
  131. }

客户端client.c

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include <errno.h>
  5. #include <sys/socket.h>
  6. #include <arpa/inet.h>
  7. #include <netinet/in.h>
  8. #include <sys/types.h>
  9. #include <unistd.h>
  10. #include <sys/time.h>

  12. #define BUFLEN 1024
  13. #define PORT 6666

  15. int main(int argc, char **argv)
  16. {
  17.     int sockfd;
  18.     struct sockaddr_in s_addr;
  19.     socklen_t len;
  20.     unsigned int port;
  21.     char buf[BUFLEN];
  22.     fd_set rfds;
  23.     struct timeval tv;
  24.     int retval, maxfd;
  25.     
  26.     /*建立socket*/
  27.     if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1){
  28.         perror("socket");
  29.         exit(errno);
  30.     }else
  31.         printf("socket create success!\n");

  33.     
  34.     /*设置服务器ip*/
  35.     memset(&s_addr,0,sizeof(s_addr));
  36.     s_addr.sin_family = AF_INET;
  37.      s_addr.sin_port = htons(PORT);
  38.     if (inet_aton(argv[1], (struct in_addr *)&s_addr.sin_addr.s_addr) == 0) {
  39.         perror(argv[1]);
  40.         exit(errno);
  41.     }
  42.     /*开始连接服务器*/
  43.     if(connect(sockfd,(struct sockaddr*)&s_addr,sizeof(struct sockaddr)) == -1){
  44.         perror("connect");
  45.         exit(errno);
  46.     }else
  47.         printf("conncet success!\n");
  48.     
  49.     while(1){
  50.         FD_ZERO(&rfds);
  51.         FD_SET(0, &rfds);
  52.         maxfd = 0;
  53.         FD_SET(sockfd, &rfds);
  54.         if(maxfd < sockfd)
  55.             maxfd = sockfd;
  56.         tv.tv_sec = 6;
  57.         tv.tv_usec = 0;
  58.         retval = select(maxfd+1, &rfds, NULL, NULL, &tv);
  59.         if(retval == -1){
  60.             printf("select出错，客户端程序退出\n");
  61.             break;
  62.         }else if(retval == 0){
  63.             printf("waiting...\n");
  64.             continue;
  65.         }else{
  66.             /*服务器发来了消息*/
  67.             if(FD_ISSET(sockfd,&rfds)){
  68.                 /******接收消息*******/
  69.                 bzero(buf,BUFLEN);
  70.                 len = recv(sockfd,buf,BUFLEN,0);
  71.                 if(len > 0)
  72.                     printf("服务器发来的消息是：%s\n",buf);
  73.                 else{
  74.                     if(len < 0 )
  75.                         printf("接受消息失败！\n");
  76.                     else
  77.                         printf("服务器退出了，聊天终止！\n");
  78.                 break;
  79.                 }
  80.             }
  81.             /*用户输入信息了,开始处理信息并发送*/
  82.             if(FD_ISSET(0, &rfds)){
  83.                 /******发送消息*******/
  84.                 bzero(buf,BUFLEN);
  85.                 fgets(buf,BUFLEN,stdin);
  86.                
  87.                 if(!strncasecmp(buf,"quit",4)){
  88.                     printf("client 请求终止聊天!\n");
  89.                     break;
  90.                 }
  91.                     len = send(sockfd,buf,strlen(buf),0);
  92.                 if(len > 0)
  93.                     printf("\t消息发送成功：%s\n",buf);
  94.                 else{
  95.                     printf("消息发送失败!\n");
  96.                     break;
  97.                 }
  98.             }
  99.         }
  100.     
  101.     }
  102.     /*关闭连接*/
  103.     close(sockfd);

  105.     return 0;
  106. }
 在程序的服务端输入
  1. lwp@lwp-linux:~/Desktop/1234$ ./server 
在程序的客户端输入
  1. lwp@lwp-linux:~/Desktop/1234$ ./client 192.168.100.80
当然这都是我在我的机子上截的图，客户端我们可以放到任何一台机子上，只要保证都能在同一个局域网下，连到我的IP地址就行。开启服务端后，在开启客户端，我们就可以聊天了：

server端：

  1. waiting...
  2. waiting...
  3. waiting...
  4. nihal
  5.     消息发送成功：nihal

  7. 客户端发来的信息是：zhuzhu
  8. hehe
  9.     消息发送成功：hehe

  11. 客户端发来的信息是：haha
  12. 客户端退出了，聊天终止！
  13. 服务器是否退出程序：y->是；n->否? y
  14. server端退出。

client端：

  1. waiting...
  2. waiting...
  3. waiting...
  4. 服务器发来的消息是：nihal
  6. zhuzhu
  7. 消息发送成功：zhuzhu
  9. 服务器发来的消息是：hehe
  11. haha
  12. 消息发送成功：haha








  1. lwp@lwp-linux:~/Desktop/1234$ ./server 
阅读(673) | 评论(0) | 转发(0) |
0

上一篇：Python白手起家五：文件/目录操作合集

下一篇：web服务之负载均衡篇

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6