第93讲:Akka第一个案例动手实战开发消息实体类
HelloActor的整体框架及实现:
一:HelloActor包括的actors:
1 AggregateActor:对最后所有ReduceActor的结果进行统计
2 MapActor:对收到的消息进行单词切分
3 MasterActor 控制器,给MapActor发字符串,要MapActor进行单词切分工作。
4 ReduceActor 对MapActor产生的结果进行统计
二:HelloActor包括的messages 数据存储的数据,定义数据实体
如下:
1 MapData:私有成员是一个list WordCount,用来让MapActor处理数据以后存储在MapData,然后交给ReduceActor。
过程:
MasterActor 发送一个字符串 ->MapActor对字符串单词切分,存储在MapData,交给ReduceActor进行本地统计。
2 ReduceData:对MapActor产生的结果进行本地性统计为ReduceData(类似于hadoop中的comminbia),再发送给AggregateActor
进行全局统计
3 Result:master.tell(new Result),消息类型是Result,因此转给AggregateActor进行处理,AggregateActor识别是Result,就打印出最后统计的结果。
4 WordCount :包括:单词字符串及计数,在MapActor表现为(字符串,1)
DT大数据微信公众账号:DT_Spark
DT大数据梦工厂scala的所有视频、PPT和代码在百度云盘的链接地址:http://pan.baidu.com/share/home?uk=4013289088&view=share#category/type=0&qq-pf-to=pcqq.group