BaseRequestHandlerへのPythonのアクセス

Question

私のコードは、基本的には、クライアントとの簡単なチャットサーバーを起動する必要があります。どこのサーバーとクライアントが前後にお互いに話すことができます。私はすべてが正しく実装されるように得ているが、私は、私が行っていたときに、サーバーをシャットダウンする方法を見つけ出すことはできません。 （私はそれのss.shutdown()を知っています）。

私は2つ（"bye"のようなもの）の間で共有キーワードをもとに、今終了したいんだけど、私は何とかSocketServerにBaseRequestHandlerから私のshutdown()にメッセージを送ることができれば、それはメッセージを受信するたびに、私は知りませんます。

結局、私の目標は、GUIを作るためにTkinterを組み込むことであるが、私は最初の仕事に他のすべてを取得したい、これはPythonでソケットを扱うのは初めてです。

from sys import argv, stderr
from threading import Thread
import socket
import SocketServer
import threading
import sys

class ThreadedRecv(Thread):
    def __init__(self,socket):
        Thread.__init__(self)
        self.__socket = socket
        self.__message = ''
        self.__done = False
    def recv(self):
        while self.__message.strip() != "bye" and not self.getStatus():
            self.__message = self.__socket.recv(4096)
            print 'received',self.__message
        self.setStatus(True)

    def run(self):
        self.recv()

    def setStatus(self,status):
        self.__done = status

    def getStatus(self):
        return self.__done

class ThreadedSend(Thread):
    def __init__(self,socket):
        Thread.__init__(self)
        self.__socket = socket
        self.__message = ''
        self.__done = False
    def send(self):
        while self.__message != "bye" and not self.getStatus():
            self.__message = raw_input()
            self.__socket.send(self.__message)
        self.setStatus(True)

    def run(self):
        self.send()

    def setStatus(self,status):
        self.__done = status

    def getStatus(self):
        return self.__done



class HostException(Exception):
    def __init__(self, value):
        self.value = value
    def __str__(self):
        return repr(self.value)

class EchoServer(SocketServer.BaseRequestHandler):
    def setup(self):
        print self.client_address, 'is connected!'
        self.request.send('Hello ' + str(self.client_address) + '\n')
        self.__done = False
    def handle(self):

        sender = ThreadedSend(self.request)
        recver = ThreadedRecv(self.request)
        sender.start()
        recver.start()
        while 1:
            if recver.getStatus():
                sender.setStatus(True)
                break
            if sender.getStatus():
                recver.setStatus(True)
                break         

    def finish(self):
        print self.client_address, 'disconnected'
        self.request.send('bye client %s\n' % str(self.client_address))
        self.setDone(True)

    def setDone(self,done):
        self.__done = done

    def getDone(self):
        return self.__done



def setup(arg1, arg2, arg3):
    server = False
    defaultPort,defaultHost = 2358,"localhost"
    hosts = []
    port = defaultPort
    serverNames = ["TRUE","SERVER","S","YES"]
    arg1 = arg1.upper()
    arg2 = arg2.upper()
    arg3 = arg3.upper()
    if arg1 in serverNames or arg2 in serverNames or arg3 in serverNames:
    server = True
    try:
        port = int(arg1)
        if arg2 != '':
            hosts.append(arg2)
    except ValueError:
        if arg1 != '':
            hosts.append(arg1)
        try:
            port = int(arg2)
            if arg3 != '':
                hosts.append(arg3)
        except ValueError:
            if arg2 != '':
                hosts.append(arg2)
            try:
                port = int(arg3)
            except ValueError:
                if arg3 != '':
                    hosts.append(arg3)
                port = defaultPort

    for sn in serverNames:
        if sn in hosts:
            hosts.remove(sn)

    try:
        if len(hosts) != 1:
            raise HostException("Either more than one or no host "+ \
                                "declared.  Setting host to localhost.")
    except HostException as error:
        print error.value, "Setting hosts to default"
        return (server,defaultHost,port)

    return (server,hosts[0].lower(),port)

def main():
    bufsize = 4096
    while len(argv[1:4]) < 3:
        argv.append('')
    settings = setup(*argv[1:4])
    connections = (settings[1],settings[2])
    print connections
    if not settings[0]:
        try:
            mySocket = socket.socket(socket.AF_INET,\
                                     socket.SOCK_STREAM)
        except socket.error, msg:
            stderr.write("[ERROR] %s\n" % msg[1])
            sys.exit(1)
        try:
            mySocket.connect(connections)
        except socket.error, msg:
            stderr.write("[ERROR] %s\n" % msg[1])
            sys.exit(2)

        message = ""
        print "Enter a message to send to the server. "+\
              "Enter \"bye\" to quit."
        sender = ThreadedSend(mySocket)
        recver = ThreadedRecv(mySocket)
        sender.start()
        recver.start()
        while 1:
            if sender.getStatus():
                recver.setStatus(True)
                break
            if recver.getStatus():
                sender.setStatus(True)
                break    

    else:
        xserverhandler = EchoServer
        serversocket = SocketServer.ThreadedTCPServer(\
            connections,xserverhandler)
        server_thread = Thread(target = serversocket.serve_forever)
        server_thread.setDaemon(True)
        server_thread.start()
        # I would like to shut down this server whenever 
        # I get done talking to it.
        """while 1:
            if xserverhandler.getDone():
                print 'This is now true!'
                serversocket.shutdown()
                break"""

if __name__ == '__main__':
    main()

うん、私は（セットアップを知っている）は、試してみるのとキャッチで今ひどい関数であるが、私は後でそれを修正するつもりだったので、それは、今のところ機能します。

私の質問は基本的である：どのように私は実際にそれが受信したメッセージに基づいて終了するために、サーバーを得ることができますか？可能であれば、それは始まっています後にリクエスト・ハンドラにアクセスする方法はありますか？

Answer 1

それが動作するようにコードを修正し、それを使用するいくつかの方法を記載してください。あなたが追加する必要があります。

class ThreadedTCPServer(SocketServer.ThreadingMixIn, SocketServer.TCPServer):
    pass

SocketServerが実際に（少なくともない2.6や2.7の私のバージョンで）そのクラスが含まれていないからです。代わりに、それは SocketServer定義するからの例を示します。

コードを使用/起動する方法の例を記載してください。

：この場合、あなたがする必要があるサーバを起動するには

ss.py SERVER localhost 8001

として

とクライアント

ss.py localhost 8001

あなたがそれを行う場合に実行されている他のスレッドが存在しないので、

あなたは、サーバーがすぐに終了することを意味しており、server_thread.setDaemon（true）を行うことはできません。

それは解決策は次のように、あなたのEchoServer.handle方法のself.server.shutdown（）insdieにコール（または2）を追加することで行われています一度

    while 1:
        if recver.getStatus():
            sender.setStatus(True)
            self.server.shutdown()
            break

しかし、私は仕事にそれを得ることができない、と私は物事がうまく継承された、またはあなたが何をしたかで間違って推測するので、それはだと思います。

何をすべきことは、Pythonでチャットサーバーを行っている他の誰かのための検索です。 Googleの私が見つけた使用 http://www.slideshare.net/didip/socket-で-pythonのプログラミングと他の人が確かに存在します。

あなたはGUIをミックスしようとしている場合は、

また、スレッド、あなたはそれに基づい例になるはずプログラミング。私は「Tkinterのチャット」の検索ヒット数があります。また、あなたはすでに、これらの問題の多くを解決した、ツイストに見たいと思うかもしれません。

どのような問題？さて、例えば、あなたは可能性SO_REUSEADDRソケットオプションを望んます。

Answer 2

要求ハンドラオブジェクトは、それぞれの新しい要求のために作成されます。ハンドラではない、サーバーのフラグを「完了」を格納する必要がありますので。次のような何かます：

class EchoServer(SocketServer.BaseRequestHandler):
    ...
    def setDone(self):
        self.server.setDone() # or even better directly self.server.shutdown()