Sử dụng accept() và chọn() cùng một lúc?

Question

Tôi có một chương trình máy chủ mạng hướng sự kiện. Chương trình này chấp nhận các kết nối từ các quá trình khác trên các máy chủ khác. Có thể có nhiều kết nối ngắn ngủi từ các cổng khác nhau trên cùng một IP từ xa.

Hiện tại, tôi có một vòng lặp while(1) gọi accept() và sau đó sinh ra một luồng để xử lý kết nối mới. Mỗi kết nối được đóng lại sau khi tin nhắn được đọc. Ở đầu từ xa, kết nối sẽ bị đóng sau khi tin nhắn được gửi đi.

Tôi muốn loại bỏ chi phí của việc thiết lập và xé các kết nối bằng cách lưu bộ nhớ đệm các ổ cắm FD mở. Về phía người gửi, điều này rất dễ dàng - tôi chỉ không đóng các kết nối và giữ chúng xung quanh.

Ở phía người nhận, khó hơn một chút. Tôi biết tôi có thể lưu trữ FD trả về accept() trong cấu trúc và nghe tin nhắn trên tất cả các ổ cắm như vậy bằng cách sử dụng poll() hoặc select(), nhưng tôi muốn đồng thời cả hai đều nghe kết nối mới qua số accept()và nghe trên tất cả các kết nối được lưu trong bộ nhớ cache.

Nếu tôi sử dụng hai luồng, một trên poll() và một trên accept(), sau đó khi trả về cuộc gọi accept() (kết nối mới), tôi phải đánh thức luồng khác đang chờ kết nối cũ. Tôi biết tôi có thể làm điều này với một tín hiệu và pselect(), nhưng toàn bộ mớ hỗn độn này có vẻ như cách quá nhiều công việc cho một cái gì đó rất đơn giản.

Có cuộc gọi hoặc phương pháp vượt trội nào sẽ cho phép tôi xử lý đồng thời các kết nối mới đang được mở và dữ liệu được gửi trên các kết nối cũ không?

Answer 1

Thời gian qua tôi đã kiểm tra, bạn có thể chỉ listen trên một socket và sau đó select hoặc poll để xem nếu một kết nối đến trong Nếu vậy, accept nó.; nó sẽ không chặn (nhưng bạn có thể muốn thực sự cần bộ O_NONBLOCK chỉ để đảm bảo)

Answer 2

Tôi muốn đặt một người biết lắng nghe trong quá trình riêng biệt (thread) không để những thứ dơ lên. Và chạy một quy trình công nhân trên một quy trình khác để xử lý các ổ cắm hiện có. Không cần thiết cho người nghe không chặn thực sự. Và không có chủ đề trên không chạy 2 chủ đề.

Nó sẽ hoạt động như thế: bạn chấp nhận chuỗi người nghe cho đến khi nó trả về cho bạn một bộ mô tả ổ cắm máy khách và chuyển nó cho nhân viên đang thực hiện tất cả công việc đọc/ghi bẩn trên đó.

Nếu bạn muốn nghe một số cảng và không muốn giữ một quá trình mỗi người nghe tôi đề nghị bạn cài đặt ổ cắm của bạn trong O_NONBLOCK và làm someth như:

// loop through listeners here and poll'em for read, when read is successful call accept, get descriptor, pass it to worker and continue listen 
    while(1){ 
     foreach(serverSocket in ServerSockets){ 
      if(serverSocket.Poll(10, SelectRead)){ 
        clientSocket = serverSocket.Accept(); 
        // pass to worker here and release 
      } 

     } 
    } 

Answer 3

bạn có thể sử dụng lắng nghe sau đó sử dụng chọn hoặc thăm dò ý kiến ​​sau đó chấp nhận

if (listen (socket_fd, Number_connection) <0) 
{ 
    perror("listen"); 
    return 1; 
} 
fd_set set; 
struct timeval timeout; 
int rv; 
FD_ZERO(&set); /* clear the set */ 
FD_SET(socket_fd, &set); /* add our file descriptor to the set */ 

timeout.tv_sec = 20; 
timeout.tv_usec = 0; 

rv = select(socket_fd + 1, &set, NULL, NULL, &timeout); 
if(rv == -1) 
{ 
    perror("select"); /* an error accured */ 
    return 1; 
} 
else if(rv == 0) 
{ 
    printf("timeout occurred (20 second) \n"); /* a timeout occured */ 
    return 1; 
} 
else 
    client_socket_fd = accept (socket_fd,(struct sockaddr *) &client_name, &client_name_len);