diff options
| author | Victor Stinner <victor.stinner@gmail.com> | 2013-12-04 10:16:17 (GMT) |
|---|---|---|
| committer | Victor Stinner <victor.stinner@gmail.com> | 2013-12-04 10:16:17 (GMT) |
| commit | 31d83228c2c58d7882a742c1c297893c2508b925 (patch) | |
| tree | bd3ca5d7960b9d1d17747eb5bcdd595e0bd03f8f /Doc/library | |
| parent | bd306db07cd225151ccc3be725f7c1b240d710ef (diff) | |
| download | cpython-31d83228c2c58d7882a742c1c297893c2508b925.zip cpython-31d83228c2c58d7882a742c1c297893c2508b925.tar.gz cpython-31d83228c2c58d7882a742c1c297893c2508b925.tar.bz2 | |
asyncio doc: add some notes on the ping example
Diffstat (limited to 'Doc/library')
| -rw-r--r-- | Doc/library/asyncio-protocol.rst | 44 |
1 files changed, 26 insertions, 18 deletions
diff --git a/Doc/library/asyncio-protocol.rst b/Doc/library/asyncio-protocol.rst index 4b56b57..ae519e7 100644 --- a/Doc/library/asyncio-protocol.rst +++ b/Doc/library/asyncio-protocol.rst @@ -579,43 +579,52 @@ Network functions This function returns a :ref:`coroutine <coroutine>`. -Protocol example: TCP echo client and server +Protocol example: TCP echo server and client ============================================ Echo server ----------- -TCP echo server example:: +TCP echo server example, send back received data and close the connection:: import asyncio class EchoServer(asyncio.Protocol): def connection_made(self, transport): - print('connection made') + peername = transport.get_extra_info('peername') + print('connection from {}'.format(peername)) self.transport = transport - def data_received(self, data): - print('data received:', data.decode()) + print('data received: {}'.format(data.decode())) self.transport.write(data) # close the socket self.transport.close() - def connection_lost(self, exc): - print('connection lost') - loop = asyncio.get_event_loop() - f = loop.create_server(EchoServer, '127.0.0.1', 8888) - s = loop.run_until_complete(f) - print('serving on', s.sockets[0].getsockname()) - loop.run_forever() + task = loop.create_server(EchoServer, '127.0.0.1', 8888) + server = loop.run_until_complete(task) + print('serving on {}'.format(server.sockets[0].getsockname())) + + try: + loop.run_forever() + except KeyboardInterrupt: + print("exit") + finally: + server.close() + loop.close() + +:meth:`Transport.close` can be called immediatly after +:meth:`WriteTransport.write` even if data are not sent yet on the socket: both +methods are asynchronous. ``yield from`` is not needed because these transport +methods don't return coroutines. Echo client ----------- -TCP echo client example:: +TCP echo client example, send data and wait until the connection is closed:: import asyncio @@ -623,15 +632,14 @@ TCP echo client example:: message = 'This is the message. It will be echoed.' def connection_made(self, transport): - self.transport = transport - self.transport.write(self.message.encode()) - print('data sent:', self.message) + transport.write(self.message.encode()) + print('data sent: {}'.format(self.message)) def data_received(self, data): - print('data received:', data.decode()) + print('data received: {}'.format(data.decode())) def connection_lost(self, exc): - print('connection lost') + print('server closed the connection') asyncio.get_event_loop().stop() loop = asyncio.get_event_loop() |