simple tools
Project description
version: 0.0.2
status: dev
author: hsz
email: hsz1273327@gmail.com
Desc
A tcp sever for running asyncio.Protocol. The inspiration comes from sanic,
only support python 3.6+
keywords:tcp-server,asyncio
Feature
with multiple worker
for asyncio.Protocol
can be closed by ctrl+C in windows
with hooks
Example
server.py
import asyncio
import time
from aio_tcpserver import tcp_server, listener
@listener("before_server_start")
async def beat(loop):
print(time.time())
print("ping")
class EchoServerClientProtocol(asyncio.Protocol):
def connection_made(self, transport):
peername = transport.get_extra_info('peername')
print('Connection from {}'.format(peername))
self.transport = transport
def data_received(self, data):
message = data.decode()
print('Data received: {!r}'.format(message))
print('Send: {!r}'.format(message))
self.transport.write(data)
print('Close the client socket')
self.transport.close()
def main():
tcp_server(EchoServerClientProtocol, worker=3)
if __name__ == '__main__':
main()
client.py
import asyncio
class EchoClientProtocol(asyncio.Protocol):
def __init__(self, message, loop):
self.message = message
self.loop = loop
def connection_made(self, transport):
transport.write(self.message.encode())
print('Data sent: {!r}'.format(self.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()
loop = asyncio.get_event_loop()
message = 'Hello World!'
coro = loop.create_connection(lambda: EchoClientProtocol(message, loop),
'127.0.0.1', 5000)
loop.run_until_complete(coro)
loop.run_forever()
loop.close()
Install
python -m pip install aio-tcpserver
Documentation
Project details
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
aio-tcpserver-0.0.2.tar.gz
(9.8 kB
view hashes)
Built Distribution
Close
Hashes for aio_tcpserver-0.0.2-py3-none-any.whl
Algorithm | Hash digest | |
---|---|---|
SHA256 | 768c9727ceaebd7ad825fcd09c0c5f7d0da986cb3036d561472b4c034fa1b396 |
|
MD5 | 9ef299ee61c988766b086fbd95d22b6c |
|
BLAKE2b-256 | ed17b08a16202ef1c1df1dff94c7547544e8c3e8997919f47a1468dd87fd504e |