Flink 实时处理 Socket 数据

本文主要是介绍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 

这篇关于Flink 实时处理 Socket 数据的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---