如何让akka事件源(akka-persistence)使用并行日志参与者

Question

我正在测试事件源()，并编写了自己的日志插件。但是在运行性能测试时，我很快注意到并不是所有的CPU资源都被使用。将消息写入日志的类是一个参与者(例如，is以串行方式执行所有写操作)。

是否可以使用此日志参与者的多个实例来提高日志后端的写入性能？如果是，怎么做？

谢谢

Answer 1

正如我在akka-用户邮件列表上暗示的那样，现在不可能有多个“华尔街日报”演员。不过，您可以做的是实现AsyncWritePlugin API，该API将允许参与者以非阻塞的方式执行写操作，然后可以扩展插件中的写操作。