4

我是演员模特界的新手,我爱上了这个想法。但是是否存在一些模式来处理一批消息,以安全的方式进行批量存储?

恐怕如果我阅读了预期 500 条的 400 条消息并将它们放在一个列表中,如果系统关闭,我不想从(持久)邮箱中丢失这 400 条消息。在服务总线世界中,您可以请求一批消息,并且只有在处理后,才提交所有消息。谢谢你。

4

2 回答 2

2

您可能希望将您的参与者系统与一些服务总线/可靠队列(如 RabbitMQ 或 Azure 服务总线)结合起来,仅将参与者系统用于消息处理。

在 Akka.NET 内部,您拥有持久性扩展,可用于将参与者状态存储在您选择的持久性后端中。它还包含一种专用的actor,AtLeastOnceDeliveryActor可用于重新发送消息,直到它们被确认。

于 2015-09-15T06:29:36.560 回答
0

你可以在你的 ESB 中扩展拆分和聚合来做到这一点,我很久以前就用 mule ESB 做了类似的事情。

于 2018-08-02T10:04:55.330 回答