1
私たちは、Pythonベースの環境からスカラプレイフレームワークに移行する過程にあり、別のシステムとインタフェースするバッファ付きパブリッシャサブスクライバを作成する必要がありますPythonで書かれています。ここでの目標は、バッファ/キューからメッセージを受け取り、それらをtcpソケットを介してサーバーに送信し、ソケットを開いたままにして後で再利用できるようにするパブリッシャを作成することです。scalaでバッファされたtcpパブリッシャ/サブスクライバを設計する方法/ akka
私たちの古いpythonパブリッシャーは、決して閉じることのないsocket.socket（socket.AF_INET、socket.SOCK_STREAM）ソケットを作成し、スケジューラーと協力してメッセージをキューから取り出し、ストリーミングソケットを介して送信しました。
私はakka streaming ioの使用に興味がありますが、定期的にキューを見てサーバにメッセージを送信するスケジューラと連携するストリーミングソケットを作成する方法はわかりません。
誰かが、これがどのようにスケーラ/プレイフレームワーク/ akkaストリーミングioでできるかを示すことができるコードサンプルを持っていれば素晴らしいでしょう。
http://doc.akka.io/docs/akka/current/scala/io-tcp.html
：あなたがアッカTCPをしたいようですね