kopia lustrzana https://github.com/peterhinch/micropython-samples
65 wiersze
2.1 KiB
Python
65 wiersze
2.1 KiB
Python
# application.py
|
|
|
|
# Released under the MIT licence.
|
|
# Copyright (C) Peter Hinch 2018
|
|
|
|
# The App class emulates a user application intended to service a single
|
|
# client. In this case we have four instances of the application servicing
|
|
# clients with ID's 1-4.
|
|
|
|
import uasyncio as asyncio
|
|
loop = asyncio.get_event_loop(runq_len=32, waitq_len=32)
|
|
import ujson
|
|
import server
|
|
|
|
class App():
|
|
def __init__(self, client_id):
|
|
self.client_id = client_id
|
|
self.data = [0, 0] # Exchange a 2-list with remote
|
|
loop = asyncio.get_event_loop()
|
|
loop.create_task(self.start(loop))
|
|
|
|
async def start(self, loop):
|
|
print('Client {} Awaiting connection.'.format(self.client_id))
|
|
conn = None
|
|
while conn is None:
|
|
await asyncio.sleep_ms(100)
|
|
conn = server.client_conn(self.client_id)
|
|
loop.create_task(self.reader(conn))
|
|
loop.create_task(self.writer(conn))
|
|
|
|
async def reader(self, conn):
|
|
print('Started reader')
|
|
while True:
|
|
# Attempt to read data: server times out if none arrives in timeout
|
|
# period closing the Connection. .readline() pauses until the
|
|
# connection is re-established.
|
|
line = await conn.readline()
|
|
self.data = ujson.loads(line)
|
|
# Receives [restart count, uptime in secs]
|
|
print('Got', self.data, 'from remote', self.client_id)
|
|
|
|
# Send [approx application uptime in secs, received client uptime]
|
|
async def writer(self, conn):
|
|
print('Started writer')
|
|
count = 0
|
|
while True:
|
|
self.data[0] = count
|
|
count += 1
|
|
print('Sent', self.data, 'to remote', self.client_id)
|
|
print()
|
|
# .write() behaves as per .readline()
|
|
await conn.write('{}\n'.format(ujson.dumps(self.data)))
|
|
await asyncio.sleep(5)
|
|
|
|
|
|
clients = [App(n) for n in range(1, 5)] # Accept 4 clients with ID's 1-4
|
|
try:
|
|
loop.run_until_complete(server.run(timeout=1500))
|
|
except KeyboardInterrupt:
|
|
print('Interrupted')
|
|
finally:
|
|
print('Closing sockets')
|
|
for s in server.socks:
|
|
s.close()
|