我想解决两个场景:
您需要开发自己的协议来确认消息,并且已经过处理,并重试那些尚未处理的消息。看到:
https://doc.akka.io/docs/akka/current/general/message-delivery-reliability.html
总是可以在基本的基础上增加更强的可靠性,但是为了获得更高的性能,不可能主动地去除可靠性。