Une meilleure API pour l'UDP asynchrone
Une API de type websockets pour UDP
Voici un exemple de serveur d'écho :
import asyncio
import signal
import aioudp
async def main ():
async def handler ( connection ):
async for message in connection :
await connection . send ( message )
# Optional. This is for properly exiting the server when Ctrl-C is pressed
# or when the process is killed/terminated
loop = asyncio . get_running_loop ()
stop = loop . create_future ()
loop . add_signal_handler ( signal . SIGTERM , stop . set_result , None )
loop . add_signal_handler ( signal . SIGINT , stop . set_result , None )
# Serve the server
async with aioudp . serve ( "localhost" , 9999 , handler ):
await stop # Serve forever
if __name__ == '__main__' :
asyncio . run ( main ())
Et un client pour se connecter au serveur :
import asyncio
import aioudp
async def main ():
async with aioudp . connect ( "localhost" , 9999 ) as connection :
await connection . send ( b"Hello world!" )
assert await connection . recv () == b"Hello world!"
if __name__ == '__main__' :
asyncio . run ( main ())
Vous pouvez obtenir ce projet via pip
$ pip install aioudp
Ou, si vous utilisez la poésie
$ poetry add aioudp
Note
Cette bibliothèque ne fournit aucune autre abstraction sur l'interface UDP existante dans asyncio
autre que l'API basée sur async
/ await
. Cela signifie qu'aucun protocole implicite n'est géré dans cette bibliothèque tel que QUIC. Vous devez écrire le vôtre ou trouver une autre bibliothèque.
async
. Il a une API similaire (que je ne connaissais pas avant d'écrire cette bibliothèque)Copyright © 2021, Bryan Hu
Ce projet est sous licence GNU GPL v3+.
En bref, cela signifie que vous pouvez tout faire avec (distribuer, modifier, vendre) mais si vous deviez publier vos modifications, vous devez rendre le code source et les instructions de construction facilement accessibles.
Si vous êtes une entreprise utilisant ce projet et souhaitez une exception, envoyez-moi un e-mail à [email protected] et nous pourrons en discuter.