3

以前から気になっていたことがあるのですが、現在、外部からのリクエストを操作するデーモンを開発中です。サーバークライアントのようなものです。このプロジェクトでは、Twisted Python Framework を使用しており、非マルチスレッド サーバーの構築に成功しました。しかし今、私は一度に複数の顧客にサービスを提供する必要があります。Twisted Framework でこれを行う方法がわかりません。私が知っていることはすべて試しました...

これで私を助けてください:|

class Server(protocol.Protocol, protocol.Factory):

def buildProtocol(self, addr):                               
    if addr.host in ipList:
        log.msg("Connected from IP: " + addr.host)
        return self
    return None

def dataReceived(self, data):
    reactor.callFromThread(self.actionCreator(data))

def actionCreator(self, data):
    jsonData = json.loads(data)
    if not jsonData["action"]:
        log.msg("Incorrect data from IP: " + self.transport.getPeer().host + " data: " + data)
        self.transport.write(json.dumps({'response' : '300'}))
    elif jsonData["action"] == 'echo':
        log.msg("Doing ask from IP: " + self.transport.getPeer().host)
        self.transport.write(json.dumps({'response' : '400', 'data' : {'status' : 'online'}}))
    elif jsonData["action"] == 'wget': 
        log.msg("Downloading file... for user - " + jsonData["user"])
        os.system("wget -q http://****************")
        self.transport.write(json.dumps({'response' : '400', 'data' : {'status' : 'downloaded'}}))
    else:
        log.msg("Incorrect data from IP: " + self.transport.getPeer().host + " data: " + data)
        self.transport.write(json.dumps({'response' : '300'}))


if __name__ == '__main__':
    try:
        log.msg("Running server...")
        context = ssl.DefaultOpenSSLContextFactory(certificate + "/server.key", certificate + "/server.crt")
        log.msg("Initiating a secure SSL connection...")
        reactor.listenSSL(config.getint(general, 'port'), Server(), context)
        log.msg("Waiting for connections...")

        reactor.run()  
    except KeyboardInterrupt:
        sys.exit()
4

1 に答える 1

1

サーバーは、デフォルトで (スレッドなしで) 並列クライアントをプログラミング モデルのプロパティとして扱い、その後に Twisted が続きます。

これを無効にするサンプルコードには何も表示されません-(壊れた)スレッドを使用しようとする試みを削除すると、このサーバーは複数のクライアントにサービスを提供しても問題はありません。

于 2013-10-06T21:50:47.007 に答える