Akka'da nasıl kontrol edilir Gelen kutusunda bir mesaj ne kadardı? İleti gelen kutusunda çok uzunsa bir günlük iletisi oluşturmak istiyorum. Şunlar gibi:Akka - bir iletinin gelen kutusunda ne kadar olduğunu nasıl kontrol edersiniz?
override def receive: Receive = {
case Message =>
val timeInInbox = ...
if (timeInInbox > treshold) log.warn("bla bla bla the doom is coming")
Bu bilgileri sağlayabilen metrikleri/telemetri kitaplıkları vardır. biri "posta kutusu zaman" diyor sana "zaman-in-posta kutusuna" verir (açık kaynak), metrik, http://kamon.io/documentation/kamon-akka/0.6.6/actor-router-and-dispatcher-metrics/
diğeri (bkz, özgür olmayan kapalı kaynak) 'dir "Lightbend Telemetry", kamon.io olduğunu (bkz. http://developer.lightbend.com/docs/monitoring/latest/instrumentations/akka/akka.html#actor-metrics
Akka için şu anda yerleşik hiçbir şey yok.
Her iletinin varış saatini enqueue tarihinde kaydedip, oturum süresini dequeue oturumunda kaydeden özel bir posta kutusu uygulaması oluşturabilirsiniz. Akka belgelerinde "Creating your own Mailbox type" konusuna bakın.
getCurrentTimeMillis veya benzeri aramaların ucuz olmadığından emin olun, böylece böyle bir posta kutusunun önemli bir performans maliyetine sahip olduğunu görebilirsiniz. Bu yüzden Akka'nın bunu kutudan çıkarmamasını bekliyorum.
, iletilerinizi açık bir şekilde zaman damgası haline getirebilir, örneğin: 'case class İleti (ts: Uzun)' – kosii
Oturum açma yerine, çok uzun bir işlem yapıyoruz. gelen kutusunda kalmak. Kosii'nin bir zaman damgasıyla oyuncularımıza giden tüm mesajlarımızı önerip damgaladığını ve mesajların oluşturulduğu zamandan bu yana ne kadar zaman geçtiğini görmek için 'dequeue' işlevini geçersiz kılan özel bir posta kutusuna sahip olduğumuzu yapıyoruz. posta kutusundan dequeued edildi. – cmbaxter
Özel bir posta kutusu oluşturduğumda, özgün mesajı tuple '(msg, timestamp) içine koyan ve kayıtla birlikte 'dequeue' geçersiz kılan" enqueue "ile büyük bir yük oluşturur mu? – mpr