Akka-Essentials

Akka 实例 (详细信息请参阅 http://akka-essentials.blogspot.com/) 你会在 Java 和 Scala 中找到 Akka 的示例,其中介绍了一个概念以及解决的问题。

WordCountMapReduce: 此示例实现了单词计数 Map Reduce 模型。客户端系统读取文本文件，并将每行文本作为消息发送给服务器。服务器读取行，映射单词，减少单词，最后在内存中聚合结果。示例还实现了优先邮箱，用于将 Map Reduce 请求与消息请求分离，并从聚合行为中获取结果列表。

GridPatternExample: 网格计算模式是控制节点将工作分配给其他节点的模式。其思想是利用网络中的节点来利用其计算能力。它类似于主从模式，但存在一定的差异。主从模式背后的思想是将工作分割成相同的子任务，然后委托给从节点。示例演示了 WorkerActor 系统如何发送注册请求。RegisterRemoteWorker 接收请求，并将其转发给 JobController，JobController 更新了 RoundRobinRouter 以记录新的工作节点信息。WorkScheduler 定期向 JobController 发送请求，JobController 然后将数据包发送给所有已注册的工作节点。

AkkaSerializableExample: Akka 默认支持 2 种序列化选项 - java 和 protobuf。此外，Akka 提供了一个 API，可让您自行编写序列化类。在本示例中，我使用了 Google Gson 库，将您的值对象转换为 JSON 字符串表示，然后进行序列化。