Python sock.listen (...)

Question

Tất cả các ví dụ tôi đã thấy trong số sock.listen(5) trong tài liệu python đề nghị tôi nên đặt số backlog tối đa là 5. Điều này gây ra sự cố cho ứng dụng của tôi vì tôi đang mong đợi một số lượng rất lớn (nhiều kết nối đồng thời). Tôi đặt nó lên 200 và chưa thấy bất kỳ vấn đề nào trên hệ thống của mình, nhưng tôi tự hỏi tôi có thể đặt nó cao đến mức nào trước khi nó gây ra vấn đề ..

Có ai biết không?

Chỉnh sửa: Đây là vòng lặp accept() của tôi.

while True:  
    try: 
     self.q.put(sock.accept()) 
    except KeyboardInterrupt: 
     break 
    except Exception, e: 
     self.log("ERR %s" % e) 

Answer 1

Các doc nói điều này

socket.listen(backlog) Nghe kết nối thực hiện cho các ổ cắm. Đối số tồn tại xác định số lượng tối đa số kết nối được xếp hàng đợi và phải có ít nhất 1; giá trị tối đa phụ thuộc vào hệ thống (thường là 5).

Rõ ràng giá trị hệ thống lớn hơn 5 trên hệ thống của bạn. Tôi không thấy lý do tại sao đặt nó thành một số lớn hơn sẽ là một vấn đề. Có lẽ một số bộ nhớ được dành riêng cho mỗi kết nối được xếp hàng đợi.

trang người đàn ông linux của tôi có điều này để nói

Nếu đối số tồn đọng lớn hơn giá trị trong /proc/sys/net/core/somaxconn, sau đó nó đang âm thầm cắt ngắn để giá trị đó; giá trị mặc định trong tập tin này là 128. Trong hạt nhân trước 2.4.25, giới hạn này là một giá trị cứng mã hóa, SOMAXCONN, với giá trị 128.

Answer 2

Bạn không cần phải điều chỉnh các tham số để listen() đến một số lớn hơn 5.

Tham số kiểm soát số lượng kết nối không phải là accept() được phép xuất sắc. Thông số listen() không mang về số lượng ổ cắm được kết nối đồng thời, chỉ trên số lượng kết nối đồng thời mà không được accept()-bởi quy trình.

Nếu điều chỉnh thông số thành listen() có tác động đến mã của bạn, đó là một triệu chứng xảy ra quá nhiều sự chậm trễ giữa mỗi cuộc gọi đến accept(). Sau đó bạn sẽ muốn thay đổi vòng lặp accept() của bạn sao cho nó có ít chi phí hơn.

Trong trường hợp của bạn, tôi đoán rằng self.q là một con trăn queue, trong trường hợp mà bạn có thể muốn gọi self.q.put_nowait() để tránh bất kỳ khả năng chặn các accept() vòng lặp tại cuộc gọi này.