我们正在从基于python的环境转移到scala-play框架一，我必须编写一个缓冲的发布服务器订阅服务器，它将与另一个用python编写的系统接口。这里的目标是编写一个发布器，它将从缓冲区/队列中获取消息，并通过tcp套接字将它们发送到服务器，并保持套接字打开，以便我们以后可以重用它。
我们的旧python发布者创建了一个永远不会关闭的socket.socket（socket.AF_INET，socket.SOCK_STREAM）套接字，并与调度程序一起将消息从队列中取出，并通过流套接字发送。
我对使用akka流式传输io很感兴趣，但我不知道如何创建一个流式传输套接字，该套接字与定期查看队列并向服务器发送消息的调度器一起工作。
如果有人有一个代码示例可以说明如何在scala/playframework/akka-streaming-io中实现这一点，那将是非常棒的。
提前感谢您Francis
听起来你想要Akka TCP:
http://doc.akka.io/docs/akka/current/scala/io-tcp.html