Нормально ли для потоков Akka запускать и останавливать ActorGraphInterpreter каждую секунду? - PullRequest
0 голосов
/ 21 декабря 2018

В настоящее время я отлаживаю устаревшее приложение на основе Akka и начал с перехода с Play's Logger на использование правильного Akka logger, учитывая, что система использует в основном akka Actors.

Но после включенияПри регистрации в Akka и установке этого параметра на DEBUG, я вижу множество ненужных запусков / остановок экземпляров ActorGraphInterpreter каждую секунду, полностью заполняющих журналы:

2018-12-20 14:09:43,872 [debug] a.s.i.StreamSupervisor - now supervising Actor[akka://application/system/StreamSupervisor-10/flow-621-0-seqSink#1394488285] 2018-12-20 14:09:43,872 [debug] a.s.i.f.ActorGraphInterpreter - started (akka.stream.impl.fusing.ActorGraphInterpreter@4a57dba5) 2018-12-20 14:09:43,874 [debug] a.s.i.f.ActorGraphInterpreter - stopped 2018-12-20 14:09:44,642 [debug] a.s.i.StreamSupervisor - now supervising Actor[akka://application/system/StreamSupervisor-10/flow-622-0-seqSink#900632321] 2018-12-20 14:09:44,642 [debug] a.s.i.f.ActorGraphInterpreter - started (akka.stream.impl.fusing.ActorGraphInterpreter@3cf268af) 2018-12-20 14:09:44,644 [debug] a.s.i.f.ActorGraphInterpreter - stopped 2018-12-20 14:09:44,644 [debug] a.a.TimerScheduler - Start timer [QueryOrderingIdsTimerKey] with generation [299] 2018-12-20 14:09:44,893 [debug] a.s.i.StreamSupervisor - now supervising Actor[akka://application/system/StreamSupervisor-10/flow-623-0-seqSink#-862636181] 2018-12-20 14:09:44,893 [debug] a.s.i.f.ActorGraphInterpreter - started (akka.stream.impl.fusing.ActorGraphInterpreter@2c83fe5a) 2018-12-20 14:09:44,895 [debug] a.s.i.f.ActorGraphInterpreter - stopped 2018-12-20 14:09:45,663 [debug] a.s.i.StreamSupervisor - now supervising Actor[akka://application/system/StreamSupervisor-10/flow-624-0-seqSink#-1452327997] 2018-12-20 14:09:45,663 [debug] a.s.i.f.ActorGraphInterpreter - started (akka.stream.impl.fusing.ActorGraphInterpreter@4c67665a) 2018-12-20 14:09:45,665 [debug] a.s.i.f.ActorGraphInterpreter - stopped 2018-12-20 14:09:45,665 [debug] a.a.TimerScheduler - Start timer [QueryOrderingIdsTimerKey] with generation [300] 2018-12-20 14:09:45,912 [debug] a.s.i.StreamSupervisor - now supervising Actor[akka://application/system/StreamSupervisor-10/flow-625-0-seqSink#-1284226793] 2018-12-20 14:09:45,912 [debug] a.s.i.f.ActorGraphInterpreter - started (akka.stream.impl.fusing.ActorGraphInterpreter@59802f1d) 2018-12-20 14:09:45,914 [debug] a.s.i.f.ActorGraphInterpreter - stopped

Я довольно новичок в Scala в целом, и особенно новичок в потоках Akka и Akka, поэтому я прошу прощения, если это , как это работает , и я задаю ненужный вопрос.

Приложение в первую очередь основано на потоковой обработке Akka с помощью нескольких основных актеров, поэтому я не удивлен, увидев потоковые журналы, именно частота вызывает у меня паузу.

Это нормальное поведение?Или это указывает на основную проблему с унаследованным приложением?

Спасибо за помощь!

...