Flink 实时处理 Socket 数据

在 2.3 中讲解了 Flink 最简单的 WordCount 程序的创建、运行结果查看和代码分析，这篇文章继续带大家来看一个入门上手的程序：Flink 处理 Socket 数据。

IDEA 创建项目

使用 IDEA 创建新的 module，结构如下：

├── pom.xml
└── src
    ├── main
    │   ├── java
    │   │   └── com
    │   │       └── zhisheng
    │   │           └── socket
    │   │               └── Main.java
    │   └── resources
    │       └── log4j.properties
    └── test
        └── java

项目创建好了后，我们下一步开始编写 Flink Socket Job 的代码。

Flink Socket 应用程序代码

Main 类：

public class Main {
    public static void main(String[] args) throws Exception {
        //参数检查
        if (args.length != 2) {
            System.err.println("USAGE:\nSocketTextStreamWordCount <hostname> <port>");
            return;
        }
        String hostname = args[0];
        Integer port = Integer.parseInt(args[1]);
        final StreamExecutionEnvironment