Chinaunix首页 | 论坛 | 博客

oops

首页　| 　博文目录　| 　关于我

王贤才

  • 博客访问： 1218738
  • 博文数量： 573
  • 博客积分： 0
  • 博客等级： 民兵
  • 技术积分： 66
  • 用 户 组： 普通用户
  • 注册时间： 2016-06-28 16:21
文章分类

全部博文（573）

文章存档

2018年（3）

2016年（48）

2015年（522）

我的朋友
最近访客
推荐博文
相关博文
最简单的CS架构代码

分类： LINUX

2015-12-02 15:48:48

client.c文件

点击(此处)折叠或打开

  1. #include <stdio.h>
  2. #include <string.h>
  3. #include <sys/types.h>
  4. #include <sys/socket.h>
  5. #include <netinet/in.h>
  6. #include <arpa/inet.h>
  7. #include <sys/wait.h>
  8. #include <pthread.h>
  9. #include <stdlib.h>
  10. #include <time.h>
  11. #include <unistd.h>
  12. #include <sys/stat.h>
  13. #include <fcntl.h>
  14. #include <errno.h>
  15. #include <termios.h>
  16. #include <sys/time.h>
  17. #include <sys/timeb.h>
  18. #include <stdarg.h>

  20. #define SER_IP "127.0.0.1" /*服务器的IP地址*/

  22. int read_socket(int socket_id, char *pbuf, int len);
  23. int write_socket(int socket_id, char *pbuf, int len);

  25. int main(int argc, char ** argv) /*客户端程序*/
  26. {
  27.     FILE * fp = NULL;
  28.     char judg[32];
  29.     char total_buf[1024];;
  30.     int sockfd = -1;
  31.     int ret = -1;
  32.     int opt = 1;
  33.     int len1, len2;
  34.     struct sockaddr_in seraddr; /*用来存放要访问的服务器的IP地址和端口号*/
  35.     
  36.     memset(judg, 0, sizeof(judg));
  37.     memset(total_buf, 0, sizeof(total_buf));
  38.     memset(&seraddr, 0, sizeof(seraddr)); /*初始化*/
  39.     

  41.     sockfd = socket(AF_INET, SOCK_STREAM, 0); /*创建套接字文件,TCP协议*/
  42.     if(sockfd < 0)
  43.     {
  44.         return -1;
  45.     }
  46.     setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)); /*将客户端设置具有端口号可以重复*/

  48.     seraddr.sin_family = AF_INET; /*服务器的地址族协议*/
  49.     seraddr.sin_port = htons(4989);     /*服务器的端口号*/
  50.     inet_pton(AF_INET, SER_IP, &seraddr.sin_addr.s_addr); /*服务器的ip地址*/
  51.                                                                                                             
  52.     ret = connect(sockfd, (struct sockaddr*)&seraddr, sizeof(seraddr)); /*请求连接服务器*/
  53.     if(ret < 0)
  54.     {
  55.         return -1;
  56.     }
  57.     
  58.     printf("客户端已请求连接！\n");
  59.     
  60.     ret = read_socket(sockfd, judg, sizeof(char)*2); /*对服务器是否准备好的判断*/
  61.     if (0 == ret) /*套接字关闭*/
  62.     {
  63.         return -1;
  64.     }
  65.     else if(ret < 0)
  66.     {
  67.         exit(0);
  68.     }
  69.     if (strncmp(judg, "OK", sizeof(char)*2) != 0) /*服务器OK*/
  70.     {
  71.         close(sockfd);
  72.         return -1;
  73.     }
  74.     printf("客户端接受数据：\n");
  75.     
  76.     ret = read(sockfd, total_buf, 10);
  77.     if (ret <= 0)
  78.     {
  79.         return(-1);
  80.     }
  81.     printf("total_buf=[%s]\n", total_buf);
  82.     return 0;
  83. }

  85. /***********************************************************
  86. * 函 数 名：read_socket
  87. * 功能描述: 读socket
  88. * 输入参数：
  89. * 输出参数：
  90. * 返 回：
  91. * 流程描述：
  92. * 说明：
  93. * 修改记录:
  94. * [修改人] [日期] - [描述]
  95. ***********************************************************/
  96. int read_socket(int socket_id, char *pbuf, int len){
  97.     int num;
  98.     int i;
  99.     
  100.     if(len <= 0) {
  101.         return     read(socket_id, pbuf, sizeof(pbuf));
  102.     }

  104.     i = 0;
  105.     do{
  106.         num = read(socket_id, &(pbuf[i]), len - i);
  107.         if (num <= 0){
  108.             /* LOG: Read socket error exit. */
  109.             return(-1);
  110.         }
  111.         i += num;
  112.     } while (i < len);

  114.     return(i);
  115. }

  117. /***********************************************************
  118. * 函 数 名：write_socket
  119. * 功能描述: 写socket
  120. * 输入参数：
  121. * 输出参数：
  122. * 返 回：
  123. * 流程描述：
  124. * 说明：
  125. * 修改记录:
  126. * [修改人] [日期] - [描述]
  127. ***********************************************************/
  128. int write_socket(int socket_id, char *pbuf, int len){
  129.     int num;
  130.     int i;

  132.     if (len <= 0) return(0);
  133.         
  134.     i = 0;
  135.     do{
  136.         num = write(socket_id, &(pbuf[i]), len - i);
  137.         if (num < 0){
  138.             /* LOG: Write socket error exit. */
  139.             return(-1);
  140.         }
  141.         i += num;
  142.     } while (i < len);
  143.     
  144.     return(i);
  145. }
server.c文件

点击(此处)折叠或打开

  1. #include <stdio.h>
  2. #include <string.h>
  3. #include <sys/types.h>
  4. #include <sys/socket.h>
  5. #include <netinet/in.h>
  6. #include <arpa/inet.h>
  7. #include <sys/wait.h>
  8. #include <pthread.h>
  9. #include <stdlib.h>
  10. #include <time.h>
  11. #include <unistd.h>
  12. #include <sys/stat.h>
  13. #include <fcntl.h>
  14. #include <errno.h>
  15. #include <termios.h>
  16. #include <sys/time.h>
  17. #include <sys/timeb.h>
  18. #include <stdarg.h>

  20. #define SER_IP "127.0.0.1" /*服务器的IP地址*/

  22. int read_socket(int socket_id, char *pbuf, int len);
  23. int write_socket(int socket_id, char *pbuf, int len);

  25. int main(int argc, char ** argv) /*服务端程序*/
  26. {
  27.     char ip_buf[32];
  28.     int sockfd = -1; /*监听套接字*/
  29.     int newfd = -1; /*连接套接字*/
  30.     int ret = -1;
  31.     int opt = 1;
  32.     int len;
  33.     int i=0;
  34.     int read_count = 1; /*读取次数*/
  35.     struct sockaddr_in seraddr; /*用来保存服务器自己的ip地址和端口号的*/
  36.     struct sockaddr_in cliaddr; /*用来保存连接过来的客户的ip地址和端口号的*/
  37.     
  38.     memset(&seraddr, 0, sizeof(seraddr));
  39.     memset(&cliaddr, 0, sizeof(cliaddr));
  40.     
  41.     
  42.     sockfd = socket(AF_INET, SOCK_STREAM, 0); /*创建连接套接字,TCP协议*/
  43.     if(sockfd < 0)
  44.     {
  45.         return -1;
  46.     }
  47.     setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)); /*将服务端设置具有端口号可以重复*/

  49.     seraddr.sin_family = AF_INET; /*指定服务器地址协议族*/
  50.     seraddr.sin_port = htons(4989);     /*指定要监听的服务器的端口号*/
  51.     seraddr.sin_addr.s_addr = INADDR_ANY; /*指定要监听的服务器的ip*/

  53.     ret = bind(sockfd, (struct sockaddr*)&seraddr, sizeof(struct sockaddr)); /*将IP地址，端口号和文件绑定,为套接字命名*/
  54.     if(ret < 0)
  55.     {
  56.         return -1;
  57.     }
  58.     ret = listen(sockfd, 10); /*监听*/
  59.     if(ret < 0)
  60.     {
  61.         return -1;
  62.     }
  63.     printf("等待客户端连接.....\n");
  64.     
  65.     len = sizeof(cliaddr); /*值-结果参数*/
  66.     newfd = accept(sockfd, (struct sockaddr*)&cliaddr, &len); /*等着客户端连接*/
  67.     if(newfd < 0)
  68.     {
  69.         return -1;
  70.     }
  71.     inet_ntop(AF_INET, &cliaddr.sin_addr.s_addr, ip_buf, sizeof(ip_buf)); /**/
  72.     printf("客户IP=[%s]", ip_buf);
  73.     ret = write_socket(newfd, "OKYES", sizeof("OKYES")); /*告诉客户端，服务器OK了*/
  74.     if(ret < 0)
  75.     {
  76.         return -1;
  77.     }
  78.     printf("客户端不发数据，执行while(1)，循环等待\n");
  79.     while(1);

  81.     return 0;
  82. }


  85. /***********************************************************
  86. * 函 数 名：read_socket
  87. * 功能描述: 读socket
  88. * 输入参数：
  89. * 输出参数：
  90. * 返 回：
  91. * 流程描述：
  92. * 说明：
  93. * 修改记录:
  94. * [修改人] [日期] - [描述]
  95. ***********************************************************/
  96. int read_socket(int socket_id, char *pbuf, int len){
  97.     int num;
  98.     int i;
  99.     
  100.     if(len <= 0) {
  101.         return     read(socket_id, pbuf, sizeof(pbuf));
  102.     }

  104.     i = 0;
  105.     do{
  106.         num = read(socket_id, &(pbuf[i]), len - i);
  107.         if (num <= 0){
  108.             /* LOG: Read socket error exit. */
  109.             return(-1);
  110.         }
  111.         i += num;
  112.     } while (i < len);

  114.     return(i);
  115. }

  117. /***********************************************************
  118. * 函 数 名：write_socket
  119. * 功能描述: 写socket
  120. * 输入参数：
  121. * 输出参数：
  122. * 返 回：
  123. * 流程描述：
  124. * 说明：
  125. * 修改记录:
  126. * [修改人] [日期] - [描述]
  127. ***********************************************************/
  128. int write_socket(int socket_id, char *pbuf, int len){
  129.     int num;
  130.     int i;

  132.     if (len <= 0) return(0);
  133.         
  134.     i = 0;
  135.     do{
  136.         num = write(socket_id, &(pbuf[i]), len - i);
  137.         if (num < 0){
  138.             /* LOG: Write socket error exit. */
  139.             return(-1);
  140.         }
  141.         i += num;
  142.     } while (i < len);
  143.     
  144.     return(i);
  145. }

阅读(859) | 评论(0) | 转发(0) |
0

上一篇：select函数

下一篇：信号

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

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

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

16024965号-6