storm(3)-任务提交

public void submitTopologyToMachine(String nimbusAddress, String fileName, List<String> mainArgs, String mainClass, String jarFile){
        StringBuffer args = new StringBuffer();
        args.append(jarFile).append(" ");
        for (String arg: mainArgs){
            args.append(arg).append(" ");
        }
        args.append("-Dstorm.options=nimbus.host=").append(nimbusAddress).append(" ");
        args.append(mainClass);
        if (fileName != null){
            args.append(" ").append(fileName);
        }
        InputStream is = null;
        try {
            Runtime rt = Runtime.getRuntime();
            String command = "/home/apps/platform/storm/bin/storm/bin/storm jar "+args.toString();
            LOG.info("submit topology command is {}", command);
            String[] commandStr = {"/bin/sh","-c",command};
            Process proc = rt.exec(commandStr);
            if (LOG.isDebugEnabled()) {
                is = proc.getErrorStream();
                BufferedReader reader = new BufferedReader(new InputStreamReader(is));
                String line;
                while ((line = reader.readLine()) != null) {
                    LOG.debug("submit topology result line {}", line);
                }
            }
            int exitVal = proc.waitFor();
            LOG.info("submit topology result is {}", exitVal==0? "success" : "failure");

        } catch (IOException e) {
            LOG.error("submit job is exception {}", e);
        } catch (InterruptedException e) {
            LOG.error("submit job is exception {}", e);
        }finally {
            try {
                if (is != null){
                    is.close();
                }
            } catch (IOException e) {

            }
        }
    }