2

这是我玩的代码，但每次我犯了错误我都无法重新启动它。它对我说端口/套接字已被使用这是第一个问题第二个问题在我的 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()

但它不起作用。问候

4

2 回答 2

11

它实际上比这更容易——您可以将其设置为类变量，而不是覆盖init。例如，

class MyServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
    allow_reuse_address = True
于 2011-06-07T02:55:29.863 回答
3

bind_and_activate=True在对构造函数的调用中创建您的 SocketServer 。

然后设置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()
于 2010-10-12T01:33:44.803 回答