这是我的愚蠢 - 我没有将索引器道具传递给系统创建。 我会在这里留下答案,以防任何人获得一些好处*
我正在创建一个单例并发送如下消息:
val indexerProps = ClusterSingletonManager.props(had => Props( classOf[SingleCoreIndexer], dataProvider, publisher, name), name, End, None) val coreIndexer = system.actorOf(indexerProps, name) //val coreIndexer = system.actorOf(Props(classOf[SingleCoreIndexer], dataProvider, publisher, name)) coreIndexer ! "start_indexing"注释掉的行显示了非单身道具,它们可以正常工作
当我运行应用程序时,我收到以下错误:
[WARN] [06/21/2013 11:55:32.443] [deadcoreindexerstest-akka.actor.default-dispatcher-5] [akka://deadcoreindexerstest/user/node1] unhandled event start_indexing in state Start所有其他功能都停止工作,这与暗示“coreIndexer”actor未获得“start_indexing”消息的消息相关
更多代码:
class Indexer(systemCreator: SystemCreator, publisherProps: Props, dataProviderProps: Props, name: String) { def start { val system = systemCreator.create val dataProvider = system.actorOf(dataProviderProps) val publisher = system.actorOf(publisherProps) val indexerProps = ClusterSingletonManager.props( singletonProps = had => Props(classOf[SingleCoreIndexer], dataProvider, publisher, name), singletonName = "aaa", terminationMessage = End, role = None ) val coreIndexer = system.actorOf(Props(classOf[SingleCoreIndexer], dataProvider, publisher, name)) coreIndexer ! "start_indexing" } } class SingleCoreIndexer(dataProvider: ActorRef, publisher: ActorRef, name: String) extends Actor { def receive = { case "start_indexing" => { println("Single core indexer starting indexing") dataProvider ! new NextBatchOfDataPlease } case BatchOfData(data) => { publisher ! (name, data) self ! "next_batch" } case "next_batch" => { dataProvider ! new NextBatchOfDataPlease } } }看起来我正在向经理发送消息而不是单身人士。 但是,当我向单例发送消息时,没有任何反应:
class Indexer(systemCreator: SystemCreator, publisherProps: Props, dataProviderProps: Props, name: String) { def start { val system = systemCreator.create val dataProvider = system.actorOf(dataProviderProps) val publisher = system.actorOf(publisherProps) val indexerProps = ClusterSingletonManager.props( singletonProps = had => Props(classOf[SingleCoreIndexer], dataProvider, publisher, name), singletonName = "singlecoreindexer", terminationMessage = End, role = None ) system.actorOf(Props(classOf[SingleCoreIndexer], dataProvider, publisher, name)) val coreIndexer = system.actorSelection(s"/user/$name/singlecoreindexer") coreIndexer ! "start_indexing" } }It was me being stupid - I wasn't passing the indexer props into system creation. I'll leave the answer here in case anyone takes some benefit *
I'm creating a singleton and sending a message like this:
val indexerProps = ClusterSingletonManager.props(had => Props( classOf[SingleCoreIndexer], dataProvider, publisher, name), name, End, None) val coreIndexer = system.actorOf(indexerProps, name) //val coreIndexer = system.actorOf(Props(classOf[SingleCoreIndexer], dataProvider, publisher, name)) coreIndexer ! "start_indexing"The commented out line shows the non-singleton props that work fine
When I run the app I get the following errors:
[WARN] [06/21/2013 11:55:32.443] [deadcoreindexerstest-akka.actor.default-dispatcher-5] [akka://deadcoreindexerstest/user/node1] unhandled event start_indexing in state StartAll of the other functionality stops working, which correlates with the message implying the "coreIndexer" actor is not getting the "start_indexing" message
More code:
class Indexer(systemCreator: SystemCreator, publisherProps: Props, dataProviderProps: Props, name: String) { def start { val system = systemCreator.create val dataProvider = system.actorOf(dataProviderProps) val publisher = system.actorOf(publisherProps) val indexerProps = ClusterSingletonManager.props( singletonProps = had => Props(classOf[SingleCoreIndexer], dataProvider, publisher, name), singletonName = "aaa", terminationMessage = End, role = None ) val coreIndexer = system.actorOf(Props(classOf[SingleCoreIndexer], dataProvider, publisher, name)) coreIndexer ! "start_indexing" } } class SingleCoreIndexer(dataProvider: ActorRef, publisher: ActorRef, name: String) extends Actor { def receive = { case "start_indexing" => { println("Single core indexer starting indexing") dataProvider ! new NextBatchOfDataPlease } case BatchOfData(data) => { publisher ! (name, data) self ! "next_batch" } case "next_batch" => { dataProvider ! new NextBatchOfDataPlease } } }It looks like I was sending a message to the manager and not the singleton. However, when I send messages to the singleton, nothing happens:
class Indexer(systemCreator: SystemCreator, publisherProps: Props, dataProviderProps: Props, name: String) { def start { val system = systemCreator.create val dataProvider = system.actorOf(dataProviderProps) val publisher = system.actorOf(publisherProps) val indexerProps = ClusterSingletonManager.props( singletonProps = had => Props(classOf[SingleCoreIndexer], dataProvider, publisher, name), singletonName = "singlecoreindexer", terminationMessage = End, role = None ) system.actorOf(Props(classOf[SingleCoreIndexer], dataProvider, publisher, name)) val coreIndexer = system.actorSelection(s"/user/$name/singlecoreindexer") coreIndexer ! "start_indexing" } }最满意答案
您看到的问题(我认为)源于您向ClusterSingletonManager发送消息而不是发送给位于其下方的实际actor。 尝试通过名称( actorFor )查找下面的actor,它应该可以工作。
The issue you are seeing (I think) stems from you sending a message to the ClusterSingletonManager instead of to your actual actor that is sitting underneath it. Try looking up the actor underneath if by name (actorFor) and it should work.
更多推荐
发布评论