python SocketServer.BaseRequestHandler 知道端口并使用已打开的端口

Question

这是我写的代码，但每次我出错后，我都无法重新启动它。系统告诉我端口/套接字已经被占用了。这是第一个问题。第二个问题是，在我的 MyTCPHandler 里，我怎么知道使用的是哪个端口呢？以下是我的代码：

# MetaProject v 0.2
# -*- coding: utf-8 -*-
"""
Thanks to :
People from irc :
Flox,Luyt
People from stack Overflow :
Philippe Leybaert,Platinum Azure,methodin,Suresh Kumar,S.Lott,MatTheCat,
kevpie,Ignacio Vazquez-Abrams,adamk,Frédéric Hamidi,THC4k,THC4k,Blam
"""
import SocketServer
import threading

class MyTCPHandler(SocketServer.BaseRequestHandler):
    def handle(self):
        self.data = self.request.recv(1024)
        socket = self.request
        print "%s wrote:" % self.client_address[0]
        print self.data
        print self.__dict__
        socket.sendto(self.data.upper(), self.client_address)

def serve_thread(host, port):
    server = SocketServer.TCPServer((host, port), MyTCPHandler)
    server.serve_forever()

if __name__ == "__main__":
    threading.Thread(target=serve_thread,args=('localhost', 1238)).start()
    threading.Thread(target=serve_thread,args=('localhost', 1237)).start()
    print "toto"

我做了：

def serve_thread(host, port):
    if port == 1858 :
        server = SocketServer.TCPServer((host, port), Serverhttp,bind_and_activate=True)
    elif port == 1958 :
        server = SocketServer.TCPServer((host, port), Serversmtp,bind_and_activate=True)
    server.allow_reuse_address=True
    server.serve_forever()

但是它不工作。祝好。

Answer 1

其实这比你想的要简单得多——你可以直接把它设置为一个类变量，而不是重写init方法。比如说，

class MyServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
    allow_reuse_address = True

Answer 2

创建你的SocketServer时，在构造函数中使用 bind_and_activate=True。

然后设置 server.allow_reuse_address=True。

如果你想区分两个端口，可以为请求处理器使用两个不同的类。

编辑：

把你的代码修改成这样：

def serve_thread(host, port):
    if port == 1858 :
        server = SocketServer.TCPServer((host, port), Serverhttp,bind_and_activate=True)
    elif port == 1958 :
        server = SocketServer.TCPServer((host, port), Serversmtp,bind_and_activate=True)
    server.allow_reuse_address=True
    server.server_bind()
    server.server_activate()
    server.serve_forever()

创建你自己的服务器类可能会更清晰。可以像这样做：

class ReuseAddrServer(SocketServer.TCPServer):
    def __init__(self, (host, port)):
        SocketServer.TCPServer.__init__(self, (host, port), bind_and_activate=False)
        self.allow_reuse_address = True
        self.server_bind()
        self.server_activate()