發送Socket對象分叉正在運行的進程（multiprocessing.Queue）

我學習使用HTML5 WebSockets的和的那部分，我用Python寫一個服務器，這樣我就可以知道他們是如何工作的細節問題。我前幾天創建了一個工作得很好的工作，但我想擴展它，以便支持多個端點，每個端點都是可以處理websocket客戶端的不同「服務」。現在，我的實現與產卵過程等工作（我使用多處理，而不是線程，因爲我讀了線程是不是真的多線程在CPython中，這就是我認爲我正在使用（默認安裝在Ubuntu 12.04 ）），但我無法將收到的客戶端套接字發送到服務進程。發送Socket對象分叉正在運行的進程（multiprocessing.Queue）

這裏是我送他們（這個循環運行）：

try: 
    #get a new client 
    conn, addr = server.accept() 
    print "Client connected from", addr 
    request = conn.recv(4096) 
    response, close, service = self.handshake(request) 
    conn.send(response) 
    if close: 
     print "Invalid request from", addr 
     conn.close() 
     continue 
    client = WebSockets.WebSocketClient(conn, addr) 
    service.clientConnQueue.put(client)

「服務器」是監聽傳入連接的插座。握手方法負責驗證其請求並確定將客戶端放入哪個服務進程。 'response'是要發送的http響應，'close'如果發生錯誤則爲True，'service'是從multiprocessing.Queue繼承的類。 WebSocktes.WebSocketClient是我的發送和接收實現存儲的地方，它基本上作爲套接字的包裝函數。

「clientConnQueue」創建像這樣：

class Service(multiprocessing.Process): 
    """Base class for all services.""" 
    def __init__(self, manager): 
     multiprocessing.Process.__init__(self) 
     self.manager = manager 
     self.clientConnQueue = self.manager.Queue() 
     self.shutdownFlag = multiprocessing.Event()

經理是一個multiprocessing.Manager（）

我得到的錯誤，當我嘗試把客戶在clientConnQueue如下：

File "./WebSocketServer.py", line 183, in <module> 
main() 
File "./WebSocketServer.py", line 180, in main 
server.runServer() 
File "./WebSocketServer.py", line 67, in runServer 
service.clientConnQueue.put(client) 
File "<string>", line 2, in put 
File "/usr/lib/python2.7/multiprocessing/managers.py", line 758, in _callmethod 
conn.send((self._id, methodname, args, kwds)) 
TypeError: expected string or Unicode object, NoneType found

然後我在接收端得到一個破損的管道錯誤。

我得到了我使用的是multiprocessing.Queue發送連接時同樣的錯誤，我認爲它改變成一個管理器創建隊列會解決這個問題。但是，它似乎做了完全相同的實現。

顯然，這是沒有辦法的辦法都應該送這樣的事情正在運行的進程，那麼什麼是正確的方法是發送非序列化對象的過程？

來源

2012-05-28 Los Frijoles