数据库 – Akka演员：处理数据库失败而不丢失数据

首选行为
重要的数据在将来某个时候重新启动时会写入数据库.

当前实施
演员捕获DBException,将数据包裹在DBWriteFailed案例类中,并将消息发送到其主管.然后,主管将使用system.scheduler.scheduleOnce(…)在将来的某个时间安排另一个写入(例如1分钟),以便我们在等待数据库恢复时不要旋转太多.

这个实施肯定有效,但我觉得可能会有更好的方法.

>提交演员必须在成功提交后对原始发件人做出响应,协议会变得更加复杂.
>对提交actor的消息的定期流程不会以任何方式进行限制,并且actor将乐意处理新的消息,可能无法连接到每个其中的DB.
>如果邮件在此重试循环中被捕获了很长时间,则提交演员的邮箱将开始气球.重要的是要提交这些数据,但是如果应用程序由于内存过多使用而爬行停止或崩溃,那么这一点很重要.

我是一个akka的新手,而在主管策略方面我基本上没有经验,但我觉得我可以利用其中的一个来处理这些重试逻辑.

在akka中有一个常见的方法来解决这样的问题？我在正确的轨道上还是应该朝着不同的方向前进？

任何帮助是赞赏.

解决方法

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!