赞
踩
我有一个asycnio tcp服务器,它连接到5个tcp客户端。在import asyncio
class EchoServerClientProtocol(asyncio.Protocol):
def connection_made(self, transport):
peername = transport.get_extra_info('peername')
print('Connection from {}'.format(peername))
self.transport = transport
def data_received(self, data):
message = data.decode()
print('Data received: {!r}'.format(message))
print('Send: {!r}'.format(message))
self.transport.write(data)
print('Close the client socket')
self.transport.close()
loop = asyncio.get_event_loop()
# Each client connection will create a new protocol instance
coro = loop.create_server(EchoServerClientProtocol, '127.0.0.1', 8888)
server = loop.run_until_complete(coro)
# Serve requests until Ctrl+C is pressed
print('Serving on {}'.format(server.sockets[0].getsockname()))
try:
loop.run_forever()
except keyboardInterrupt:
pass
# Close the server
server.close()
loop.run_until_complete(server.wait_closed())
loop.close()
我还有一个龙卷风网络插座,连接到3个网络浏览器。在
^{pr2}$
现在我想合并他们。在这儿我想做的是:
我的服务器会一直监听我的客户。
当数据从其中任何一个到达时,程序将用Websocket异步地发布到webbrowser。
我做了很多研究,但是没有成功。。。在
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。