Java使用telnet连接远程计算机执行命令

Java使用telnet连接远程计算机执行命令所需的jar包 http://commons.apache.org/proper/commons-net/如题，代码如下：package securecrt.ssh2;import java.io.IOException;
import java.io.InputStream;
import java.io.PrintStream;
import java.io.UnsupportedEncodingException;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.List;import org.apache.commons.net.telnet.TelnetClient;/**
*
* 使用java连接telnet进行操作的注意
1.telnet有VT100 VT52 VT220 VTNT ANSI等协议。
我用vt100。
2.vt100控制码（ansi控制码）过滤的问题,可以过滤，也可以在服务设置不要。
不过滤都是一些乱码。是以33[***一个字母结尾的格式。
3.中文乱码的问题。
new String（old.getBytes（"ISO8859-1"）,"GBK"）。
4.如何判断读取到最后了。
一有readUntil（）,二有使用线程。
5.选择telnet的java包问题，包有很多，比如appache（commons-net-3.1.jar）, ganymed（ganymed-ssh2-build210.jar）,javaexpect（smart-0.1-SNAPSHOT-jar-with-dependencies.jar）
我使用appache。javaexpect有带的vt100控制码过滤，我没有仔细研究。
6.write要flush（）才发送。
*
*
* telnet操作类。使用appache的net.Telnet包，对vt100控制代码（即ansi控制码）进行简单过滤。
*
* @author chruan
* @version 1.0
*/
public class TelnetHelper_bak {
Object lock = new Object（）;
TelnetClient telnet = null;
String hostname;
int hostport = 23;
String user;
String password;
private InputStream in;
private PrintStream out;
private static final String ORIG_CODEC = "ISO8859-1";
private static final String TRANSLATE_CODEC = "GBK";   public TelnetHelper_bak（String hostname, int hostport, String user,
String password） throws SocketException, IOException {
super（）;
this.hostname = hostname;
this.hostport = hostport;
this.user = user;
this.password = password;   telnet = new TelnetClient（"VT100"）;// VT100 VT52 VT220 VTNT ANSI
telnet.connect（hostname, hostport）;
in = telnet.getInputStream（）;
out = new PrintStream（telnet.getOutputStream（））;   readUntil（"login: "）;
write（user）;
write（" "）;
readUntil（"Password: "）;
write（password）;
write（" "）;
}    private void restartTerminal（） {
try {
readUntil（">"）;
write（"telnet 0.0.7.74 "）;
readUntil（"login: "）;
write（"dd ", 500）;
readToEnd（）;   write（"dff ", 200）;
readToEnd（）;   } catch （Exception e） {
e.printStackTrace（）;
} finally {   }
}    public void readToEnd（） {
ReadThread readThread = new ReadThread（）;
readThread.start（）;
try {
readThread.join（）;
} catch （Exception e） {
}
readThread = null;
}   public void readUntil（String str） {
char last = str.charAt（str.length（） - 1）;
String[] ss;
try {
StringBuffer sb = new StringBuffer（）;
char c;
int code = -1;
boolean ansiControl = false;
boolean start = true;
while （（code = （in.read（）））！= -1） {
c = （char） code;
if （c == "33"） {//vt100控制码都是以33开头的。
ansiControl = true;
int code2 = in.read（）;
char cc = （char） code2;
if （cc == "[" || cc == "（"） {
}
}
if （！ansiControl） {
if （c == " "） {
//这里是命令行中的每一句反馈
String olds = new String（sb.toString（）.getBytes（
ORIG_CODEC）, TRANSLATE_CODEC）;
System.out.println（olds）;
if （sb.lastIndexOf（str）！= -1） {
break;
}
sb.delete（0, sb.length（））;
} else if （c == " "）
;
else
sb.append（c）;
if （sb.lastIndexOf（str）！= -1） {
break;
}
}   if （ansiControl） {
if （（"a" <= c && c <= "z"） || （"A" <= c && c <= "Z"）
|| c == """） {
ansiControl = false;
}
}
}
System.out.println（new String（sb.toString（）.getBytes（ORIG_CODEC）,
TRANSLATE_CODEC））;
} catch （Exception e） {
e.printStackTrace（）;
}
}   public void write（String s） {
try {
out.write（s.getBytes（））;
out.flush（）;
System.out.println（s）;
} catch （Exception e） {
}
}   public void write（String s, int sleep） {
write（s）;
try {
Thread.sleep（sleep）;
} catch （Exception e） {
}
}
/**
* 完成之后必须关闭
*/
public void close（） {
if （out ！= null）
out.close（）;
if （in ！= null）
try {
in.close（）;
} catch （IOException e1） {
}
if （telnet ！= null）
try {
telnet.disconnect（）;
} catch （IOException e） {
}
} public void doJob（） {
// restartTerminal（）;
counter（）;
}
private void counter（） {
//演示在一台机器上远程登录另一台计算机
try {
readUntil（"bash-2.05b$ "）;
write（"ssh loc@192.168.0.1 "）;
readUntil（"loc@192.168.0.1"s password: "）;
write（"nodee "）;
readUntil（"[nodee@dz-05 ~]$ "）;
write（"ll "）;
readToEnd（）;    } catch （Exception e） {
e.printStackTrace（）;
} finally {   }
}
public static void main（String[] args） {
String hostname = "192.168.0.2";
int hostport = 23;
String user = "username";
String password = "pwd";
TelnetHelper_bak helper = null;
try {
helper = new TelnetHelper_bak（hostname, hostport, user, password）;
helper.doJob（）;   } catch （Exception e） {
e.printStackTrace（）;
} finally {
if （helper ！= null）
helper.close（）;
}
}   /**
* 读取主线程，负责管理子线程。防止读取时不动了，这时就抛弃读取子线程
*
*/
class ReadThread extends Thread {
public void run（） {
synchronized （lock） {//只能一个读取
SubReadThread sub = new SubReadThread（）;
sub.start（）;
int last = sub.count;
while （true） {
try {
Thread.sleep（100）;
} catch （InterruptedException e） {
}
if （last == sub.count） {
sub.stop（）;
break;
} else {
last = sub.count;
}
}
String s = sub.sb.toString（）;
try {
System.out.println（new String（s.getBytes（ORIG_CODEC）,
TRANSLATE_CODEC））;
} catch （UnsupportedEncodingException e） {
System.out.println（s）;
}
sub = null;
} // System.out.println（"===========ReadThread end============="）;
}
}   /**
* 读取子线程，完成实际读取
*
*/
class SubReadThread extends Thread {
int count = 0;
StringBuffer sb = new StringBuffer（）;   public void read（） {
try {
char c;
int code = -1;
boolean ansiControl = false;
boolean start = true;
while （（code = （in.read（）））！= -1） {
count++;
c = （char） code;
if （c == "33"） {
ansiControl = true;
int code2 = in.read（）;
char cc = （char） code2;
count++;
if （cc == "[" || cc == "（"） {
}
}
if （！ansiControl） {
if （c == " "） {
String olds = new String（sb.toString（）.getBytes（
ORIG_CODEC）, TRANSLATE_CODEC）;
System.out.println（olds）;
sb.delete（0, sb.length（））;
} else if （c == " "）
;
else
sb.append（c）;
}   if （ansiControl） {
if （（"a" <= c && c <= "z"） || （"A" <= c && c <= "Z"）
|| c == """） {
ansiControl = false;
}
}
}
} catch （Exception e） {
}
}   public void run（） {
read（）;
}
}
} 本文永久更新链接地址：http://www.linuxidc.com/Linux/2016-03/129529.htm