Wir sind dabei, von einer Python-basierten Umgebung zu scala play framework one zu wechseln und einen gepufferten Publisher-Subscriber zu schreiben, der mit einem anderen System interagiert geschrieben in Python. Das Ziel ist es, einen Herausgeber zu schreiben, der Nachrichten aus einem Puffer/einer Warteschlange entgegennimmt und sie über einen tcp-Socket an einen Server sendet und den Socket geöffnet hält, damit wir ihn später wiederverwenden können.Wie man einen gepufferten tcp Publisher/Subscriber in scala erstellt playframework/akka
Unser alter Python-Verleger hat einen socket.socket-Socket (socket.AF_INET, socket.SOCK_STREAM) erstellt, der niemals geschlossen werden konnte. Er arbeitete mit einem Scheduler, um Nachrichten aus der Warteschlange zu entfernen und über den Streaming-Socket zu senden.
Ich habe Interesse an der Verwendung von akka streaming io, aber ich weiß nicht, wie man einen Streaming-Socket erstellt, der mit einem Scheduler regelmäßig in eine Warteschlange schaut und eine Nachricht an einen Server sendet.
Wenn jemand ein Codebeispiel hat, das veranschaulichen könnte, wie das in scala/play framework/akka streaming io gemacht werden könnte, wäre das großartig.
Sie im Voraus Francis