TheAkkaWay
TheAkkaWay copied to clipboard
persistent actor
请教个问题,使用persistent Actor,如果接收方处理消息的逻辑非常耗时,在接收方还未处理完该消息的时候,此时发送方,又重发一个相同的消息过来,这个咋怎么过滤掉呀。
@scalaoop 这个就不属于persistent actor的范畴了,exactly-once需要自己来实现的。或者你只是为了过滤相同消息,可以在接收方前面再单独做一个actor,由这个actor判断。使用akka一定要用好actor的层级关系。