Flink 源码阅读准备之 – Apache Commons Cli

一、介绍一下 Apache Commons Cli,有一个感官的认识

我们在使用一些开源项目时,会敲一些命令,有简单的,比如 hadoop version;有复杂的,比如 flink run … ,hdfs dfs -ls ,等等。一般这些命令后面有很多的参数,特别是在往 Yarn 上提交 Flink 任务时,后面要设置很多属性。

这些命令实际上最终还是会启动虚拟机来执行的,如果你用 vi 看过这些命令,就可以发现,最终都是调用的 java xxxx,来执行的。那么命令后面的参数会传到 main 方法里,然后 main 方法的代码再去解析这些个参数。

参数比较少,一两个月还好。参数一多,那解析起来简直就是灾难了,会有很多 switch ,if else 。

Apache Commons Cli 项目就是为了解决这个问题的。它封装了命令行的基本元素,帮助程序去解析传递给程序的命令行参数。也可以打印帮助信息来说明这个命令行的有效参数。

二、核心概念

核心概念只有三个,那就是命令行程序的处理流程

  • 定义阶段

首先我们要通过 Options 对象,来创建实例,把我们可能要处理的所有参数,都预先定义好。这样一方面,可以打印出命令行参数的使用帮助,另一方面才能处理掉参数的所有情况;

  • 解析阶段

解析阶段,就是把用户命令行传到程序里的参数,通过 CommandLineParser 类解析出来,解析出来 CommandLine 对象。

  • 询问阶段

询问阶段,就是把程序中需要用的参数从 CommandLine 中解析出来,并根据不同的参数,走到不同的应用代码分支。这个阶段在用户应用逻辑中实现。

三、用一个例子就能理解全部了

上面我们并没有讲太多代码细节,因为把全局的概念弄清楚,搞懂代码其实就没什么难度了。最后用一个例子,把上面的知识点都串起来。

 package com.hudsun.flink.commonscli;
 ​
 import org.apache.commons.cli.*;
 ​
 /**
  * @Author wangkai
  * @Time 2021/2/2 15:55
  */
 public class CommonsCli01 {
 ​
     public static void main(String[] args1) throws ParseException {
         String[] arg = { "-h", "-c", "config.xml" };
         testOptions(arg);
    }
 ​
     public static void testOptions(String[] args) {
         // Options 准备阶段,准备好所有的选项
         Options options = new Options();
         Option opt = new Option("h", "help", false, "Print help");
         opt.setRequired(false);
         options.addOption(opt);
 ​
         opt = new Option("c", "configFile", true, "Name server config properties file");
         opt.setRequired(false);
         options.addOption(opt);
 ​
         opt = new Option("p", "printConfigItem", false, "Print all config item");
         opt.setRequired(false);
         options.addOption(opt);
 ​
         // 帮助打印
         HelpFormatter hf = new HelpFormatter();
         hf.setWidth(110);
 ​
         // 解析从命令行传过来的参数
         CommandLine commandLine = null;
         CommandLineParser parser = new PosixParser();
         try {
             // 得到 CommandLine 对象
             commandLine = parser.parse(options, args);
 ​
             // 根据不同的参数处理不同的业务逻辑
             // h 打印帮助信息
             if (commandLine.hasOption('h')) {
                 // 打印使用帮助
                 hf.printHelp("testApp", options, true);
            }
 ​
             // 打印opts的名称和值
             System.out.println("--------------------------------------");
             Option[] opts = commandLine.getOptions();
             if (opts != null) {
                 for (Option opt1 : opts) {
                     String name = opt1.getLongOpt();
                     String value = commandLine.getOptionValue(name);
                     System.out.println(name + "=>" + value);
                }
            }
        }
         catch (ParseException e) {
             hf.printHelp("testApp", options, true);
        }
    }
 }
 ​

原创文章,作者:kk,如若转载,请注明出处:http://www.wangkai123.com/76/

(0)
上一篇 2022-06-19 21:57
下一篇 2022-06-19 21:59

相关推荐

  • Flink 异步 I/O 解析

    一、简介 我们知道 flink 对于外部数据源的操作可以通过自带的连接器,或者自定义 sink 和 source 实现数据的交互。 那么为啥还需要异步 IO 呢?那时因为对于实时处…

    Flink 2022-06-19
  • linux 的输入(出)重定向和管道符

    一、输入输出重定向 标准输入重定向(STDIN,文件描述符为0):默认从键盘输入,也可从其他文件或者命令中输入 标准输出重定向(STDOUT,文件描述符为1):默认输出到屏幕 错误…

    Linux 2022-07-03
  • Flink-Clients 源码阅读(2)

    一、我们本次的目的是什么? 这次我们的目的是,在本地的 IDEA 中去 debug flink-clients 代码,然后远程提交给 flink standalone 集群上去执行…

    Flink 2022-06-19
  • Flink 源码阅读准备之 – SPI 和 ClassLoader

    一、本文大纲 二、ClassLoader 类加载器 1、Java 中的类加载器以及双亲委派机制 Java 中的类加载器,是 Java 运行时环境的一部分,负责动态加载 Java 类…

    Flink 2022-06-19
  • Flink metrics 介绍和应用

    一、Flink metrics简介 Flink 的 metrics 是 Flink 公开的一个度量系统,metrics 也可以暴露给外部系统,通过在 Flink 配置文件 conf…

    Flink 2022-06-19
  • Flink 异步编程模型介绍

    本次我们来实现一个支持百万并发连接数的采集服务器,并且找到异步+ NIO 的编程方式和实时流模型的那些千丝万缕的联系。 一、需求说明 简单的需求功能如下: 数据采集是一个 web …

    Flink 2022-06-19
  • vim 的使用

    一、命令模式中最常用的一些命令 dd 删除(剪切)光标所在行 5dd 删除(剪切)从光标处开始的5行 yy 复制光标所在的整行 5yy 复制从光标处开始的5行 n 显示搜索命令定位…

    Linux 2022-07-03
  • Flink 源码阅读准备之 – Java8 异步编程

    阅读 Flink 源码前必会的知识 Java8 异步编程 本文大纲速看 一、异步编程 通常来说,程序都是顺序执行,同一时刻只会发生一件事情。如果一个函数依赖于另一个函数的结果,它只…

    Flink 2022-06-19
  • Flink-Clients 模块源码阅读

    本文大纲 一、Flink 官方文档这么全面,为什么还要读 Flink 源码 读文档和读源码的目的是不一样的,就拿 Apache Flink 这个项目来说,如果你想知道 Flink …

    Flink 2022-06-19
  • Flink 用户代码如何生成 StreamGraph(下)

    九、一小段源码 上次说到了所有的算子都会转化成 transformation ,并放到一个 List 列表中,那么今天我们开始遍历这个列表,来生成 StreamGraph。 打开这…

    Flink 2022-06-19

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注