Python 套接字重定向服务器 - 套接字错误： (98， "地址已在使用中")

Question

我有这样的脚本:

#!/usr/bin/python
import socket
import select
import time
import sys
buffer_size = 4096
delay = 0.0002
forward_to = ('127.0.0.1', 8888)
class Forward:
    def __init__(self):
        self.forward = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    def start(self, host, port):
        try:
            self.forward.connect((host, port))
            return self.forward
        except Exception, e:
            print e
            return False
class TheServer:
    input_list = []
    channel = {}
    def __init__(self, host, port):
        self.server = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        self.server.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        self.server.bind((host, port))
        self.server.listen(200)
    def main_loop(self):
        self.input_list.append(self.server)
        while 1:
            time.sleep(delay)
            ss = select.select
            inputready, outputready, exceptready = ss(self.input_list, [], [])
            for self.s in inputready:
                if self.s == self.server:
                    self.on_accept()
                    break
                self.data = self.s.recv(buffer_size)
                if len(self.data) == 0:
                    self.on_close()
                    break
                else:
                    self.on_recv()
    def on_accept(self):
        forward = Forward().start(forward_to[0], forward_to[1])
        clientsock, clientaddr = self.server.accept()
        if forward:
            print clientaddr, "has connected"
            self.input_list.append(clientsock)
            self.input_list.append(forward)
            self.channel[clientsock] = forward
            self.channel[forward] = clientsock
        else:
            print "Can't establish connection with remote server.",
            print "Closing connection with client side", clientaddr
            clientsock.close()
    def on_close(self):
        #print self.s.getpeername(), "has disconnected"
        self.input_list.remove(self.s)
        self.input_list.remove(self.channel[self.s])
        out = self.channel[self.s]
        self.channel[out].close()
        self.channel[self.s].close()
        del self.channel[out]
        del self.channel[self.s]
    def on_recv(self):
        data = self.data
        #print data
        self.channel[self.s].send(data)
if __name__ == '__main__':
    while True:
        server = TheServer('', 1080)
        try:
            server.main_loop()
        except KeyboardInterrupt:
            print "Ctrl C - Stopping server"
            sys.exit(1)
        except:
            pass

工作，问题是每2-3分钟给出此错误并关闭脚本:

('79.36.77.61', 58701) has connected
('79.36.77.61', 58702) has connected
Traceback (most recent call last):
  File ".redirect2.py", line 82, in ?
    server = TheServer('', 1080)
  File ".redirect2.py", line 30, in __init__
    self.server.bind((host, port))
  File "<string>", line 1, in bind
socket.error: (98, 'Address already in use')

如何解决这个问题?我尝试白色，但不工作:

if __name__ == '__main__':
    while True:
        try:
            server = TheServer('', 1080)
            server.main_loop()
        except KeyboardInterrupt:
            print "Ctrl C - Stopping server"
            sys.exit(1)
        except:
            pass

当这个解决方案脚本崩溃时:(请帮助我。

Answer 1

您的服务器正在崩溃并试图重新连接。前一个连接处于TIME_WAIT状态。如果您想重用该地址，请在绑定套接字之前添加SO_REUSEADDR套接字选项。