05-Flink可视化控制台依赖配置和界面介绍

• WebUI可视化界面
  • 访问：ip:8081
  • 方式一：服务端部署Flink集群（生产环境）
  • 方式二：本地依赖添加（测试开发）

    <!--Flink web ui-->
    <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-runtime-web_${scala.version}</artifactId>
        <version>${flink.version}</version>
    </dependency>

• 代码开发

    public static void main(String[] args) throws Exception {

        final StreamExecutionEnvironment env = StreamExecutionEnvironment.createLocalEnvironmentWithWebUI(new Configuration());
        //env.setParallelism(1);

        DataStream<String> stringDataStream = env.socketTextStream("121.40.146.120", 8888);

        DataStream<String> flatMapDataStream = stringDataStream.flatMap(new FlatMapFunction<String, String>() {
            @Override
            public void flatMap(String value, Collector<String> out) throws Exception {
                String[] arr = value.split(",");
                for (String word : arr) {
                    out.collect(word);
                }
            }
        });
        flatMapDataStream.print("结果");

        //DataStream需要调用execute,可以取个名称
        env.execute("data stream job");
    }

• nc命令介绍

  • Linux nc命令用于设置网络路由的
  • nc -lk 8888
  • 开启 监听模式，用于指定nc将处于监听模式, 等待客户端来链接指定的端口

• win | linux 需要安装

  • win 百度搜索博文参考不同系统安装
    • 下载地址 https://eternallybored.org/misc/netcat/
  • linux 安装
    • yum install -y netcat
    • yum install -y nc