例如:我有演员X和Y。 角色X将消息保留到日记中,然后将消息发送给Y。Y收到消息,然后将确认发送回X,以使其知道已收到消息。当X收到此确认时,我希望它a)从日志中删除邮件,以便在恢复时不重播该邮件。 (这部分似乎不可行)。b)在邮件上标记“已完成”(已发送)。我认为这部分将通过日志(使用登录恢复)或通过在日志中添加“标签”(通过事件适配器)来完成,但是我不确定如果可行的话是否会进行更新。 这使我意识到,akka持久性实际上是如何工作的。如果一个参与者保留了所有消息,然后该参与者失败了并且需要恢复,那么无论传递什么,…

2020年10月30日 0条评论 45点热度 阅读全文

例如:我有演员X和Y。 角色X将消息保留到日记中,然后将消息发送给Y。Y收到消息,然后将确认发送回X,以使其知道已收到消息。当X收到此确认时,我希望它a)从日志中删除邮件,以便在恢复时不重播该邮件。 (这部分似乎不可行)。b)在邮件上标记“已完成”(已发送)。我认为这部分将通过日志(使用登录恢复)或通过在日志中添加“标签”(通过事件适配器)来完成,但是我不确定如果可行的话是否会进行更新。 这使我意识到,akka持久性实际上是如何工作的。如果一个参与者保留了所有消息,然后该参与者失败了并且需要恢复,那么无论传递什么,…

2020年1月31日 0条评论 23点热度 阅读全文

以下来自文档(akka): 交货保证 流裁判将正常的演员消息传递用于他们的体育比赛,因此提供了相同水平的基本交付保证。流引用确实通过需求重新传递和顺序故障检测在某种程度上扩展了语义。换一种说法: messages are sent over actor remoting which relies on TCP (classic remoting or Artery TCP) or Aeron UDP for basic redelivery mechanisms messages are guaranteed to…

2019年6月25日 0条评论 19点热度 阅读全文

以下来自文档(akka): 交货保证 流裁判将正常的演员消息传递用于他们的体育比赛,因此提供了相同水平的基本交付保证。流引用确实通过需求重新传递和顺序故障检测在某种程度上扩展了语义。换一种说法: messages are sent over actor remoting which relies on TCP (classic remoting or Artery TCP) or Aeron UDP for basic redelivery mechanisms messages are guaranteed to…

2019年6月17日 0条评论 26点热度 阅读全文

使用Akka持久性,我得到以下异常: 引起原因:akka.persistence.typed.internal.JournalFailureException: 恢复期间发生异常。最后已知序列号[0]。 PersistenceId [PersistenceExample],由于:无法构造实例 的com.exercisePersistence.simpleExample.MyPersistentBehavior$Added (尽管至少存在一个创建者):无法从Object反序列化 值(没有基于委托人或基于属性的创建者)…

2019年1月9日 0条评论 35点热度 阅读全文