linux多线程并发服务器

我就是我 2022-11-29 13:29 238阅读 0赞

linux多线程并发服务器

此为多线程并发服务器，多进程版。

  1. #include <stdio.h>
  2. #include <unistd.h>
  3. #include <stdlib.h>
  4. #include <sys/types.h>
  5. #include <string.h>
  6. #include <sys/socket.h>
  7. #include <arpa/inet.h>
  8. #include <ctype.h>
  9. #include <pthread.h>
  11. //自定义数据结构
  12. typedef struct SockInfo
  13. { 
  14.     int fd;//文件描述符cfd
  15.     struct sockaddr_in addr;//存放ip地址的结构体
  16.     pthread_t id;//线程的id
  17. }SockInfo;
  19. //子线程处理函数
  20. void* worker(void* arg){ 
  21.     char ip[64];
  22.     char buf[1024];
  23.     SockInfo* info = (SockInfo*)arg;
  24.     //通信
  25.     while(1)
  26.     { 
  27.         printf("client IP:%s,port:%d\n",
  28.                 inet_ntop(AF_INET,&info->addr.sin_addr.s_addr,ip,sizeof(ip)),
  29.                 ntohs(info->addr.sin_port));
  30.         int len = read(info->fd,buf,sizeof(buf));
  31.         if(len == -1){ 
  32.             perror("read error");
  33.             pthread_exit(NULL);
  34.         }
  35.         else if(len ==0){ 
  36.             printf("客户端断开了连接\n");
  37.             close(info->fd);
  38.             break;
  39.         }
  40.         else{ 
  41.             printf("recv buf: %s\n",buf);
  42.             write(info->fd,buf,len);
  43.         }        
  44.     }
  46.     return NULL;
  47. }
  49. int main(int argc, char const *argv[])
  50. { 
  51.     if(argc<2){ 
  52.         printf("eg: ./a.out port\n");
  53.         exit(1);
  54.     }
  55.     struct sockaddr_in serv_addr;
  56.     socklen_t serv_len = sizeof(serv_addr);
  57.     int port = atoi(argv[1]);
  59.     //创建套接字
  60.     int lfd = socket(AF_INET,SOCK_STREAM,0);
  61.     //初始化服务器 sockaddr_in
  62.     memset(&serv_addr,0,serv_len);
  63.     serv_addr.sin_family = AF_INET;                 //地址族
  64.     serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);  //监听本机所有的IP
  65.     serv_addr.sin_port = htons(port);               //设置端口
  66.     //绑定IP和端口
  67.     bind(lfd,(struct sockaddr*)&serv_addr,serv_len);
  69.     //设置同时监听的最大个数
  70.     listen(lfd,36);
  71.     printf("Start accept ......\n");
  73.     int i = 0;
  74.     SockInfo info[256];//线程个数,限制最多为256
  75.     //规定 数组里边的fd等于-1，表示当前结构体空闲
  76.     for(i=0;i<sizeof(info)/sizeof(info[0]);++i){ 
  77.         info[i].fd = -1;
  78.     }
  79.     struct sockaddr_in client_addr;
  80.     socklen_t cli_len = sizeof(struct sockaddr_in);
  81.     while(1){ 
  82.         //选一个没有被使用的，最小的数组元素
  83.         for(i=0;i<256;++i){ 
  84.             if(info[i].fd == -1){ 
  85.                 break;
  86.             }
  87.         }
  88.         if(i == 256){ 
  89.             break;
  90.         }
  92.         //主线程 - 等待接受连接请求
  93.         info[i].fd = accept(lfd,(struct sockaddr*)&info[i].addr,&cli_len);
  95.         //创建子线程 - 通信
  96.         pthread_create(&info[i].id,NULL,worker,&info[i]);
  97.         //设置线程分离
  98.         pthread_detach(info[i].id);
  101.     }
  103.     close(lfd);
  104.     //只退出主线程
  105.     pthread_exit(NULL);
  106.     return 0;
  107. }

终端1

  1. $ gcc pthread_server.c -lpthread -o server
  2. $ ./server 9876
  3. Start accept ......
  4. client IP:127.0.0.1,port:39808
  5. recv buf: 321
  7. client IP:127.0.0.1,port:39808
  8. client IP:127.0.0.1,port:39810
  9. recv buf: 456
  11. client IP:127.0.0.1,port:39810
  12. client IP:127.0.0.1,port:39820
  13. recv buf: hahaha
  15. client IP:127.0.0.1,port:39820
  16. 客户端断开了连接
  17. 客户端断开了连接
  18. 客户端断开了连接

终端2

  1. $ nc 127.1 9876
  2. 321 -------------客户端输入的
  3. 321 -------------服务端返回的

终端3

  1. $ nc 127.1 9876
  2. 456 -------------客户端输入的
  3. 456 -------------服务端返回的

终端4

  1. $ nc 127.1 9876
  2. hahaha
  3. hahaha

发表评论

表情：
评论列表 （有 0 条评论，238人围观）

还没有评论，来说两句吧...

相关阅读

    相关 多线程并发

    1.并发就是对共享资源同时进行访问，而产生的现象。 2.线程的实现方式：继承Thread或实现runnable 都要重写run方法。 3.启动线程是通过Thread的sta

    以你之姓@以你之姓@/ 0 赞/ 431 阅读