python - 我怎样才能做一个多线程扭曲的python

Question

我有一个问题困扰了我很长时间，目前我正在研究一个从外部操作请求的守护进程。它就像一个服务器客户端。在这个项目中，我使用了一个 Twisted Python 框架，我成功地构建了一个非多线程服务器，它可以工作!但是现在，我需要同时服务好几个客户。我不知道如何在 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()

Answer 1

您的服务器默认处理并发客户端 - 没有线程 - 作为 Twisted 遵循的编程模型的属性。

我在您的示例代码中没有看到任何使此无效的内容 - 如果您删除了使用线程的(中断的)尝试，则此服务器在为多个客户端提供服务时应该没有任何问题。