在我與Akka的日常工作中，我最近寫了一個(gè)字?jǐn)?shù)映射表簡化示例。 本示例實(shí)現(xiàn)了Map Reduce模型，該模型非常適合橫向擴(kuò)展設(shè)計(jì)方法。

流

客戶端系統(tǒng)（FileReadActor）讀取文本文件，并將每一行文本作為消息發(fā)送給ClientActor。

ClientActor具有對RemoteActor的引用（WCMapReduceActor），并且消息傳遞到遠(yuǎn)程Actor

服務(wù)器（WCMapReduceActor）獲取消息。 Actor使用PriorityMailBox來確定消息的優(yōu)先級并相應(yīng)地過濾隊(duì)列。 在這種情況下，PriorityMailBox用于在mapreduce請求之間隔離消息，并從聚合角色獲取結(jié)果列表（DISPLAY_LIST）消息。

WCMapReduceActor將消息發(fā)送到MapActor（使用RoundRobinRouter調(diào)度程序）以映射單詞

映射單詞后，將消息發(fā)送到ReduceActor（使用RoundRobinRouter調(diào)度程序）以減少單詞

精簡后的結(jié)果將發(fā)送到Aggregate Actor，后者對結(jié)果進(jìn)行內(nèi)存內(nèi)聚合

下圖詳細(xì)說明了程序的結(jié)構(gòu)

該程序的代碼庫位于以下位置-https://github.com/write2munish/Akka-Essentials 。
有關(guān)MapReduce的更多信息，請閱讀MapReduce for dummies 。

參考： Akka Essentials博客上的JCG合作伙伴 Munish K Gupta提供的Akka 字?jǐn)?shù)統(tǒng)計(jì)MapReduce 。

翻譯自: https://www.javacodegeeks.com/2012/04/word-count-mapreduce-with-akka.html

總結(jié)

以上是生活随笔為你收集整理的Akka的字数统计MapReduce的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。