如何在asyncio和transport_基类中创建python并行套接字？

Question

我在python中使用asyncio作为不间断服务器，并实现了 连接已建立，连接丢失，数据已接收 我的ServerClientProtocol中的函数

我第一次使用这个类是因为我使用了多次向socket类socket发送数据 关闭程序退出

第二个原因是我认为它是异步的，并且可以同时并行应答多个传入的套接字， 但事实并非如此。在

我应该如何在一个异步线程和并行应答套接字中使用它？在

这是我的代码：

    class ServerClientProtocol(asyncio.Protocol):    
        def connection_made(self,transport):
            self.transport = transport

        def connection_lost(self,exc):
            pass

        def data_received(self, data):
            server.server(self,data)

    def main(*args):    
        loop = get_event_loop()        
        coro = loop.create_server(ServerClientProtocol, '127.0.0.1', 50008)    
        srv = loop.run_until_complete(coro)    
        loop.run_forever()    
    if __name__ == '__main__':
        main()

Answer 1

server.server()可能正在阻止其他连接。如果这是一个长时间运行的调用，请尝试使用^{}（示例here），并使用^{}调用{}