摘要：在阅读Flink源代码之前，需要做一些准备工作并了解Flink的设计理念与基本架构。
在阅读Flink源代码之前，需要做一些准备工作并了解Flink的设计理念与基本架构。
本章首先介绍如何搭建阅读Flink源代码所需的环境、Flink源代码的获取和调试方法以及Flink源代码的目录结构，然后介绍Flink的设计理念与基本架构；
在下载、导入和阅读Flink源代码之前，需要准备好所需的环境。
1. JDK环境
根据计算机的操作系统类型，下载相应版本的JDK并安装。注意，需要保证JDK的版本在1.8及以上，原因是Flink使用了JDK 1.8中新增的lambda特性。JDK的下载地址为
https://www.oracle.com/technetwork/JAVA/javase/downloads/index.html。
执行以下命令配置环境：
$ vi ~/.bash_proFile
添加Java环境配置：
export JAVA_HOME=/usr/local/java
export CLASSPATH=$:CLASSPATH:$JAVA_HOME/lib/
export PATH=$PATH:$JAVA_HOME/bin
环境配置设置完成后，执行source命令，让配置立即生效。
$ source ~/.bash_profile
最后，使用java -version命令确认安装正常，如图1-1所示。
2. Git
Flink源代码使用Git作为版本控制工具。访问Git的下载地址https://git-scm.com/downloads下载最新版本的Git并安装。
下面介绍如何配置SSH公钥。
1）生成GitHub使用的SSH公钥。输入下面的ssh-keygen命令，再按3次回车键即可。（注：-C后面跟的是GitHub账号的关联邮箱。）
$ ssh-keygen -t rsa -C 'xx@xx.com' -f ~/.ssh/id-rsa-github
2）将SSH公钥添加到GitHub。复制生成的公钥~/.ssh/id-rsagithub.pub的内容，再登录GitHub账号，在Account settings中单击New SSHkey按钮，在新页面中将刚才复制的内容填入Key字段，并单击Add SSH key按钮进行保存，如图1-2所示。
3）通过下面的命令测试SSH公钥是否生效。
ssh -T git@github.com
4）出现GitHub欢迎界面，则配置成功，如图1-3所示。
对于一些开发者来说，除了个人的Git仓库外，公司也有Git仓库，因此需要配置多个SSH公钥。公司的Git仓库生成SSH公钥的方式与GitHub类似，只需创建一个ssh config配置即可。
$ vi ~/.ssh/config
ssh config配置内容如下：
#GitLab
Host gitlab.company.com
HostName gitlab.company.com
PreferredAuthentications publickey
IdentityFile ~/.ssh/id-rsa-company
# GitHub
Host github.com
HostName github.com
IdentityFile ~/.ssh/id-rsa-github
host *
ControlMaster auto
ControlPath ~/.ssh/master-%r@%h:%p
3. Maven
Flink源代码使用Maven作为构建工具。Flink官方推荐使用Maven 3.2.5版本，Maven的下载地址为https://maven.apache.org/download.cgi#。注意，如果你下载的是Maven 3.3.x版本，则需注意Shade存在问题。
4. IntelliJ IDEA
Eclipse和IDEA都是流行的Java IDE，但由于Eclipse存在对scala的兼容性问题，因此Flink官方推荐使用IntelliJ IDEA作为IDE。
（1）下载IntelliJ IDEA
读者可以通过IntelliJ IDEA的官方网站，根据自己的计算机操作系统进行下载和安装。下载地址为https://www.jetbrains.com/idea/download/。
（2）Scala
Scala是面向函数式编程的语言，在大数据的流式开发方面，相比Java，Scala开发更简洁方便。Flink主要用到的有Scala API、Flink SQL和Akka通信。IntelliJ IDEA默认不支持Scala开发环境，阅读源代码时需要安装Scala插件。
（3）Scala插件安装
在IntelliJ IDEA的菜单栏选择Preferences选项，然后选择Plugins选项，在搜索框中输入scala，如图1-4所示。在搜索出来的结果列表中选择Scala插件并安装，安装后重启IDEA，Scala插件即安装完毕。
本篇内容讲解到这里就结束了，因为也比较简单，只是环境的准备。
下篇内容给大家讲解获取、编译和调试Flink的源代码！
来源：大数据架构师
