下载掌阅APP，畅读海量书库
立即打开
在准备好所有的开发环境之后，我们就可以开始开发自己的第一个Flink程序了。首先我们要做的，就是在IDEA中搭建一个Flink项目的骨架。我们使用Java项目中常见的Maven来进行依赖管理。
1.创建工程
（1）打开IntelliJ IDEA，创建一个Maven工程，如图2-1所示。
图2-1 创建Maven工程
（2）将这个Maven工程命名为FlinkTutorial，如图2-2所示。
图2-2 Maven工程命名
（3）设置这个Maven工程所在的存储路径，并点击Finish按钮，如图2-3所示，Maven工程即创建成功。
图2-3 Maven工程路径设置
2.添加项目依赖
在项目的pom文件中，增加<properties>标签设置属性，然后增加<denpendencies>标签引入需要的依赖。我们需要添加的依赖最重要的就是Flink的相关组件，包括flink-scala、flink-streaming-scala，以及flink-clients（客户端，也可以省略）。
这里做一点解释：
在属性中，我们定义了<scala.binary.version>，这指代的是所依赖的Scala版本。这不仅因为我们将使用Scala API，还因为Flink的架构中使用了Akka来实现底层的分布式通信，而Akka是用Scala开发的。本书中用到的Scala版本为2.12。