akka
在我与Akka的日常工作中，我最近写了一个字数映射减少示例。 本示例实现了Map Reduce模型，该模型非常适合横向扩展设计方法。 
流
- 客户端系统（FileReadActor）读取文本文件，并将每一行文本作为消息发送给ClientActor。
- ClientActor具有对RemoteActor的引用（WCMapReduceActor），并且消息传递到远程Actor
- 服务器（WCMapReduceActor）获取消息。 Actor使用PriorityMailBox来确定消息的优先级并相应地过滤队列。 在这种情况下，PriorityMailBox用于在mapreduce请求之间隔离消息，并从聚合角色获取结果列表（DISPLAY_LIST）消息。
- WCMapReduceActor将消息发送到MapActor（使用RoundRobinRouter调度程序）以映射单词
- 映射单词后，将消息发送到ReduceActor（使用RoundRobinRouter调度程序）以减少单词
- 精简后的结果将发送到Aggregate Actor，后者对结果进行内存内聚合
下图详细说明了程序的结构
该程序的代码库位于以下位置-https://github.com/write2munish/Akka-Essentials 。
有关MapReduce的更多信息，请阅读MapReduce for dummies 。
参考： Akka Essentials博客上来自JCG合作伙伴 Munish K Gupta的Akka 单词计数MapReduce 。
翻译自: https://www.javacodegeeks.com/2012/04/word-count-mapreduce-with-akka.html
akka
)
)
