ssh登陆程序

ゞ 浴缸里的玫瑰 2022-05-22 08:57 322阅读 0赞 
  1. <dependency>
  2.    <groupId>ch.ethz.ganymed</groupId>
  3.    <artifactId>ganymed-ssh2</artifactId>
  4.    <version>build210</version>
  5. </dependency>
  7. package cn.tisson.ipran.gdcsgcf.driver.client;
  9. import ch.ethz.ssh2.Connection;
  10. import ch.ethz.ssh2.ServerHostKeyVerifier;
  11. import ch.ethz.ssh2.Session;
  12. import org.slf4j.Logger;
  13. import org.slf4j.LoggerFactory;
  15. import java.io.InputStreamReader;
  16. import java.io.OutputStreamWriter;
  18. public class SshCommandDriver extends CommandDriver{
  19.    protected Logger log = LoggerFactory.getLogger(SshCommandDriver.class);
  20.    private Connection conn = null;
  21.    //SSH会话
  22.    private Session sess = null;
  23.    @Override
  24.    public int open(String ip, int port, String loginPrompt, String userName,
  25.          String pwdPrompt, String pwd, String commandPrompt,StringBuffer resultBuf) {
  27.       if (isOpen) {
  28.          log.debug("SSH 连接已经打开 ");
  29.          return 0;
  30.       }
  31.       if (ip == null || ip.equals("") || port < -1) {
  32.          log.error("需要ssh连接的ip 或端口不正确，请校验");
  33.          resultBuf.append("需要ssh连接的ip 或端口不正确，请校验");
  34.          return -101;
  35.       }
  36.       try {
  37.          this.ip=ip;
  38.          conn = new Connection(ip, port);
  39.          conn.connect(new ServerHostKeyVerifier() {
  41.             @Override
  42.             public boolean verifyServerHostKey(String hostname, int port,
  43.                         String serverHostKeyAlgorithm, byte[] serverHostKey)
  44.                   throws Exception {
  45.                return true;
  46.             }
  47.          }, 5000, 30000);
  48.       } catch (Exception e) {
  49.          resultBuf.append(e.getMessage());
  50.          log.error(ip + " 打开SSH 连接出现异常，连接ip端口为" + port, e);
  51.          close();
  52.          return -102;
  53.       }
  54.       boolean isAuthentication = false;
  55.       try {
  56.          isAuthentication = conn.authenticateWithPassword(userName,pwd);
  57.       } catch (Exception e) {
  58.          resultBuf.append(e.getMessage());
  59.          log.error(ip + " SSH授权出现异常，连接ip端口为"+ port, e);
  60.          close();
  61.          return -103;
  62.       }
  63.       if (!isAuthentication) {
  64.          resultBuf.append(ip + " SSH授权失败，连接ip端口为" + port);
  65.          log.error(ip + " SSH授权失败，连接ip端口为" + port);
  66.          close();
  67.          return -104;
  68.       }
  69.       try {
  70.          sess = conn.openSession();
  71.          sess.requestPTY("dumb", 132, 90, 0, 0, null);
  72.          sess.startShell();
  73.       } catch (Exception e) {
  74.          resultBuf.append(e.getMessage());
  75.          close();
  76.          log.error(ip + "获取session出现异常，连接ip端口为" + port,e);
  77.          return -105;
  78.       }
  79.       try {
  80.          isr = new InputStreamReader(sess.getStdout(), charsetName);
  81.          osr = new OutputStreamWriter(sess.getStdin(), charsetName);
  83.       } catch (Exception e) {
  84.          resultBuf.append(e.getMessage());
  85.          close();
  86.          log.error(ip + "获取输入/出流出现异常，连接ip端口为" + port,e);
  87.          return -106;
  88.       }
  89.       try {
  90.          String result=read(commandPrompt);
  91.          resultBuf.append(result);
  92.          if(this.isAutoAnswer){
  93.             this.write("N");
  94.             result=read(commandPrompt);
  95.             resultBuf.append(result);
  96.          }
  97.          log.debug(result);
  98.          this.commandPrompt=result.substring(result.lastIndexOf("\n")+1);
  99.       } catch (Exception e) {
  100.          resultBuf.append(e.getMessage());
  101.          log.error("读取数据出现异常",e);
  102.       }
  103.       this.isOpen = true;
  104.       return 0;
  106.    }
  107.    public void close(){
  108.       super.close();
  109.       try {
  110.          if (sess != null) {
  111.             sess.close();
  112.          }
  113.          if (conn != null) {
  114.             conn.close();
  115.          }
  116.       } catch (Exception e) {
  117.          log.error(ip+" closed sshClient exception", e);
  118.       }finally{
  119.          sess=null;
  120.          conn = null;
  121.       }
  122.    }
  123.    public static void main(String [] args) throws Exception{
  124.       SshCommandDriver d=new SshCommandDriver();
  125.       StringBuffer buf = new StringBuffer();
  126.       int result=d.open("*.*.*.*", 22, ":", "admin", ":", "123@abc", ">",buf);
  127.       System.out.println(result);
  128.       if(result==0){
  129.          d.write("display version");
  130.          String temp=d.read();
  131.          System.out.println(temp);
  132.       }
  133.       d.close();
  134.    }
  135. }
  137. package cn.tisson.ipran.gdcsgcf.driver.client;
  139. import org.slf4j.Logger;
  140. import org.slf4j.LoggerFactory;
  142. import java.io.BufferedReader;
  143. import java.io.IOException;
  144. import java.io.InputStreamReader;
  145. import java.io.OutputStreamWriter;
  148. public abstract class CommandDriver implements ICommandDriver{
  149.    protected Logger log = LoggerFactory.getLogger(CommandDriver.class);
  150.    protected InputStreamReader isr;// 输入流
  151.    protected OutputStreamWriter osr;// 输出流
  152.    protected boolean isOpen = false;// 是否已经打开连接，防止打开多次
  153.    protected String ip;
  154.    protected String userName;
  155.    protected String pwd;
  156.    protected String commandPrompt;
  157.    protected String loginPrompt;
  158.    protected String pwdPrompt;
  159.    protected int outTime=10000;
  160.    protected String charsetName="iso8859-1";
  161.    protected String neName;
  162.    protected boolean isAutoAnswer = false;
  164.    public boolean isAutoAnswer() {
  165.       return isAutoAnswer;
  166.    }
  167.    @Override
  168.    public abstract int open(String ip, int port, String loginPrompt, String userName,
  169.                       String pwdPrompt, String pwd, String commandPrompt,StringBuffer resultBuf);
  170.    @Override
  171.    public void close() {
  172.       this.isOpen = false;
  173.       try {
  174.          if (isr != null) {
  175.             isr.close();
  176.          }
  177.       } catch (IOException e) {
  178.          log.error(this.ip + "closed inputStreamRead failed", e);
  179.       } finally {
  180.          isr = null;
  181.       }
  182.       try {
  183.          if (osr != null) {
  184.             osr.close();
  185.          }
  187.       } catch (IOException e) {
  188.          log.error(this.ip + "closed outputStramRead failed", e);
  189.       } finally {
  190.          osr = null;
  191.       }
  192.    }
  193.    @Override
  194.    public void write(String command) throws Exception {
  195.       log.debug(ip+" 发送的命令为"+command);
  196.       clearReadBuffer();
  197.       osr.write(command+ getTerminalSendPostfix());
  198.       osr.flush();
  199.    }
  201.    @Override
  202.    public void write(String command,String terminalSendPostfix) throws Exception {
  203.       log.debug(ip+" 发送的命令为"+command);
  204.       clearReadBuffer();
  205.       osr.write(command+ terminalSendPostfix);
  206.       osr.flush();
  207.    }
  209.    @Override
  210.    public String read() throws Exception {
  211.       return this.read(new StringResponseEndChecker() {
  213.          @Override
  214.          public boolean isResponseEnd(StringBuffer data) {
  215.             if (data!=null&&data.toString().trim().endsWith(commandPrompt)) {
  216.                return true;
  217.             }
  218.             return false;
  219.          }
  220.       }, this.outTime);
  221.    }
  223.    @Override
  224.    public String read(String terminator) throws Exception {
  225.       return this.read(terminator, this.outTime);
  226.    }
  227.    @Override
  228.    public String read(final String terminator,int timeout) throws Exception {
  229.       return this.read(new StringResponseEndChecker() {
  231.          @Override
  232.          public boolean isResponseEnd(StringBuffer data) {
  233.             if (data!=null&&data.toString().trim().endsWith(terminator)) {
  234.                return true;
  235.             }else if(data!=null&&data.toString().trim().endsWith("[Y/N]:")){
  236.                isAutoAnswer=true;
  237.                return true;
  238.             }
  239.             return false;
  240.          }
  241.       }, timeout);
  242.    }
  243.    public boolean isOpen(){
  244.       return this.isOpen;
  245.    }
  246.    @Override
  247.    public void setCharsetName(String charsetName) {
  248.       if(charsetName!=null)
  249.          this.charsetName=charsetName;
  250.    }
  251.    @Override
  252.    public String getUsername() {
  254.       return this.userName;
  255.    }
  257.    @Override
  258.    public String getPassword() {
  260.       return this.pwd;
  261.    }
  263.    @Override
  264.    public String getNeName() {
  266.       return this.neName;
  267.    }
  268.    /** * 清空接受 */ private void clearReadBuffer() {
  269.       BufferedReader br = null;
  270.       try {
  271.          if (isr!=null) {
  272.             br = new BufferedReader(isr);
  273.             while (br.ready()) {
  274.                br.read();
  275.             }
  276.          }
  277.       } catch (Exception e) {
  278.          log.error("清空read buffer 出现异常", e);
  279.       }
  280.    }
  281.    /** * 命令发送结尾符 * @return */ protected String getTerminalSendPostfix() {
  282.       return "\r\n";
  283.    }
  284.    @Override
  285.    public String read(StringResponseEndChecker checker, long timeout) throws IOException{
  286.       long time = System.currentTimeMillis() + timeout;
  287.       StringBuffer sb = new StringBuffer();
  288.       BufferedReader br = null;
  289.       boolean readed = false;
  290.       boolean isClose=true;//用来判断网络是否正常 true不正常 false正常
  291.       br = new BufferedReader(isr);
  292.       while (System.currentTimeMillis() < time) {
  293.          try {
  294.             if (br.ready()) {
  295.                int brchar = br.read();
  296.                if((32<=brchar&&brchar<=127)||brchar==10||brchar==13) {
  297.                   sb.append((char) brchar);
  298.                }
  299.                readed = true;
  300.                isClose=false;
  301.             } else {
  302.                if ((checker != null) && (readed == true)) {
  303.                   readed = false;
  304.                   if (checker.isResponseEnd(sb))
  305.                      break;
  306.                }
  307.                Thread.sleep(150);
  308.             }
  309.          } catch (InterruptedException e) {
  310.             log.error("读取数据出现异常",e);
  311.          }
  312.       }
  313.       if(isClose&&sb.length()==0){
  314.          this.isOpen=false;
  315.          throw new IOException("网络已经中断.....");
  316.       }
  317.       String temp=sb.toString();
  318. //    temp=temp.substring(temp.indexOf("\n")+1);//删除命令回显
  319.       log.debug(ip+" 接受到的数据为"+temp);
  320.       return temp;
  321.    }
  322.    @Override
  323.    public void setOutTime(int outTime) {
  324.       if(outTime>5000)
  325.          this.outTime = outTime;
  326.    }
  327.    @Override
  328.    public int getOutTime() {
  329.       return outTime;
  330.    }
  332. }
  337. package cn.tisson.ipran.gdcsgcf.driver.client;
  339. public interface ICommandDriver {
  340.    public boolean isAutoAnswer();
  341.    /** * 打开连接 * @param ip telnet ip地址 如127.0.0.1 * @param port telnet 端口号 如23 * @param loginPrompt 用户名输入提示符 如userName： * @param userName 用户名 如who * @param pwdPrompt 输入密码提示符 如Password： * @param pwd 密码 如who * @param commandPrompt 登陆成功提示符 如> * @return 0成功，-1数据可是不对 -2没有接到输入用户名提示符 -3没有接收到密码提示符 -4没有接到登陆成功提示符 -5出现异常 */ public abstract int open(String ip, int port, String loginPrompt,String userName, String pwdPrompt, String pwd,    String commandPrompt,StringBuffer resultBuf);
  342.    /** * 关闭连接 */ public void close();
  343.    /** * 获取登录用户名 * @return */ public String getUsername();
  344.    /** * 获取登录密码 * @return */ public String getPassword();
  345.    /** * 获取网元名称 * @return */ public String getNeName();
  346.    /** * 发送命令 * @param command * @throws Exception */ public void write(String command) throws Exception;
  347.    /** * 发送命令 * @param command * @param terminalSendPostfix \r\n \r * @throws Exception */ public void write(String command,String terminalSendPostfix) throws Exception;
  348.    /** * 接受命令结果 * @return * @throws Exception */ public String read() throws Exception;
  349.    /** * 接受命令结果直到结束 * @param terminator * @return * @throws Exception */ public String read(String terminator)throws Exception;
  350.    /** * 设置字符集 * @param charsetName */ public void setCharsetName(String charsetName);
  351.    /** * @param terminator * @param timeout * @return * @throws Exception */ String read(String terminator, int timeout) throws Exception;
  352.    /** * 返回连接状态 主要是主动关闭 */ public boolean isOpen();
  353.    /** * 设置默认超时时间单位毫秒 * @param outTime */ public void setOutTime(int outTime);
  354.    public int getOutTime();
  355.    String read(StringResponseEndChecker checker, long timeout) throws Exception;
  356. }

发表评论

表情：
评论列表 （有 0 条评论，322人围观）

还没有评论，来说两句吧...

相关阅读

    相关 ssh 别名登陆

    此方法配合ssh 免密码登录 密钥登录可以快速登录服务器 通常我们在 Termianl 下用 ssh 链接远程主机的时候，每次都需要输入一长串的用户名加主机地址，是不是觉得很

    超、凢脫俗超、凢脫俗/ 0 赞/ 301 阅读

    相关 配置ssh免登陆

    \生成ssh免登陆密钥 \进入到我的home目录 cd ~/.ssh   ssh-keygen -t rsa （四个回车） 执行完这个命令后，会生成两个文件id\_r

    冷不防冷不防/ 0 赞/ 485 阅读

    相关 远程登陆ssh

    远程登陆ssh 以下操作需要一个客户端和服务端两个虚拟机来完成。 打开两个虚拟机，可输入“nm-connectiong-editor”来修改ip 示例： 服务端

    傷城~傷城~/ 0 赞/ 558 阅读

    相关 ssh 无密码登陆

    本文引用自：[Linux大神博客的博文][Linux]  SSH无密码登录：只需两个简单步骤 (Linux) 如果你管理一台Linux服务器，那么你就会知道每次SSH登

    比眉伴天荒比眉伴天荒/ 0 赞/ 885 阅读

    相关 ssh登陆

    之前在windows下有putty，xshell，mobaXterm 工具可以选择。 现在用mac，暂时没怎么找到好到软件，直接用ssh好了。 ssh -p 22 user

    喜欢ヅ旅行喜欢ヅ旅行/ 0 赞/ 532 阅读