我正在使用最新版本的Akka,当时我注意到现在从Akka中移除了持久邮箱.
我需要确保在崩溃后重新启动时恢复我的消息.是否有其他方法可以在没有持久邮箱的情况下工作或由其他人自定义实现.
我也尝试了Akka Persistence,但它重放了消息,我不想在发生崩溃的情况下两次发送相同的消息,因为所有消息的执行都很昂贵.
虽然这并不完全是与 Akka Actors 一起使用的解决方案,但它确实解决了这里所讨论的原始问题。
我认为,与其在这里使用 Akka,不如使用 Kafka 之类的东西以及带有akka/reactive-kafka
.
这样的系统对于持久性非常好,并且提供了非常好的语义来在崩溃时保留消息队列。这比将消息存储在要处理的地方要好得多,并且通常性能更好。
它不一定是 Kafka,而是任何可以插入反应流的后端(Akka 的实现或其他)。
归档时间: |
|
查看次数: |
774 次 |
最近记录: |