[問題] socket接受multi client的問題

看板C_and_CPP作者 (股市觀察者)時間7年前 (2016/12/16 10:22), 編輯推噓1(1014)
留言15則, 4人參與, 最新討論串1/2 (看更多)
if ( (sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1 ){ perror("socket"); exit(1); } addr.sin_family = AF_INET; addr.sin_port = htons(5000); addr.sin_addr.s_addr = htonl(INADDR_ANY); bzero( &(addr.sin_zero), 8 ); if ( bind(sockfd, (struct sockaddr*)&addr, sizeof(struct sockaddr)) == -1 ){ perror("bind"); exit(1); } while(1){ if ( listen(sockfd, 10) == -1 ){ perror("listen"); exit(1); } if ( (new_fd[num] = accept(sockfd, (struct sockaddr*) &their_addr, &sin_size)) == -1 ){ perror("accept"); exit(1); } res = pthread_create( &(accept_thread[times]), NULL, thread_function, (void *)p_num ); if (res != 0){ perror("Thread create failed!n"); exit(EXIT_FAILURE); } num++; times++; } close(sockfd); return 0; } 以上是server片段程式 我想實作一個就是可以接受多個client的socket 以上的code可以做到接收多個client但無法同時執行pthread_create 就是說當我第一個client連線到server時,正執行pthread的thread_function時 當有其他client連入,必須等到pthread結束..等下個accept後才能執行 但我想做到的是 當第一個client連線執行時,這時有另一個client連入後可以馬上接受accept並執行 pthread的thread_function 不知道要如何修改才能達到? -- ※ 發信站: 批踢踢實業坊(ptt.cc), 來自: 175.98.141.254 ※ 文章網址: https://www.ptt.cc/bbs/C_and_CPP/M.1481854942.A.B04.html

12/16 10:53, , 1F
listen 只需要 listen 一次,不用一直 loop
12/16 10:53, 1F

12/16 10:59, , 2F
單純回答你的問題,就多開幾個thread/process來接收連線
12/16 10:59, 2F

12/16 11:00, , 3F
建議在 accept() 加上 lock 一次只讓一個 thread 接收
12/16 11:00, 3F

12/16 11:00, , 4F
不過如果你要的是效能(提高每秒連線數),
12/16 11:00, 4F

12/16 11:01, , 5F
那又是另一個問題了...
12/16 11:01, 5F

12/16 14:08, , 6F
multi-process 一起 listen 同一個 socket 的方法可以參
12/16 14:08, 6F

12/16 14:08, , 7F
考 Richard Stevens 的 Unix Network Programming
12/16 14:08, 7F

12/16 14:09, , 8F
裡面有完整的 sample code
12/16 14:09, 8F

12/19 08:42, , 9F
不大懂樓主的意思,create應該立刻就結束,就進下一個
12/19 08:42, 9F

12/19 08:42, , 10F
迴圈去接受新的client了不是嗎?
12/19 08:42, 10F

12/19 08:44, , 11F
thread_function是由create的thread去做,main thread
12/19 08:44, 11F

12/19 08:44, , 12F
不會等他結束才進下一個迴圈接受新client
12/19 08:44, 12F

12/19 18:19, , 13F
應該是一次開多個accept();在accept前用mutex鎖上
12/19 18:19, 13F

12/19 18:19, , 14F
這樣就可以零時差接到下一個accept();
12/19 18:19, 14F

12/20 15:23, , 15F
去看mjpg_streamer的source code
12/20 15:23, 15F
文章代碼(AID): #1OKq_Ui4 (C_and_CPP)
文章代碼(AID): #1OKq_Ui4 (C_and_CPP)