Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import asyncio
- import random
- class EchoServerProtocol:
- def connection_made(self, transport):
- self.transport = transport
- def datagram_received(self, data, addr):
- message = data.decode()
- print('Received %r from %s' % (message, addr))
- rand = random.randint(0, 5)
- if rand >= 4:
- print('Send %r to %s' % (message, addr))
- self.transport.sendto(data, addr)
- else:
- print('Send %r to %s' % (message, addr))
- self.transport.sendto(data, addr)
- loop = asyncio.get_event_loop()
- print("Starting UDP server")
- # One protocol instance will be created to serve all client requests
- listen = loop.create_datagram_endpoint(
- EchoServerProtocol, local_addr=('192.168.43.215', 12000))
- transport, protocol = loop.run_until_complete(listen)
- try:
- loop.run_forever()
- except KeyboardInterrupt:
- pass
- transport.close()
- loop.close()
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement