Java - 消息传递框架

Question

我想测试一个应该在多个服务器上运行的分布式算法(每个服务器运行相同的代码和逻辑)。端点将通过相互广播消息进行通信。

为了预先测试算法，我考虑开发一个单进程应用程序，其中每个端点都由单个线程模拟。

是否有任何框架提供类似的功能，仅定义线程数、实现消息以及每个线程将执行的代码？

谢谢

Answer 1

您可能会发现 Akka 可以满足您的需要。 Akka使用参与者作为业务逻辑的实现 - 这些参与者对其他参与者产生的事件使用react。

Akka 提供了这个 API 并处理参与者的协调 - 虽然底层必须使用 Thread，但开发人员不必处理它们。

您的问题的最后一个好处是 Akka 可以分布在多台机器上 - 我不认为从单机到多机的这种变化涉及到程序的任何修改。我假设您需要确保您的事件实现Serialized。