Linux网络编程:socket实现client/server通信

打印 上一主题 下一主题

主题 908|帖子 908|积分 2724

一、问题引入

阅读UNIX网络编程 卷1:套接字联网API 第3版的前4个章节,觉得有必要对书籍上的源码案例进行复现,并推敲TCP的C/S通信过程。
二、解决过程

2-1 server
  1. #include <sys/types.h>
  2. #include <sys/socket.h>
  3. #include <stdio.h>
  4. #include <netinet/in.h>
  5. #include <arpa/inet.h>
  6. #include <unistd.h>
  7. #include <string.h>
  8. #include <stdlib.h>
  9. #include <fcntl.h>
  10. #include <sys/shm.h>
  11. #define PORT 8887
  12. #define QUEUE 20
  13. #define BUFFER_SIZE 1024
  14. int main()
  15. {
  16.     // 定义sockfd, AF_INET:IPv4协议,SOCK_STREAM:字节流套接字
  17.     int server_sockfd = socket(AF_INET, SOCK_STREAM, 0);
  18.     // 定义sockaddr_in
  19.     struct sockaddr_in server_sockaddr;
  20.     server_sockaddr.sin_family = AF_INET;
  21.     server_sockaddr.sin_port = htons(PORT);
  22.     server_sockaddr.sin_addr.s_addr = htonl(INADDR_ANY);
  23.     // bind,成功返回0,出错返回-1
  24.     if (bind(server_sockfd, (struct sockaddr *)&server_sockaddr, sizeof(server_sockaddr)) == -1)
  25.     {
  26.         perror("bind failure");
  27.         exit(1);
  28.     }
  29.     // listen,成功返回0,出错返回-1
  30.     if (listen(server_sockfd, QUEUE) == -1)
  31.     {
  32.         perror("listen failure");
  33.         exit(1);
  34.     }
  35.     // 客户端套接字
  36.     char buffer[BUFFER_SIZE];
  37.     struct sockaddr_in client_addr;
  38.     socklen_t length = sizeof(client_addr);
  39.     // 成功返回非负描述字,出错返回-1
  40.     // accept()被阻塞,等待客户端连接,一旦客户端和服务器完成TCP三次握手,accept()返回一个已连接描述值
  41.     int conn = accept(server_sockfd, (struct sockaddr *)&client_addr, &length);
  42.     if (conn < 0)
  43.     {
  44.         perror("connect failure");
  45.         exit(1);
  46.     }
  47.     printf("**************************\n");
  48.     printf("accept successful !!!\n");
  49.     char ipbuf[64] = {0};
  50.     printf("client || ip: %s, port: %d\n",
  51.            inet_ntop(AF_INET, &client_addr.sin_addr.s_addr, ipbuf, sizeof(ipbuf)),
  52.            ntohs(client_addr.sin_port));
  53.     printf("**************************\n");
  54.     while (1)
  55.     {
  56.         memset(buffer, 0, sizeof(buffer));
  57.         // 接收
  58.         int len = recv(conn, buffer, sizeof(buffer), 0);
  59.         if (strcmp(buffer, "exit") == 0 || strcmp(buffer, "q") == 0)
  60.             break;
  61.         if(len > 0)
  62.         {
  63.             printf("Recv:%s (%d Byte)\n", buffer, strlen(buffer));
  64.         }
  65.     }
  66.     close(conn);
  67.     close(server_sockfd);
  68.     return 0;
  69. }
复制代码
2-2 client
  1. #include <sys/types.h>
  2. #include <sys/socket.h>
  3. #include <stdio.h>
  4. #include <netinet/in.h>
  5. #include <arpa/inet.h>
  6. #include <unistd.h>
  7. #include <string.h>
  8. #include <stdlib.h>
  9. #include <fcntl.h>
  10. #include <sys/shm.h>
  11. #define PORT 8887
  12. #define BUFFER_SIZE 1024
  13. int main()
  14. {
  15.     int sockfd = socket(AF_INET, SOCK_STREAM, 0);
  16.     struct sockaddr_in servaddr;
  17.     memset(&servaddr, 0, sizeof(servaddr));
  18.     servaddr.sin_family = AF_INET;
  19.     servaddr.sin_port = htons(PORT);
  20.     servaddr.sin_addr.s_addr = inet_addr("127.0.0.1");
  21.     /// 连接服务器,成功返回0,错误返回-1
  22.     if (connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr)) < 0)
  23.     {
  24.         perror("connect");
  25.         exit(1);
  26.     }
  27.     printf("**************************\n");
  28.     printf("connect successful !!!\n");
  29.     char ipbuf[64] = {0};
  30.     printf("server || ip: %s, port: %d\n",
  31.            inet_ntop(AF_INET, &servaddr.sin_addr.s_addr, ipbuf, sizeof(ipbuf)),
  32.            ntohs(servaddr.sin_port));
  33.     printf("now you can send message to server\n");
  34.     printf("**************************\n");
  35.     char sendbuf[BUFFER_SIZE];
  36.     while (fgets(sendbuf, sizeof(sendbuf), stdin) != NULL)
  37.     {
  38.         if(sendbuf[strlen(sendbuf)-1] == '\n')
  39.             sendbuf[strlen(sendbuf)-1] = '\0';
  40.         // 发送
  41.         send(sockfd, sendbuf, strlen(sendbuf), 0);
  42.         if (strcmp(sendbuf, "exit") == 0 || strcmp(sendbuf, "q") == 0)
  43.             break;
  44.         memset(sendbuf, 0, sizeof(sendbuf));
  45.     }
  46.     close(sockfd);
  47.     return 0;
  48. }
复制代码
2-3 编译和运行测试



免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!
回复

使用道具 举报

0 个回复

倒序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

天空闲话

金牌会员
这个人很懒什么都没写!

标签云

快速回复 返回顶部 返回列表