• Linux TCP 通信并发

    多进程

    客户端

    1. #include 
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. int main() {
    7.     //创建套接字
    8.     int lfd = socket(AF_INET, SOCK_STREAM, 0);
    9.     if(lfd == -1) {
    10.         perror("socket");
    11.         exit(-1);
    12.     }
    13.     //连接服务器
    14.     struct sockaddr_in serveraddr;
    15.     inet_pton(AF_INET, "192.168.245.129", &serveraddr.sin_addr.s_addr);
    16.     serveraddr.sin_family = AF_INET;
    17.     serveraddr.sin_port = htons(9999);
    18.     int ret = connect(lfd, (struct sockaddr *) &serveraddr, sizeof(serveraddr));
    19.     if(ret == -1) {
    20.         perror("connect");
    21.         _exit(-1);
    22.     }
    23.     //通信
    24.     int i = 0;
    25.     char receiveBuf[1024] = {0};
    26.     while(1) {
    27.         sprintf(receiveBuf, "data: %d\n", i++);
    28.  
    29.         write(lfd, receiveBuf, strlen(receiveBuf));
    30.         sleep(1);
    31.         
    32.         int len = read(lfd, receiveBuf, sizeof(receiveBuf));
    33.         if(len == -1) {
    34.             perror("read");
    35.             exit(0);
    36.         } else if(len > 0) {
    37.             printf("receive server data: %s\n", receiveBuf);
    38.         } else if (len == 0) {
    39.             printf("server closed...");
    40.         }
    41.         
    42.     }
    43.     
    44.  
    45.     close(lfd);
    46. }

    服务器端

    1. #define _XOPEN_SOURCE
    2. #include
    3. #include
    4. #include
    5. #include
    6. #include
    7. #include
    8. #include
    9. #include
    10.  
    11. void recyleChild(int arg) {
    12.     while(1) {
    13.         int ret = waitpid(-1, NULL, WNOHANG);
    14.         if(ret == -1) {
    15.             break;
    16.         } else if (ret == 0) {
    17.             break;
    18.         } else if (ret > 0) {
    19.             printf("pid %d is resaved\n", ret);
    20.         }
    21.     }
    22. }
    23.  
    24. int main() {
    25.  
    26.     //注册信号捕捉函数
    27.     struct sigaction act;
    28.     act.sa_flags = 0;
    29.     sigemptyset(&act.sa_mask);
    30.     act.sa_handler = recyleChild;
    31.     sigaction(SIGCHLD, &act, NULL);
    32.  
    33.  
    34.     //创建socket
    35.     int lfd = socket(AF_INET, SOCK_STREAM, 0);
    36.     if(lfd == -1) {
    37.         perror("socket");
    38.         exit(0);
    39.     }
    40.     struct sockaddr_in saddr;
    41.     saddr.sin_family = AF_INET;
    42.     saddr.sin_port = htons(9999);
    43.     saddr.sin_addr.s_addr = INADDR_ANY;
    44.  
    45.     //绑定
    46.     int ret = bind(lfd, (struct sockaddr*)&saddr, sizeof(saddr));
    47.     if(ret == -1) { 
    48.         perror("bind");
    49.         exit(0);
    50.     }
    51.  
    52.     //监听
    53.     ret = listen(lfd, 128);
    54.     if(ret == -1) { 
    55.         perror("listen");
    56.         exit(0);
    57.     }
    58.  
    59.     //接受链接
    60.     while(1) {
    61.         struct sockaddr_in cliaddr;
    62.         int len = sizeof(cliaddr);
    63.         
    64.         int cfd = accept(lfd, (struct sockaddr*)&cliaddr, &len);   
    65.         if(cfd == -1) {
    66.             if(errno == EINTR) {
    67.                 continue;
    68.             }
    69.             perror("accept");
    70.             exit(-1);
    71.         }
    72.  
    73.         //每连接一个，创建一个子进程
    74.         pid_t pid = fork();
    75.         if(pid == 0) {
    76.             char clientIP[16];
    77.             inet_ntop(AF_INET, &cliaddr.sin_addr.s_addr, clientIP, 16);
    78.             unsigned short cliPort = ntohs(cliaddr.sin_port);
    79.             printf("Client Port is %d, client addr is %s\n", cliPort, clientIP);
    80.  
    81.             char recvBuf[1024] = {0};
    82.             while(1) {
    83.                 int len = read(cfd, &recvBuf, sizeof(recvBuf));
    84.                 if(len == -1) {
    85.                     perror("read");
    86.                     return 0;
    87.                 } else if(len > 0) {
    88.                     printf("recv client data : %s \n", recvBuf);
    89.                     
    90.                 } else {
    91.                     printf("closed.....");
    92.                 }
    93.  
    94.                 write(cfd, &recvBuf, sizeof(recvBuf));
    95.             }
    96.             close(cfd);
    97.             exit(0);
    98.         }
    99.     }
    100.     close(lfd);
    101.     return 0;
    102. }

    多线程

    服务器

    1. #define _XOPEN_SOURCE
    2. #include
    3. #include
    4. #include
    5. #include
    6. #include
    7. #include
    8. #include
    9.  
    10.  
    11. struct sockinfo {
    12.     int fd;
    13.     struct sockaddr_in saddr;
    14.     pthread_t tid;
    15. };
    16.  
    17. struct sockinfo sockinfos[128];
    18.  
    19. void* working(void* arg) {
    20.  
    21.     struct sockinfo* pinfo = (struct sockinfo*) arg;
    22.     char clientIP[16];
    23.     inet_ntop(AF_INET, &pinfo->saddr.sin_addr.s_addr, clientIP, 16);
    24.     unsigned short cliPort = ntohs(pinfo->saddr.sin_port);
    25.     printf("Client Port is %d, client addr is %s\n", cliPort, clientIP);
    26.  
    27.     char recvBuf[1024] = {0};
    28.     while(1) {
    29.         int len = read(pinfo->fd, &recvBuf, sizeof(recvBuf));
    30.         if(len == -1) {
    31.             perror("read");
    32.             return 0;
    33.         } else if(len > 0) {
    34.             printf("recv client data : %s \n", recvBuf);
    35.                     
    36.         } else {
    37.             printf("closed.....");
    38.         }
    39.  
    40.         write(pinfo->fd, &recvBuf, sizeof(recvBuf));
    41.     }
    42.     close(pinfo->fd);
    43.     exit(0);
    44.     return NULL;
    45. }
    46.  
    47. int main() {
    48.  //创建socket
    49.     int lfd = socket(AF_INET, SOCK_STREAM, 0);
    50.     if(lfd == -1) {
    51.         perror("socket");
    52.         exit(0);
    53.     }
    54.     struct sockaddr_in saddr;
    55.     saddr.sin_family = AF_INET;
    56.     saddr.sin_port = htons(9999);
    57.     saddr.sin_addr.s_addr = INADDR_ANY;
    58.  
    59.     //绑定
    60.     int ret = bind(lfd, (struct sockaddr*)&saddr, sizeof(saddr));
    61.     if(ret == -1) { 
    62.         perror("bind");
    63.         exit(0);
    64.     }
    65.  
    66.     //监听
    67.     ret = listen(lfd, 128);
    68.     if(ret == -1) { 
    69.         perror("listen");
    70.         exit(0);
    71.     }
    72.  
    73.     //初始化数据
    74.     int max = sizeof(sockinfos) / sizeof(sockinfos[0]);
    75.     for(int i = 0; i < max; i++) {
    76.         memset(&sockinfos[i], 0, sizeof(sockinfos[i]));
    77.         sockinfos[i].fd = -1;
    78.         sockinfos[i].tid = -1;
    79.     }
    80.  
    81.     //接受链接
    82.     while(1) {
    83.         struct sockaddr_in cliaddr;
    84.         int len = sizeof(cliaddr);
    85.         
    86.         int cfd = accept(lfd, (struct sockaddr*)&cliaddr, &len);   
    87.         if(cfd == -1) {
    88.             perror("accept");
    89.             exit(-1);
    90.         }
    91.  
    92.         struct sockinfo * pinfo;
    93.         for(int i = 0; i < max; i++) {
    94.             if(sockinfos[i].fd == -1) {
    95.                 pinfo = &sockinfos[i];
    96.                 break;
    97.             }
    98.             if(i == max - 1) {
    99.                 sleep(1);
    100.                 i--;
    101.             }
    102.         }
    103.  
    104.         pinfo->fd = cfd;
    105.         memcpy(&pinfo->saddr, &cliaddr, len);
    106.  
    107.  
    108.         //每连接一个，创建一个子进程
    109.  
    110.         pthread_create(&pinfo->tid, NULL, working, pinfo);
    111.  
    112.         pthread_detach(pinfo->tid);
    113.     }
    114.     close(lfd);
    115.     return 0;
    116. }

    客户端

    1. #include 
    2. #include 
    3. #include 
    4. #include 
    5. #include 
    6. int main() {
    7.     //创建套接字
    8.     int lfd = socket(AF_INET, SOCK_STREAM, 0);
    9.     if(lfd == -1) {
    10.         perror("socket");
    11.         exit(-1);
    12.     }
    13.     //连接服务器
    14.     struct sockaddr_in serveraddr;
    15.     inet_pton(AF_INET, "192.168.245.129", &serveraddr.sin_addr.s_addr);
    16.     serveraddr.sin_family = AF_INET;
    17.     serveraddr.sin_port = htons(9999);
    18.     int ret = connect(lfd, (struct sockaddr *) &serveraddr, sizeof(serveraddr));
    19.     if(ret == -1) {
    20.         perror("connect");
    21.         _exit(-1);
    22.     }
    23.     //通信
    24.     int i = 0;
    25.     char receiveBuf[1024] = {0};
    26.     while(1) {
    27.         sprintf(receiveBuf, "data: %d\n", i++);
    28.  
    29.         write(lfd, receiveBuf, strlen(receiveBuf));
    30.         sleep(1);
    31.         
    32.         int len = read(lfd, receiveBuf, sizeof(receiveBuf));
    33.         if(len == -1) {
    34.             perror("read");
    35.             exit(0);
    36.         } else if(len > 0) {
    37.             printf("receive server data: %s\n", receiveBuf);
    38.         } else if (len == 0) {
    39.             printf("server closed...");
    40.         }
    41.         
    42.     }
    43.     
    44.  
    45.     close(lfd);
    46. }

  • 相关阅读:
    数据结构·栈与队列介绍与实现
    CCLink转Modbus TCP网关_MODBUS网口设置
    220V交流转直流的简易电源设计
    关于网络流
    react项目实现语音识别功能
    python、pyqt5实现人脸检测、性别和年龄预测
    遍历数组的10个高阶函数
    GAMES101 作业0 环境配置 超详细小白教程
    DDL、DML
    css3d制作正方体
  • 原文地址：https://blog.csdn.net/weixin_44273624/article/details/133649075