Nous sommes en train de passer d'un environnement basé sur python à celui de scala play framework et je dois écrire un abonné d'éditeur tamponné qui va s'interfacer avec un autre système écrit en python. L'objectif ici est d'écrire un éditeur qui prendrait les messages d'une mémoire tampon/file d'attente et les enverrait à un serveur via une socket tcp et garderait le socket ouvert pour que nous puissions le réutiliser plus tard. Notre ancien éditeur python a créé un socket socket.socket (socket.AF_INET, socket.SOCK_STREAM) qui ne se fermera jamais et a travaillé avec un planificateur pour retirer les messages de la file d'attente et les envoyer sur le socket de streaming. Je m'intéresse à l'utilisation de akka streaming io, mais je ne sais pas comment créer un socket de streaming qui fonctionne avec un planificateur regardant périodiquement une file d'attente et envoyant un message à un serveur.comment concevoir un éditeur/abonné tcp tamponné dans scala playframework/akka
Si quelqu'un a un exemple de code qui pourrait illustrer comment cela pourrait être fait dans scala/play framework/akka streaming io ce serait génial.
vous remerciant à l'avance Francis