java实现telnet 使用java实现telnet-client工具分享
人气:0telnet-client太费尽了，比ssh-client费尽的多，搞了一天，凑合能用，还得改。
org.apache.commons.net.telnet.TelnetClien --使用了apache的commons-net包，commons-net-3.0.1-bin.zip。
package org.sl.util;
import org.apache.commons.net.telnet.TelnetClient;
import java.io.*;
import java.nio.ByteBuffer;
public class TelnetUtil {
String charset = null;
byte[] buff = new byte[2048];
TelnetClient telnetClient = new TelnetClient();
BufferedReader telnetReader = null;
BufferedWriter telnetWirter = null;
InputStream telnetIn = null;
OutputStream telnetOut = null;
public TelnetUtil() {
telnetClient = new TelnetClient();
}
/**
* 连接至服务器
* @param ip
* @param port
* @throws UnsupportedEncodingException
* @throws IOException
*/
public void connect(String ip, int port) throws UnsupportedEncodingException,IOException {
telnetClient.connect(ip,port);
setIOStream();
}
/**
* 连接至服务器
* @param ip
* @throws UnsupportedEncodingException
* @throws IOException
*/
public void connect(String ip) throws UnsupportedEncodingException,IOException {
telnetClient.connect(ip);
setIOStream();
}
void setIOStream() throws UnsupportedEncodingException {
telnetIn = telnetClient.getInputStream();
telnetOut = telnetClient.getOutputStream();
if(null==charset){
telnetReader = new BufferedReader(new InputStreamReader(telnetIn));
telnetWirter = new BufferedWriter(new OutputStreamWriter(telnetOut));
}else{
telnetReader = new BufferedReader(new InputStreamReader(telnetIn, charset));
telnetWirter = new BufferedWriter(new OutputStreamWriter(telnetOut, charset));
}
}
/**
* 登录
* @param user
* @param passwd
* @return 是否登录成功.
* @throws IOException
*/
public boolean login(String user,String passwd) throws IOException {
String read = readString();
for(int i=0; ; i++){
if(-1==read.indexOf("login")){
read = readString();
}else{
break;
}
}
writeText(user);
read = readString();
for(int i=0; ; i++){
if(-1==read.indexOf("Password")){
read = readString();
}else{
break;
}
}
writeText(passwd);
for(;;){
read = readString();
//System.out.println("last:"+read);
if(-1!=read.indexOf("Last")){
return true;
}else if(-1!=read.indexOf("incorrect")){
return false;
}
}
}
/**
* 这是一个测试方法,随便写。
* @throws IOException
*/
public void show() throws IOException {
// System.out.println(readString());
// System.out.println(readString());
// ByteBuffer tmp = ByteBuffer.allocate(1024);
// byte[] buff = new byte[1024];
// while(telnetIn.available()>0){
// int readLen = readBytes(buff,0,1024);
// tmp.put(buff,0,readLen);
// }
// System.out.println(new String(tmp.array()));
System.out.println("1 "+readString());
System.out.println("2 "+readString());
System.out.println("3 "+readString());
writeText("root");
System.out.println("4 " + readString());
writeText("123456");
System.out.println("5 "+readString());
// System.out.println("6 "+readString());
// System.out.println("7 "+readString());
}
public int readBytes(byte[] buff, int offset, int len) throws IOException {
return telnetIn.read(buff,offset,len);
}
/**
* 读取字符串<br/>
* 相当于readByte()转为字符串
* @return
* @throws IOException
*/
public String readString() throws IOException {
int readLen = readBytes(this.buff, 0, this.buff.length);
if(0<readLen)
return new String(buff,0,readLen).trim();
else
return "";
}
/**
* 读取一行<br/>
* 如果服务器与客户端不是同一种操作系统，可能导致此方法计行失败。
* @return
* @throws IOException
*/
public String readLine() throws IOException {
String read = telnetReader.readLine();
return null==read?"":read.trim();
}
public void writeBytes(byte[] buff, int offset, int len) throws IOException {
telnetOut.write(buff,offset,len);
}
/**
* 向服务器写字符串
* @param text
* @throws IOException
*/
public void writeText(String text) throws IOException {
telnetWirter.write(text);
telnetWirter.write('\r');
telnetWirter.write('\n');
telnetWirter.flush();
}
/**
* 执行命令，并返回结果<br/>
* 相当于: <br>
* writeText(); <br/>
* return readString();
* @param cmd
* @return
* @throws IOException
*/
public String exec(String cmd) throws IOException {
writeText(cmd);
return readString();
}
String login1(String user,String passwd) throws IOException {
String read = null;
readString();
readString();
read = readString();
if(-1!=read.indexOf("login")){
writeText(user);
}
read = readString();
if(-1!=read.indexOf("Password")){
writeText(passwd);
}
read = readString();
read += readString();
return read;
// StringBuffer sb = new StringBuffer();
// while(null!= (read = readString())){
// sb.append(read);
// }
//
// return sb.toString();
}
/**
* 关闭
*/
public void close(){
try{
writeText("exit");
writeText("exit");
writeText("exit");
}catch(Exception ex){
}
try {
if(null!=telnetIn) telnetIn.close();
} catch (Exception e) {
}
try {
if(null!=telnetOut) telnetOut.close();
} catch (Exception e) {
}
try {
if(null!=telnetClient)telnetClient.disconnect();
} catch (Exception e) {
}
}
/**
* 设置telnet通信时的字符集<br/>
* 注:此字符集与服务器端字符集没有必然关系<br/>
* 此方法需在connect()前调用
* @param charset
*/
public void setCharset(String charset ){
this.charset = charset;
}
/**
* 重新设置buff大小,默认为2048字节.
* @param size
*/
public void setBufferSize(int size){
this.buff = new byte[size];
}
}
测试类
static void t4(){
TelnetUtil tu = new TelnetUtil();
try {
tu.connect("192.168.2.154");
System.out.println(tu.login("root", "123456"));
//tu.show();
//System.out.println(tu.readString());
//System.out.println(tu.exec("pwd"));
System.out.println(tu.exec("echo \"123456789\">1.txt"));
System.out.println(tu.exec("cat 1.txt"));
} catch (IOException e) {
e.printStackTrace();
}
tu.close();
}
static void t1(){
TelnetUtil tu = new TelnetUtil();
try {
tu.connect("192.168.2.154");
System.out.println(tu.login("sl1", "coffee8215"));
//tu.show();
//System.out.println(tu.readString());
System.out.println(tu.exec("pwd"));
} catch (IOException e) {
e.printStackTrace();
}
tu.close();
}
加载全部内容