如何跟踪Akka消息传递

Question

我正在使用具有主 - 工作者模式的Akka集群将作业分发给工作节点。 Kafka和JMS消息传递API可以浏览队列或主题中的消息。我可以知道在所有发送者和接收者之间跟踪Akka系统中的消息的最佳做法是什么，以便我可以有效解决问题吗？是否有基于Akka的框架来实现它？

Answer 1

您可以启用的演员级别的日志记录了所有收到的消息和演员的生命周期状态的变化：

akka { 
    loglevel = "DEBUG" 
    stdout-loglevel = "DEBUG" 
    loggers = ["akka.event.Logging$DefaultLogger"] 

    // log-config-on-start = on 
    log-dead-letters = 10 
    log-dead-letters-during-shutdown = on 

    actor { 
    debug { 
     receive = on 
     autoreceive = on 
     lifecycle = on 
     unhandled = on 
    } 
    } 
} 

对于它的工作，所有的演员需要在演员需要延长ActorLogging特质，也receive（）方法稍微调整一下：

def receive: Receive = LoggingReceive { 
    // message handlers go here 
}