服務器進程使得管道插座不立即關閉

Question

我有以下的代碼，服務器接受的網絡連接，它傳遞給孩子Manager().Queue()處理：

q = Manager().Queue() 

class Server: 

    def run(self, host, port): 
     s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
     s.bind((host, port)) 
     s.listen(1) 

     print('parent', os.getpid()) 

     while True: 
      c, _ = s.accept() 
      q.put(c) 
      c.close() 

def handle_request(): 
    print('child', os.getpid()) 
    while True: 
     c = q.get() 
     time.sleep(1) 
     print(c.recv(4)) 
     c.close() 

Process(target=handle_request, args=()).start() 
Server().run('127.0.0.1', 10000) 

close不作爲工作預計，我認爲這是因爲Manager的服務器進程窗口對該套接字有參考，​​lsof -i已確認。如何處理這個？我發現沒有辦法在Manager進程中關閉套接字，shutdown可以做到這一點，但不是我想要的。

Answer 1

有趣的問題。

我不確定這是否有幫助，但我發現你的代碼在開始時有點奇怪，因爲使用Manager().Queue()向另一個進程發送套接字對象聽起來並不像它受支持。它可能是，但發送一個文件描述符到另一個進程需要幾圈。我改變你的代碼做一點，因爲我會這樣做 - 基本上減少和重建手柄。

from multiprocessing import Manager, Process 
from multiprocessing.reduction import reduce_handle, rebuild_handle 
import socket 
import os 
from time import sleep 

q = Manager().Queue() 


class Server: 
    def run(self, host, port): 
     s = socket.socket(socket.AF_INET, socket.SOCK_STREAM) 
     s.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 
     s.bind((host, port)) 
     s.listen(1) 

     print('parent', os.getpid()) 

     while True: 
      c, _ = s.accept() 
      foo = reduce_handle(c.fileno()) 
      q.put(foo) 
      c.close() 


def handle_request(): 
    print('child', os.getpid()) 
    while True: 
     bar = q.get() 
     sleep(1) 
     barbar = rebuild_handle(bar) 
     c = socket.fromfd(barbar, socket.AF_INET, socket.SOCK_STREAM) 
     print(c.recv(4)) 
     c.shutdown(socket.SHUT_RDWR) 

Process(target=handle_request, args=()).start() 
Server().run('127.0.0.1', 10000) 

這不留下任何插座在CLOSE_WAIT至少，當我跑它，和它的作品，我會期望它的工作。