1

我正在附加 conf 文件中编写调度程序的设置，然后将其加载到 application.conf 中，但是当我给出调度程序位于我的文件中的完整路径时调度程序不起作用我还确保调度程序是否存在使用 if 语句

val config = ConfigFactory.load()

      // an actor needs an ActorSystem
      val system = ActorSystem("TestActorSystem",config)
      if(system.dispatchers.hasDispatcher("akka.actor.directUserWriteMongoActor-dispatcher"))
      {println("directUserWriteMongoActor-dispatcher exists")}
      else
      {
        println("dispatcher does not exists")
      }

当我运行directUserWriteMongoActor-dispatcher 存在打印在控制台上但是当我尝试通过代码附加它时

 val DirectUserWriteMongoActor = system.actorOf(Props[DirectUserWriteMongoActor].withDispatcher("akka.actor.directUserWriteMongoActor-dispatcher"), name = "directwritemongoactorr")
      DirectUserWriteMongoActor ! DirectUserWriteToMongo(directUser)

日志表明它正在使用 default-dispatcher 而不是我自己的名为 directUserWriteMongoActor-dispatcher 的调度程序这是我的完整代码

应用程序.conf

include "DirectUserWriteMongoActor" 

akka {
   loggers = ["akka.event.slf4j.Slf4jLogger"]
   loglevel = "DEBUG"

}

DirectUserWriteMongoActor.conf

akka {
   loggers = ["akka.event.slf4j.Slf4jLogger"]
   loglevel = "DEBUG"

  actor{
     loggers = ["akka.event.slf4j.Slf4jLogger"]
   loglevel = "DEBUG"
    ############################### Setting for a Dispatcher #####################################              
    directUserWriteMongoActor-dispatcher {
         type = Dispatcher
    executor = "fork-join-executor"
  fork-join-executor {
    parallelism-min = 2
    parallelism-factor = 2.0
    parallelism-max = 10
  }
  throughput = 10         
                  } #end default-dispatcher 

   }  #end Actor
}  #end Akka

这是我的代码

object TestActor extends App{
 val config = ConfigFactory.load()
 val system = ActorSystem("TestActorSystem",config)

      if(system.dispatchers.hasDispatcher("akka.actor.directUserWriteMongoActor-dispatcher"))
      {println("directUserWriteMongoActor-dispatcher exists")}
      else
      {
        println("directUserWriteMongoActor-dispatcher does not exists")
      }

      val DirectUserWriteMongoActor = system.actorOf(Props[DirectUserWriteMongoActor].withDispatcher("akka.actor.directUserWriteMongoActor-dispatcher"), name = "directwritemongoactorr")
      DirectUserWriteMongoActor ! DirectUserWriteToMongo(directUser)

DirectUserWriteMongoActor.scala

    case class DirectUserWriteToMongo (directuser:DirectUser) 

     class DirectUserWriteMongoActor extends Actor{

      val log = Logging(context.system, this)
     def receive = {
      case DirectUserWriteToMongo(directuser) =>
          log.debug("writing to mogo")

           log.info("message received DirectUserWriteInMongo")
           val directUserStore= new directUserStore
           log.info("going to call store in mongo")
}}

这是控制台上打印的输出

2015-04-27 10:40:01.392 INFO  Slf4jLogger [TestActorSystem-akka.actor.default-dispatcher-2]  -Slf4jLogger started
directUserWriteMongoActor-dispatcher exists
2015-04-27 10:40:02.262 INFO  DirectUserWriteMongoActor [TestActorSystem-akka.actor.default-dispatcher-3] akka://TestActorSystem/user/directwritemongoactorr -message received DirectUserWriteInMongo
2015-04-27 10:40:02.263 INFO  DirectUserWriteMongoActor [TestActorSystem-akka.actor.default-dispatcher-3] akka://TestActorSystem/user/directwritemongoactorr -going to call store in mongo

请帮助我在我的代码或我的 conf 设置中有什么问题调度程序在那里但它不起作用为什么操作系统所以应该打印

TestActorSystem-akka.actor.directUserWriteMongoActor-dispatcher-3

而不是这个

TestActorSystem-akka.actor.default-dispatcher-3

请帮助我，我也是第一次使用akka调度和其他conf文件

4

1 回答 1

3

您可能正在使用 SimpleLogger。此记录器使用默认调度程序进行记录。

你的代码没有问题。包括这个：println(context.dispatcher)给你的actor接收方法会通知你，他正在使用正确的directUserWriteMongoActor调度器。

另一方面，如果你添加println(system.dispatcher)到你的 App 对象，你会发现，在actor外部使用了默认的调度器。这是正确的，因为您只指定了参与者的调度程序，而不是全局使用的调度程序。

于 2015-04-27T08:57:57.257 回答