如何糾正一個類中產生的進程導致的「每個地址錯誤只有一個套接字使用」？

Question

目前，我正在嘗試開發一個服務器框架，將消息從抽搐傳遞到本地網絡上的其他計算機。我有一個名爲服務器的類，下面我有一個簡單的例子，它演示了我遇到的問題。問題是twitch_socket正在創建兩次並綁定到地址/端口。我的預期結果是套接字將在服務器類的子進程之間共享。我如何修改這個類，甚至完全擺脫它，這樣進程就可以在它們之間共享套接字？

import multiprocessing 
import socket 
import re 
from BotPass import PASSWORD 
def send_message(socketobj, message): 
    'Sends a str as bytes through socket' 
    message = message.encode() 
    socketobj.sendall(message) 
def recv_message(socketobj): 
    'Receives a str as bytes though socket' 
    return socketobj.recv(2048).decode() 
class Server: 
    'Handles receiving messages from twitch and directs messages from clients' 
    twitch_socket = socket.socket() 
    twitch_socket.connect(('irc.chat.twitch.tv', 6667)) 
    send_message(twitch_socket, 'PASS %s\r\n' % (PASSWORD)) 
    send_message(twitch_socket, 'NICK %s\r\n' % ('squid_coin_bot')) 
    send_message(twitch_socket, 'JOIN #jtv\r\n') 
    send_message(twitch_socket, 'CAP REQ :twitch.tv/commands\r\n') 
    server_socket = socket.socket() 
    server_socket.bind(('', 9999)) 
    work_queue = multiprocessing.Queue() 
    #Queue of messages from twitch 
    worker_queue = multiprocessing.Queue() 
    #Queue of free client socket objects 
    result_queue = multiprocessing.Queue() 
    #Queue of what to send back to twitch 
    def start(): 
     accept_process = multiprocessing.Process(target=Server.accept_connections) 
     # *This is most likely where the issue is occurring* 
     accept_process.daemon = True 
     accept_process.start() 
    def accept_connections(): 
     '' 
     Server.server_socket.listen(10) 
     while 1: 
      (clientsocket, clientaddr) = Server.server_socket.accept() 
      # What I believe I am referencing here is the server socket which is inherent to the Server class 
      if re.match(r'192\.168\.\d{1,3}\.\d{1,3}', clientaddr[0])\ 
      or clientaddr[0] == '127.0.0.1': 
       Server.worker_queue.put(clientsocket) 
      else: 
       clientsocket.close() 
Server.start() 
input() 

輸出在控制檯：

Traceback (most recent call last): 
    File "<string>", line 1, in <module> 
    File "C:\Program Files\Python36\lib\multiprocessing\spawn.py", line 105, in spawn_main 
    exitcode = _main(fd) 
    File "C:\Program Files\Python36\lib\multiprocessing\spawn.py", line 114, in _main 
    prepare(preparation_data) 
    File "C:\Program Files\Python36\lib\multiprocessing\spawn.py", line 225, in prepare 
    _fixup_main_from_path(data['init_main_from_path']) 
    File "C:\Program Files\Python36\lib\multiprocessing\spawn.py", line 277, in _fixup_main_from_path 
    run_name="__mp_main__") 
    File "C:\Program Files\Python36\lib\runpy.py", line 263, in run_path 
    pkg_name=pkg_name, script_name=fname) 
    File "C:\Program Files\Python36\lib\runpy.py", line 96, in _run_module_code 
    mod_name, mod_spec, pkg_name, script_name) 
    File "C:\Program Files\Python36\lib\runpy.py", line 85, in _run_code 
    exec(code, run_globals) 
    File "C:\twitch-market\server.py", line 18, in <module> 
    class Server: 
    File "C:\twitch-market\server.py", line 27, in Server 
    server_socket.bind(('', 9999)) 
OSError: [WinError 10048] Only one usage of each socket address (protocol/network address/port) is normally permitted 

Answer 1

添加此socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1) 這是因爲以前的執行留下了一個TIME_WAIT狀態的插座，並不能立即reused.the SO_REUSEADDR標誌告訴內核在TIME_WAIT狀態下重用本地套接字，而無需等待其自然超時過期。