Java中远程调用DataStage的job，job没有执行

0 0

Java中远程调用DataStage的job，job没有执行3

RemoteShellTool t = new RemoteShellTool(***,***,***);//连接远程服务的工具类
System.out.println(t.login());
        String result1 = t.exec("(cd /home/dsadm/Ascential/DataStage/DSEngine/bin;dsjob -run -mode NORMAL -warn 0 dstest daochu)");
        System.out.println(result1);

经测试，可以连接登录远程机（AIX系统），就无法执行，而且该job在远程命令窗口手动是可以执行的，有人知道原因吗？

问题补充：什么原因哇？

2012年7月03日 16:43

v韧竹v
-1
0 0 9

3个答案按时间排序按投票排序

0 0

我这里可以的

import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.Charset;

import ch.ethz.ssh2.Connection;
import ch.ethz.ssh2.Session;

/**
* 远程Shell脚本执行工具
*
* @author Administrator
*/
public class RemoteShellTool {

        private Connection conn;
        private String ipAddr;
        private String charset = Charset.defaultCharset().toString();
        private String userName;
        private String password;

        public RemoteShellTool(String ipAddr, String userName, String password,
                        String charset) {
                this.ipAddr = ipAddr;
                this.userName = userName;
                this.password = password;
                if (charset != null) {
                        this.charset = charset;
                }
        }

        /**
         * 登录远程Linux主机
         *
         * @return
         * @throws IOException
         */
        public boolean login() throws IOException {
                conn = new Connection(ipAddr);
                conn.connect(); // 连接
                return conn.authenticateWithPassword(userName, password); // 认证
        }

        public static void main(String[] args) {
                try {
                RemoteShellTool tool = new RemoteShellTool("127.0.0.1", "xxx", "xxx", "utf-8");

                    System.out.println(tool.login());
                    System.out.println(tool.exec("cd tmp/tomcat7/bin && ls"));
                    System.out.println(tool.exec("cd tmp/tomcat7/bin && ./startup.sh"));

                } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
        }

        /**
         * 执行Shell脚本或命令
         *
         * @param cmds
         *            命令行序列
         * @return
         */
        public String exec(String cmds) {
                InputStream in = null;
                String result = "";
                try {
                        if (this.login()) {
                                Session session = conn.openSession(); // 打开一个会话
                                session.execCommand(cmds);
                                in = session.getStdout();
                                result = this.processStdout(in, this.charset);
                                conn.close();
                        }
                } catch (IOException e1) {
                        e1.printStackTrace();
                }
                return result;
        }

        /**
         * 解析流获取字符串信息
         *
         * @param in
         *            输入流对象
         * @param charset
         *            字符集
         * @return
         */
        public String processStdout(InputStream in, String charset) {
                byte[] buf = new byte[1024];
                StringBuffer sb = new StringBuffer();
                try {
                        while (in.read(buf) != -1) {
                                sb.append(new String(buf, charset));
                        }
                } catch (IOException e) {
                        e.printStackTrace();
                }
                return sb.toString();
        }

}