-
Notifications
You must be signed in to change notification settings - Fork 0
/
protocol_client.py
37 lines (28 loc) · 959 Bytes
/
protocol_client.py
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
import asyncio
import functools
class EchoClientProtocol(asyncio.Protocol):
def __init__(self, loop):
self.loop = loop
def connection_made(self, transport):
message = 'hello world!'
transport.write(message.encode())
print('Data sent: {!r}'.format(message))
def data_received(self, data):
print('Data received: {!r}'.format(data.decode()))
def connection_lost(self, exc):
print('The server closed the connection')
print('Stop the event loop')
self.loop.stop()
def main():
loop = asyncio.get_event_loop()
coro = loop.create_connection(functools.partial(EchoClientProtocol, loop=loop),
'127.0.0.1', 8881)
loop.run_until_complete(coro)
try:
loop.run_forever()
except Exception as e:
print(str(e))
finally:
loop.close()
if __name__ == '__main__':
main()