Akka和java.nio。非阻塞选择器

我正在尝试编写侦听tcp连接的服务器。我正在使用nonblockig java.nio。当演员收到“STARTLISTEN”消息Akka和java.nio。非阻塞选择器

我selector.select（）开始，这是确定的，但选择之前没有收到任何数据时，我发信息给演员就无法接收消息。

如何避免这种情况？例如，我想发送消息“停止”给我的演员停止选择？只有通过timeout或selectNow（）才能调用select？

我不打算使用akka.io.

这不是完整的代码，但它说明了这个问题：

class MyActor(val host: String, port: Int) extends Actor { 

    val serverChannel = ServerSocketChannel.open()  
    val channelSelector = Selector.open() 

    serverChannel.configureBlocking(false);  
    serverChannel.bind(new InetSocketAddress(InetAddress.getByName(host), port)) 

    serverChannel.register(channelSelector, SelectionKey.OP_ACCEPT);     

    override def receive = { 
     case "STARTLISTEN" => { 
     val keys = channelSelector.select()   
     // processing read write etc.... 
     } 
     case "STOP" => { 
     // I want to stop selection here.... 
     } 
    } 
}

来源

2014-02-10 Antek

非常不清楚，你应该共享您的代码的相关片段。 – vptheron

我添加的代码 – Antek

您可能能够通过分裂的演员成多个演员来完成这一任务。第一位演员接收来自外部的消息，第二位接收select()。在发送任何消息之前，第一个演员可以使用wakeup()阻止第二个阻止。

来源

2014-02-10 18:12:30

你的意思是这样的：案 “STARTLISTEN”=> { blockingRef = context.actorFor（PropsclassOf [MyBlockingActor]，channelSelector） }情况下， “STOP”=> { blockingRef.wakeup（） } – Antek

尽管你忽略了它，但我想指出（在记录中），使用这个ships with Akka already的验证实现可能是更好的方法。（我链接到2.3.0-RC2文档，因为一些这是在2.2.x的系列将不会是阿卡部分介绍了实验性功能会优胜劣汰向前生存。）

来源

2014-02-11 10:48:25

Akka和java.nio。非阻塞选择器

回答

相关问题