Python SocketServer：发送到多个客户端？

Python SocketServer：发送到多个客户端？

您想在这里查看asyncore。您正在客户端调用的套接字 *** 作被阻止（在接收到一些数据或发生超时之前不会返回），这使得很难侦听主机发送的消息，并使客户端实例排队将数据发送到同一时间。异步应该从您那里抽象出基于超时的轮询循环。

这是代码“样本”-如果有任何不清楚的地方，请告诉我：

from __future__ import print_functionimport asyncoreimport collectionsimport loggingimport socketMAX_MESSAGE_LENGTH = 1024class RemoteClient(asyncore.dispatcher):    """Wraps a remote client socket."""    def __init__(self, host, socket, address):        asyncore.dispatcher.__init__(self, socket)        self.host = host        self.outbox = collections.deque()    def say(self, message):        self.outbox.append(message)    def handle_read(self):        client_message = self.recv(MAX_MESSAGE_LENGTH)        self.host.broadcast(client_message)    def handle_write(self):        if not self.outbox: return        message = self.outbox.popleft()        if len(message) > MAX_MESSAGE_LENGTH: raise ValueError('Message too long')        self.send(message)class Host(asyncore.dispatcher):    log = logging.getLogger('Host')    def __init__(self, address=('localhost', 0)):        asyncore.dispatcher.__init__(self)        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)        self.bind(address)        self.listen(1)        self.remote_clients = []    def handle_accept(self):        socket, addr = self.accept() # For the remote client.        self.log.info('Accepted client at %s', addr)        self.remote_clients.append(RemoteClient(self, socket, addr))    def handle_read(self):        self.log.info('Received message: %s', self.read())    def broadcast(self, message):        self.log.info('Broadcasting message: %s', message)        for remote_client in self.remote_clients: remote_client.say(message)class Client(asyncore.dispatcher):    def __init__(self, host_address, name):        asyncore.dispatcher.__init__(self)        self.log = logging.getLogger('Client (%7s)' % name)        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)        self.name = name        self.log.info('Connecting to host at %s', host_address)        self.connect(host_address)        self.outbox = collections.deque()    def say(self, message):        self.outbox.append(message)        self.log.info('Enqueued message: %s', message)    def handle_write(self):        if not self.outbox: return        message = self.outbox.popleft()        if len(message) > MAX_MESSAGE_LENGTH: raise ValueError('Message too long')        self.send(message)    def handle_read(self):        message = self.recv(MAX_MESSAGE_LENGTH)        self.log.info('Received message: %s', message)if __name__ == '__main__':    logging.basicConfig(level=logging.INFO)    logging.info('Creating host')    host = Host()    logging.info('Creating clients')    alice = Client(host.getsockname(), 'Alice')    bob = Client(host.getsockname(), 'Bob')    alice.say('Hello, everybody!')    logging.info('Looping')    asyncore.loop()

结果如下：

INFO:root:Creating hostINFO:root:Creating clientsINFO:Client (  Alice):Connecting to host at ('127.0.0.1', 51117)INFO:Client (    Bob):Connecting to host at ('127.0.0.1', 51117)INFO:Client (  Alice):Enqueued message: Hello, everybody!INFO:root:LoopingINFO:Host:Accepted client at ('127.0.0.1', 55628)INFO:Host:Accepted client at ('127.0.0.1', 55629)INFO:Host:Broadcasting message: Hello, everybody!INFO:Client (  Alice):Received message: Hello, everybody!INFO:Client (    Bob):Received message: Hello, everybody!