Python SocketServer.BaseRequestHandler зная порт и использовать уже открытый порт - PullRequest
Новая
       19

Python SocketServer.BaseRequestHandler зная порт и использовать уже открытый порт

2 голосов
/ 12 октября 2010

Это код, который я сыграл, но каждый раз, когда я совершаю ошибку, я не могу перезапустить ее.Он говорит мне, что порт / сокет уже используется. Это первый вопрос. Второй вопрос в моем 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()

но это не работает.Привет

Ответы [ 2 ]

11 голосов
/ 07 июня 2011

Это на самом деле проще, чем это - вы можете просто установить его как переменную класса, а не переопределять init . Например., 

class MyServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
    allow_reuse_address = True
3 голосов
/ 12 октября 2010

Создайте свой 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()
...