【发布时间】：2016-05-06 20:04:11
【问题描述】：
我们正在从基于 python 的环境迁移到 scala play 框架，我必须编写一个缓冲的发布者订阅者，它将与另一个用 python 编写的系统交互。这里的目标是编写一个发布者，它将从缓冲区/队列中获取消息并通过 tcp 套接字将它们发送到服务器并保持套接字打开，以便我们以后可以重用它。
我们的旧 python 发布者创建了一个永远不会关闭的 socket.socket(socket.AF_INET, socket.SOCK_STREAM) 套接字，并与调度程序一起将消息从队列中取出并通过流式套接字发送。
我对使用 akka 流式 io 很感兴趣，但我不知道如何创建一个流式套接字，它与定期查看队列并向服务器发送消息的调度程序一起工作。
如果有人有代码示例可以说明如何在 scala/play 框架/akka 流 io 中完成此操作，那就太棒了。
提前致谢 弗朗西斯
【问题讨论】：
标签： scala sockets tcp playframework akka