Eccezione configurazione di Akka: impossibile caricare il logger specificato

Question

Sto provando a caricare il mio client spray http in base a un modello di attore utilizzando lo strumento apache bench. La performance non è eccezionale. Tanto più, quando aumento il livello di concorrenza a circa 200-300, vedo diversi errori relativi ai logger.

frammento di codice

val result = for { 
     response <- GlobalObject.io.ask(HttpRequest(GET,URL)).mapTo[spray.http.HttpResponse] 
    } yield response 
    result Oncomplete{ 
    case Success(response) => doSomething 
    } 

completa dello stack:

[info] [WARN] [03/31/2015 14:31:52.580] [squbs-akka.actor.default-dispatcher-26] [EventStream(akka://hcp-client)] Logger log1-Logging$DefaultLogger did not respond within Timeout(5000 milliseconds) to InitializeLogger(bus) 
[error] error while starting up loggers 
[error] akka.ConfigurationException: Logger specified in config can't be loaded [akka.event.Logging$DefaultLogger] due to [akka.event.Logging$LoggerInitializationException: Logger log1-Logging$DefaultLogger did not respond with LoggerInitialized, sent instead [TIMEOUT]] 
[error]   at akka.event.LoggingBus$$anonfun$4$$anonfun$apply$1.applyOrElse(Logging.scala:116) 
[error]   at akka.event.LoggingBus$$anonfun$4$$anonfun$apply$1.applyOrElse(Logging.scala:115) 
[error]   at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:36) 
[error]   at scala.util.Failure$$anonfun$recover$1.apply(Try.scala:215) 
[error]   at scala.util.Try$.apply(Try.scala:191) 
[error]   at scala.util.Failure.recover(Try.scala:215) 
[error]   at akka.event.LoggingBus$$anonfun$4.apply(Logging.scala:115) 
[error]   at akka.event.LoggingBus$$anonfun$4.apply(Logging.scala:110) 
[error]   at scala.collection.TraversableLike$WithFilter$$anonfun$map$2.apply(TraversableLike.scala:728) 
[error]   at scala.collection.Iterator$class.foreach(Iterator.scala:750) 
[error]   at scala.collection.AbstractIterator.foreach(Iterator.scala:1202) 
[error]   at scala.collection.IterableLike$class.foreach(IterableLike.scala:72) 
[error]   at scala.collection.AbstractIterable.foreach(Iterable.scala:54) 
[error]   at scala.collection.TraversableLike$WithFilter.map(TraversableLike.scala:727) 
[error]   at akka.event.LoggingBus$class.startDefaultLoggers(Logging.scala:110) 
[error]   at akka.event.EventStream.startDefaultLoggers(EventStream.scala:26) 
[error]   at akka.actor.LocalActorRefProvider.init(ActorRefProvider.scala:622) 
[error]   at akka.actor.ActorSystemImpl.liftedTree2$1(ActorSystem.scala:619) 
[error]   at akka.actor.ActorSystemImpl._start$lzycompute(ActorSystem.scala:616) 
[error]   at akka.actor.ActorSystemImpl._start(ActorSystem.scala:616) 
[error]   at akka.actor.ActorSystemImpl.start(ActorSystem.scala:633) 
[error]   at akka.actor.ActorSystem$.apply(ActorSystem.scala:142) 
[error]   at akka.actor.ActorSystem$.apply(ActorSystem.scala:109) 
[error]   at com.paypal.vyasa.persistors.KafkaStorage.<init>(KafkaStorage.scala:40) 
[error]   at sun.reflect.GeneratedConstructorAccessor22.newInstance(Unknown Source) 
[error]   at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) 
[error]   at java.lang.reflect.Constructor.newInstance(Constructor.java:408) 
[error]   at akka.util.Reflect$.instantiate(Reflect.scala:66) 
[error]   at akka.actor.ArgsReflectConstructor.produce(Props.scala:352) 
[error]   at akka.actor.Props.newActor(Props.scala:252) 
[error]   at akka.actor.ActorCell.newActor(ActorCell.scala:552) 
[error]   at akka.actor.ActorCell.create(ActorCell.scala:578) 
[error]   at akka.actor.ActorCell.invokeAll$1(ActorCell.scala:456) 
[error]   at akka.actor.ActorCell.systemInvoke(ActorCell.scala:478) 
[error]   at akka.dispatch.Mailbox.processAllSystemMessages(Mailbox.scala:279) 
[error]   at akka.dispatch.Mailbox.run(Mailbox.scala:220) 
[error]   at akka.dispatch.Mailbox.exec(Mailbox.scala:231) 
[error]   at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) 
[error]   at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) 
[error]   at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) 
[error]   at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) 
[error] Caused by: akka.event.Logging$LoggerInitializationException: Logger log1-Logging$DefaultLogger did not respond with LoggerInitialized, sent instead [TIMEOUT] 
[error]   at akka.event.LoggingBus$class.akka$event$LoggingBus$$addLogger(Logging.scala:185) 
[error]   at akka.event.LoggingBus$$anonfun$4$$anonfun$apply$4.apply(Logging.scala:114) 
[error]   at akka.event.LoggingBus$$anonfun$4$$anonfun$apply$4.apply(Logging.scala:113) 

ho cercato nel web, ma sembra che l'errore è unico nel suo genere. Qualcuno guida qualcuno? Inoltre, qualche vantaggio su come la performance può essere aumentata? Il numero totale di richieste sembra accelerare attorno ai 15 al secondo.

Answer 1

Questo errore è stato già menzionato nel web:

https://groups.google.com/forum/#!topic/akka-user/nng-bb2IZFA

Vuol dire che uno degli attori (log1-registrazione), non ha risposto in tempo. È possibile aumentare il timeout usando logger-startup-timeout impostazione:

# Loggers are created and registered synchronously during ActorSystem 
# start-up, and since they are actors, this timeout is used to bound the 
# waiting time 
logger-startup-timeout = 5s 

Il possibile motivo per cui può capitare è il servizio esecutore (piscina) configurazione:

• forse scelto troppo bassa (o alta) Capacità piscina
• forse stai usando il pool, che può essere influenzato dal problema della fame di thread - qualsiasi pool che non supporta il blocco gestito (compresi i pool fissi e dinamici incorporati regolari). Questo problema può essere risolto utilizzando fork-join-pool (utilizzato per impostazione predefinita in akka)

Answer 2

Ciò è probabilmente dovuto a LOGBACK-1221, che è stato corretto in Logback 1.1.10. Se si utilizza una versione precedente di Logback, la soluzione è semplicemente l'aggiornamento alla versione 1.1.10 o successiva.