网站当电话线,做php网站教程视频教程,郑州市建设网站,制作网站商城这里的事件#xff0c;那里的事件#xff0c;到处都是事件。 发布有关检查每一项Akka事件最终都能找到归宿的信息。 Akka和基于事件的反应式应用程序是创建软件的新方法。 在当前基于Scala的项目中#xff0c;我们非常密集地使用Akka。 事件非常适合我们的用例#xff0c;… 这里的事件那里的事件到处都是事件。 发布有关检查每一项Akka事件最终都能找到归宿的信息。 Akka和基于事件的反应式应用程序是创建软件的新方法。 在当前基于Scala的项目中我们非常密集地使用Akka。 事件非常适合我们的用例因为我们正在与外部API通信这可能很慢。 使用传统的同步方法处理时这可能会损害用户体验。 但是幸运的是我们的请求可以异步执行因此将它们传递给Actor似乎是一个好主意。 当事情得到控制时 但是事件虽然很酷并且非常有用但是如果没有经验的人来处理事件仍然会伤害项目。 异步性质使应用程序流程乍一看很难理解。 而且每当您向系统中添加新的参与者或事件类型时您忘记正确处理某件事的可能性就会增加。 让我们看一下示例类这是一个处理与Image标签和注释关联的事件的actor class YourActor extends Actor {override def receive {case event: ImageTagged doSomething()case event: OtherImageTaggedByFriend doSomething2()case event: MostMotedUserImage doSomething3()case event: MostCommentedFriendImageChosen doSomething4()}
} 当您添加下一个事件时例如说MostLikedFriendImage您可以轻松地忘记在actor中添加处理程序案例部分尤其是当有多个actor监听此类事件时。 干违规溶液 有一种简单的解决方案可以检测遗忘的处理程序。 我们可以将case _添加到每个actor class YourActor extends Actor {override def receive {case event: ImageTagged doSomething()case event: OtherImageTaggedByFriend doSomething2()case event: MostMotedUserImage doSomething3()case event: MostCommentedFriendImageChosen doSomething4()case event: _ :logger.error(Received unknown event event.getClass.toString)}
} 虽然对于一个或两个参与者来说看起来还可以但将相同的代码片段添加到多个参与者中却很麻烦并且违反了DRY原则。 但是最危险的是您团队中的某个人可能会忘记添加它就像有人说的那样 “每个可以被遗忘的手动任务都会被遗忘” 。 那么也许我们应该寻求更好的解决方案 对任何未处理的事件做出反应 幸运的是我们不会停留在容易出错的方法上。 当actor无法处理传递给他的事件时将引发UnhandledMessage并将其发布到ActorSystem的EventStream。 因此要处理每个被遗忘的事件我们可以创建侦听器并将其订阅到EventStream class UnhandledMessageListener extends Actor {val logger LoggerFactory.getLogger(getClass)override def receive {case message: UnhandledMessage logger.error(sCRITICAL! No actors found for message ${message.getMessage}))if (!Environment.isProduction) {// Fail fast, fail LOUDlogger.error(Shutting application down)System.exit(-1)}}
} 并订阅代码片段 val actorSystem ActorSystem.create(projectActorSystem)val listener actorSystem.actorOf(Props(new UnhandledMessageListener()))actorSystem.eventStream.subscribe(listener, classOf[UnhandledMessage]) 就是这样。 现在每当有一个参与者没有处理的事件时我们都会知道这一点尤其是在非生产环境中部署应用程序时 翻译自: https://www.javacodegeeks.com/2014/06/handle-every-event-in-your-akka-application.html
