关键词：
导读：如何存储、如何利用大规模的服务器集群处理计算才是大数据技术的核心。
作者：李智慧
来源：大数据DT（ID：hzdashuju）
大数据技术其实是分布式技术在数据处理领域的创新性应用，其本质和此前讲到的分布式技术思路一脉相承，即用更多的计算机组成一个集群，提供更多的计算资源，从而满足更大的计算压力要求。
大数据技术讨论的是，如何利用更多的计算机满足大规模的数据计算要求。
大数据就是将各种数据统一收集起来进行计算，发掘其中的价值。这些数据，既包括数据库的数据，也包括日志数据，还包括专门采集的用户行为数据；既包括企业内部自己产生的数据，也包括从第三方采购的数据，还包括使用网络爬虫获取的各种互联网公开数据。
面对如此庞大的数据，如何存储、如何利用大规模的服务器集群处理计算才是大数据技术的核心。
01 HDFS分布式文件存储架构
大规模的数据计算首先要解决的是大规模数据的存储问题。如何将数百TB或数百PB的数据存储起来，通过一个文件系统统一管理，这本身就是一项极大的挑战。
HDFS的架构，如图31-1所示。
▲图31-1 HDFS架构
HDFS可以将数千台服务器组成一个统一的文件存储系统，其中NameNode服务器充当文件控制块的角色，进行文件元数据管理，即记录文件名、访问权限、数据存储地址等信息，而真正的文件数据则存储在DataNode服务器上。
DataNode以块为单位存储数据，所有的块信息，比如块ID、块所在的服务器IP地址等，都记录在NameNode服务器上，而具体的块数据则存储在DataNode服务器上。理论上，NameNode可以将所有DataNode服务器上的所有数据块都分配给一个文件，也就是说，一个文件可以使用所有服务器的硬盘存储空间。
此外，HDFS为了保证不会因为硬盘或者服务器损坏而导致文件损坏，还会对数据块进行复制，每个数据块都会存储在多台服务器上，甚至多个机架上。
02 MapReduce大数据计算架构
数据存储在HDFS上的最终目标还是为了计算，通过数据分析或者机器学习获得有益的结果。但是如果像传统的应用程序那样把HDFS当作普通文件，从文件中读取数据后进行计算，那么对于需要一次计算数百TB数据的大数据计算场景，就不知道要算到什么时候了。
大数据处理的经典计算框架是MapReduce。MapReduce的核心思想是对数据进行分片计算。既然数据是以块为单位分布存储在很多台服务器组成的集群上的，那么能不能就在这些服务器上针对每个数据块进行分布式计算呢？
事实上，MapReduce可以在分布式集群的多台服务器上启动同一个计算程序，每个服务器上的程序进程都可以读取本服务器上要处理的数据块进行计算，因此，大量的数据就可以同时进行计算了。但是这样一来，每个数据块的数据都是独立的，如果这些数据块需要进行关联计算怎么办？
MapReduce将计算过程分成两个部分：
一部分是map过程，每个服务器上会启动多个map进程，map优先读取本地数据进行计算，计算后输出一个<key, value>集合；
另一部分是reduce过程，MapReduce在每个服务器上都会启动多个reduce进程，然后对所有map输出的<key, value>集合进行shuffle操作。所谓的shuffle就是将相同的key发送到同一个reduce进程中，在reduce中完成数据关联计算。
下面以经典的WordCount，即统计所有数据中相同单词的词频数据为例，来认识map和reduce的处理过程，如图31-2所示。
▲图31-2 词频统计程序WordCount的MapReduce处理过程
假设原始数据有两个数据块，MapReduce框架启动了两个map进程进行处理，它们分别读入数据。
map函数会对输入数据进行分词处理，然后针对每个单词输出<单词, 1>这样的<key, value>结果。然后MapReduce框架进行shuffle操作，相同的key发送给同一个reduce进程，reduce的输入就是<key, value列表>这样的结构，即相同key的value合并成了一个value列表。
在这个示例中，这个value列表就是由很多个1组成的列表。reduce对这些1进行求和操作，就得到每个单词的词频结果了。
具体的MapReduce程序如下：
public class WordCount
public static class TokenizerMapper
extends Mapper<Object, Text, Text, IntWritable>
private final static IntWritable one = new IntWritable(1);
private Text word = new Text();
public void map(Object key, Text value, Context context
) throws IOException, InterruptedException
StringTokenizer itr = new StringTokenizer(value.toString());
while (itr.hasMoreTokens())
word.set(itr.nextToken());
context.write(word, one);
public static class IntSumReducer
extends Reducer<Text,IntWritable,Text,IntWritable>
private IntWritable result = new IntWritable();
public void reduce(Text key, Iterable<IntWritable> values,
Context context
) throws IOException, InterruptedException
int sum = 0;
for (IntWritable val : values)
sum += val.get();
result.set(sum);
context.write(key, result);
上面讲述了map和reduce进程合作完成数据处理的过程，那么这些进程是如何在分布式的服务器集群上启动的呢？数据是如何流动并最终完成计算的呢？下面以MapReduce1为例来看这个过程，如图31-3所示。
▲图31-3 MapReduce1计算处理过程
MapReduce1主要有JobTracker和TaskTracker这两种进程角色，JobTracker在MapReduce集群中只有一个，而TaskTracker则和DataNode一起启动在集群的所有服务器上。
MapReduce应用程序JobClient启动后，会向JobTracker提交作业，JobTracker根据作业中输入的文件路径分析需要在哪些服务器上启动map进程，然后就向这些服务器上的TaskTracker发送任务命令。
TaskTracker收到任务后，启动一个TaskRunner进程下载任务对应的程序，然后反射加载程序中的map函数，读取任务中分配的数据块，并进行map计算。map计算结束后，TaskTracker会对map输出进行shuffle操作，然后TaskRunner加载reduce函数进行后续计算。
HDFS和MapReduce都是Hadoop的组成部分。
03 Hive大数据仓库架构
MapReduce虽然只有map和reduce这两个函数，但几乎可以满足任何大数据分析和机器学习的计算场景。不过，复杂的计算可能需要使用多个job才能完成，这些job之间还需要根据其先后依赖关系进行作业编排，开发比较复杂。
传统上，主要使用SQL进行数据分析，如果能根据SQL自动生成MapReduce，就可以极大降低大数据技术在数据分析领域的应用门槛。
Hive就是这样一个工具。我们来看对于如下一条常见的SQL语句，Hive是如何将其转换成MapReduce计算的。
SELECT pageid, age, count(1) FROM pv_users GROUP BY pageid, age;这是一条常见的SQL统计分析语句，用于统计不同年龄的用户访问不同网页的兴趣偏好，具体数据输入和执行结果示例如图31-4所示。
▲图31-4 SQL统计分析输入数据和执行结果举例
看这个示例我们就会发现，这个计算场景和WordCount很像。事实上也确实如此，我们可以用MapReduce完成这条SQL的处理，如图31-5所示。
▲图31-5 MapReduce完成SQL处理过程举例
map函数输出的key是表的行记录，value是1，reduce函数对相同的行进行记录，也就是针对具有相同key的value集合进行求和计算，最终得到SQL的输出结果。
Hive要做的就是将SQL翻译成MapReduce程序代码。实际上，Hive内置了很多Operator，每个Operator完成一个特定的计算过程，Hive将这些Operator构造成一个有向无环图DAG，然后根据这些Operator之间是否存在shuffle将其封装到map或者reduce函数中，之后就可以提交给MapReduce执行了。
Operator组成的DAG如图31-6所示，这是一个包含where查询条件的SQL，where查询条件对应一个FilterOperator。
▲图31-6 示例SQL的MapReduce 有向无环图DAG
Hive整体架构如图31-7所示。Hive的表数据存储在HDFS。表的结构，比如表名、字段名、字段之间的分隔符等存储在Metastore中。用户通过Client提交SQL到Driver，Driver请求Compiler将SQL编译成如上示例的DAG执行计划中，然后交给Hadoop执行。
▲图31-7 Hive整体架构
04 Spark快速大数据计算架构
MapReduce主要使用硬盘存储计算过程中的数据，虽然可靠性比较高，但是性能却较差。
此外，MapReduce只能使用map和reduce函数进行编程，虽然能够完成各种大数据计算，但是编程比较复杂。而且受map和reduce编程模型相对简单的影响，复杂的计算必须组合多个MapReduce job才能完成，编程难度进一步增加。
Spark在MapReduce的基础上进行了改进，它主要使用内存进行中间计算数据存储，加快了计算执行时间，在某些情况下性能可以提升上百倍。
Spark的主要编程模型是RDD，即弹性数据集。在RDD上定义了许多常见的大数据计算函数，利用这些函数可以用极少的代码完成较为复杂的大数据计算。前面举例的WorkCount如果用Spark编程，只需要三行代码：
val textFile = sc.textFile("hdfs://...")
val counts = textFile.flatMap(line => line.split(" "))
.map(word => (word, 1))
.reduceByKey(_ + _)
counts.saveAsTextFile("hdfs://...")首先，从HDFS读取数据，构建出一个RDD textFile。然后，在这个RDD上执行三个操作：
一是将输入数据的每一行文本用空格拆分成单词；
二是将每个单词进行转换，比如word→(word, 1)，生成<Key, Value>的结构；
三是针对相同的Key进行统计，统计方式是对Value求和。最后，将RDD counts写入HDFS，完成结果输出。
上面代码中flatMap、map、reduceByKey都是Spark的RDD转换函数，RDD转换函数的计算结果还是RDD，所以上面三个函数可以写在一行代码上，最后得到的还是RDD。
Spark会根据程序中的转换函数生成计算任务执行计划，这个执行计划就是一个DAG。Spark可以在一个作业中完成非常复杂的大数据计算，Spark DAG示例如图31-8所示。
▲图31-8 Spark RDD有向无环图DAG示例
在图31-8中，A、C和E是从HDFS上加载的RDD。A经过groupBy分组统计转换函数计算后得到RDD B，C经过map转换函数计算后得到RDD D，D和E经过union合并转换函数计算后得到RDD F，B和F经过join连接转换函数计算后得到最终结果RDD G。
05 大数据流计算架构
Spark虽然比MapReduce快很多，但是在大多数场景下计算耗时依然是分钟级别的，这种计算一般被称为大数据批处理计算。而在实际应用中，有些时候需要在毫秒级完成不断输入的海量数据的计算处理，比如实时对摄像头采集的数据进行监控分析，这就是所谓的大数据流计算。
早期比较著名的流式大数据计算引擎是Storm，后来随着Spark的火爆，Spark上的流式计算引擎Spark Streaming也逐渐流行起来。Spark Streaming的架构原理是将实时流入的数据切分成小的一批一批的数据，然后将这些小的一批批数据交给Spark执行。
由于数据量比较小，Spark Streaming又常驻系统，不需要重新启动，因此可以在毫秒级完成计算，看起来像是实时计算一样，如图31-9所示。
▲图31-9 Spark Streaming流计算将实时流式数据转化成小的批处理计算
最近几年比较流行的大数据引擎Flink其架构原理和Spark Streaming很相似，它可以基于不同的数据源，根据数据量和计算场景的要求，灵活地适应流计算和批处理计算。
06 小结
大数据技术可以说是分布式技术的一个分支，两者都是面临大量的计算压力时，采用分布式服务器集群的方案解决问题。差别是大数据技术要处理的数据具有关联性，所以需要有个中心服务器进行管理，NameNode、JobTracker都是这样的中心服务器。
而高并发的互联网分布式系统为了提高系统可用性，降低中心服务器可能会出现的瓶颈压力、提升性能，通常不会在架构中使用这样的中心服务器。
划重点👇
干货直达👇
更多精彩👇
终于有人把大数据架构讲明白了
导读：如何存储、如何利用大规模的服务器集群处理计算才是大数据技术的核心。作者：李智慧来源：大数据DT（ID：hzdashuju）大数据技术其实是分布式技术在数据处理领域的创新性应用，其本质和此前... 查看详情
终于有人把分布式系统架构讲明白了
「数仓宝贝库」，带你学数据！导读：随着互联网的不断发展，企业积累的数据越来越多。当单台数据库难以存储海量数据时，人们便开始探索如何将这些数据分散地存储到多台服务器的多台数据库中，逐... 查看详情
终于有人把企业架构讲明白了
作者：付晓岩来源：大数据DT（ID：hzdashuju）01企业架构的概念与范围企业架构设计的服务对象是企业，所以，“企业”是企业架构理论需要首先明确的概念，对于这一概念，笔者比较赞同TOGAF理... 查看详情
终于有人把云原生架构讲明白了
今天，每个IT资源或产品都作为服务提供。因此，云原生软件开发成为每个企业的关键要求，无论其规模和性质如何。在加入云计算潮流之前，了解什么是云原生架构以及如何为您的云原生应用程序需求设计正确的架构非常重要... 查看详情
收藏，数据仓库建设与框架终于有人给讲明白了
数据仓库，这个几乎是所有大数据开发面试必问的话题。比如数据仓库的分层架构？为什么需要数据仓库建模？数据仓库建模的原则是什么？结合业务举例说明数据仓库建模的步骤，以及注意事项？... 查看详情
收藏，数据仓库建设与框架终于有人给讲明白了
数据仓库，这个几乎是所有大数据开发面试必问的话题。比如数据仓库的分层架构？为什么需要数据仓库建模？数据仓库建模的原则是什么？结合业务举例说明数据仓库建模的步骤，以及注意事项？... 查看详情
终于有人把微服务讲明白了
作者：魏新宇郭跃军来源：大数据DT（ID：hzdashuju）01微服务架构简介微服务这个概念并不是近年才有的，但这两年随着以容器为核心的新一代应用承载平台的崛起，微服务焕发了新的生命力。传统的巨... 查看详情
大数据技术终于有人把数据质量管理讲明白了！数据质量：数据治理的核心
目录背景何为数据？数据治理数据质量管理数据质量控制方法论 查看详情
终于有人把数据仓库讲明白了
作者：彭锋宋文欣孙浩峰来源：大数据DT（ID：hzdashuju）数据仓库是一个面向主题的、集成的、随时间变化但信息本身相对稳定的数据集合，用于支持管理决策过程。数据仓库的主要功能如下：建立公司... 查看详情
终于有人把数据治理讲明白了
导读：数据治理：说起来容易，做起来难。作者：石秀峰来源：谈数据（ID：learning-bigdata）“数据治理”这个10多年前就已经出现的名称，在最近这几年时间一下子火了起来。不知何时，江... 查看详情
终于有人把数据湖讲明白了
作者：彭锋宋文欣孙浩峰来源：数仓宝贝库作为全局数据汇总及处理的核心功能，数据湖在数据中台建设中必不可少。那么它与数据仓库、数据中台是什么关系？图10-1显示了一个典型的从数据采集到数据湖、数据... 查看详情
终于有人把iaaspaassaas讲明白了
...多应用场景，给出了具体解决方案。干货直达👇终于有人把分布式机器学习讲明白了聊聊这个SaaS领域爆火的话题终于有人把AB实验讲明白了图解3种主流企业架构模式（建议收藏！）更多精彩👇在公众号对... 查看详情
终于有人把iaaspaassaas讲明白了
...多应用场景，给出了具体解决方案。干货直达👇终于有人把分布式机器学习讲明白了聊聊这个SaaS领域爆火的话题终于有人把AB实验讲明白了图解3种主流企业架构模式（建议收藏！）更多精彩👇在公众号对... 查看详情
终于有人把排序算法讲明白了
导读：在大数据时代，对复杂数据结构中的各数据项进行有效的排序和查找的能力非常重要，因为很多现代算法都需要用到它。在为数据恰当选择排序和查找策略时，需要根据数据的规模和类型进行判断。尽管不... 查看详情
终于有人把红蓝对抗讲明白了
导读：什么是红蓝对抗？作者：木羊同学来源：大数据DT（ID：hzdashuju）我们现在所处的时代，有人称为网络时代，有人称为信息时代，也有人称为数据时代，不管名字怎么叫吧，我... 查看详情
终于有人把红蓝对抗讲明白了
导读：什么是红蓝对抗？作者：木羊同学来源：大数据DT（ID：hzdashuju）我们现在所处的时代，有人称为网络时代，有人称为信息时代，也有人称为数据时代，不管名字怎么叫吧，我... 查看详情
终于有人把iaaspaassaas讲明白了
导读：各有哪些有点？作者：王健宗何安珣李泽远内容摘编自《金融智能：AI如何为银行、保险、证券业赋能》视频制作：大数据DT（ID：hzdashuju）关注数据叔视频号，看更多干货视频👇延伸... 查看详情
终于有人把云计算与数据库的关系讲明白了
导读：本文讨论云计算与数据库的关系，包括云数据库自身的技术和特征，也包括云数据库的使用方式和形态变迁。作者：李海翔来源：大数据DT（ID：hzdashuju）2006年Google的CEO埃里克·施密特首次提... 查看详情