Commit 94038018 authored by Victor Stinner's avatar Victor Stinner

asyncio doc: add some notes on the ping example

parent 1d28cbb8
...@@ -579,43 +579,52 @@ Network functions ...@@ -579,43 +579,52 @@ Network functions
This function returns a :ref:`coroutine <coroutine>`. This function returns a :ref:`coroutine <coroutine>`.
Protocol example: TCP echo client and server Protocol example: TCP echo server and client
============================================ ============================================
Echo server Echo server
----------- -----------
TCP echo server example:: TCP echo server example, send back received data and close the connection::
import asyncio import asyncio
class EchoServer(asyncio.Protocol): class EchoServer(asyncio.Protocol):
def connection_made(self, transport): def connection_made(self, transport):
print('connection made') peername = transport.get_extra_info('peername')
print('connection from {}'.format(peername))
self.transport = transport self.transport = transport
def data_received(self, data): def data_received(self, data):
print('data received:', data.decode()) print('data received: {}'.format(data.decode()))
self.transport.write(data) self.transport.write(data)
# close the socket # close the socket
self.transport.close() self.transport.close()
def connection_lost(self, exc):
print('connection lost')
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
f = loop.create_server(EchoServer, '127.0.0.1', 8888) task = loop.create_server(EchoServer, '127.0.0.1', 8888)
s = loop.run_until_complete(f) server = loop.run_until_complete(task)
print('serving on', s.sockets[0].getsockname()) print('serving on {}'.format(server.sockets[0].getsockname()))
try:
loop.run_forever() 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 Echo client
----------- -----------
TCP echo client example:: TCP echo client example, send data and wait until the connection is closed::
import asyncio import asyncio
...@@ -623,15 +632,14 @@ TCP echo client example:: ...@@ -623,15 +632,14 @@ TCP echo client example::
message = 'This is the message. It will be echoed.' message = 'This is the message. It will be echoed.'
def connection_made(self, transport): def connection_made(self, transport):
self.transport = transport transport.write(self.message.encode())
self.transport.write(self.message.encode()) print('data sent: {}'.format(self.message))
print('data sent:', self.message)
def data_received(self, data): def data_received(self, data):
print('data received:', data.decode()) print('data received: {}'.format(data.decode()))
def connection_lost(self, exc): def connection_lost(self, exc):
print('connection lost') print('server closed the connection')
asyncio.get_event_loop().stop() asyncio.get_event_loop().stop()
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment