我用 Akka-IO 编写了一个简单的套接字客户端,它使用来自套接字服务器的字符串(它发送由 \n 分隔的字符串):
class SocketClient(endpoint: InetSocketAddress) extends Actor {
override def preStart() {
IOManager(context.system).connect(endpoint)
}
def receive = {
case IO.Read(socket, bytes) => ??? ! bytes.utf8String
}
}
我需要将使用服务器发送事件接收到的字符串广播给所有请求它的客户端。如何定义一个枚举器,其中包含演员收到的所有消息,以作为来自 Play 控制器的流?