Telnet協議的實現

Telnet協議詳解

rfc854.txt

java簡單實現telnet協議（關鍵在於需解析telnet協議裏的選項協商）

這裏給你們推薦個網站，上面有各網絡協議的中文版本，好比下面是Telnet協議和Socks V5協議

TELNET: http://www.cnpaf.net/rfc/rfc854.txt

SOCKS V5: http://www.cnpaf.net/rfc/rfc1928.txt

 

如下代碼來自（http://shenxueliang.iteye.com/blog/1184553）

package telnet;
 
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
 
 
/**
 * Telnet簡單實現
 * 
 * @author xueliang 2010.11.6
 * 
 */
public class Telnet {
	private static final byte SB = (byte) 250;// 子選項開始
	private static final byte SE = (byte) 240;// 子選項結束
	private static final byte WILL = (byte) 251;// 選項協商
	private static final byte WONT = (byte) 252;// 選項協商
	private static final byte DO = (byte) 253;// 選項協商
	private static final byte DONT = (byte) 254;// 選項協商
	private static final byte IAC = (byte) 255;// 數據字節255
	private static final byte ECHO = (byte) 1;// 回顯
	private static final byte IS = (byte) 0;// 是
	private static final byte SUPPRESS = (byte) 3;// 抑制繼續進行
	private static final byte TT = (byte) 24;// 終端類型
	private InputStream is;
	private OutputStream os;
	private Socket client;
	private byte[] readBuffer = new byte[1024];
 
	/**
	 * 打開telnet鏈接
	 * @param ip
	 * @param port 23
	 * @return
	 * @throws CmdException 
	 */
	public Telnet(String ip){
		this(ip, 23);
	}
 
	/**
	 * 打開telnet鏈接
	 * @param ip
	 * @param port
	 * @return
	 * @throws CmdException 
	 */
	public Telnet(String ip, int port){
		try {
			client = new Socket(ip, port);
			client.setSoTimeout(5000);//設置is的read方法阻塞時間爲5秒
			is = client.getInputStream();
			os = client.getOutputStream();
		} catch (Exception e) {
			this.close();
		} 
	}
	/**
	 * 讀取回顯，並進行telnet協商
	 * @return
	 * @throws IOException
	 */
	public String recieveEcho() throws IOException {
		int len = is.read(this.readBuffer);
		if(is.available() == 0)
			return "";
		ArrayList<Byte> bsList = new ArrayList<Byte>();
		ArrayList<Byte> cmdList = new ArrayList<Byte>();
		for (int i = 0; i < len; i++) {
			int b = this.readBuffer[i] & 0xff;//&0xff是爲了防止byte的255溢出,java中byte的取值是-128~127
			
if (b != 255) {//沒有協商要求
				if (b == '\n' || b == '\0') {// NVT中行結束符以'\r\n'表示，回車以'\r\0表示'
					continue;
				}
				bsList.add((byte) b);
				continue;
			}
			cmdList.add(IAC); 
			switch (this.readBuffer[++i] & 0xff) {
			case 251:// 服務器想激活某選項
				if ((readBuffer[++i] & 0xff) == 1) {// 贊成回顯
					cmdList.add(DO);
					cmdList.add(ECHO);
				} else if ((readBuffer[i] & 0xff) == 3) {// 贊成抑制繼續執行
					cmdList.add(DO);
					cmdList.add(SUPPRESS);
					// cmdList.add(GA);
				} else {// 不一樣意其餘類型協商
					cmdList.add(DONT);
					cmdList.add(readBuffer[i]);
				}
				break;
			case 253:// 服務器想讓客戶端發起激活某選項
				if ((readBuffer[++i] & 0xff) == 24) {// 終端類型
					cmdList.add(WONT);// 贊成激活終端類型協商
					cmdList.add(TT);
				} else if ((readBuffer[i] & 0xff) == 1) {
					cmdList.add(WILL);
					cmdList.add(ECHO);
				} else {
					cmdList.add(WONT);// 不一樣意其餘類型協商
					cmdList.add(readBuffer[i]);
				}
				break;
			case 250:// 子選項開始
				cmdList.add(SB);
				if ((readBuffer[++i] & 0xff) == 24
						&& (readBuffer[++i] & 0xff) == 1) {// 發送你的終端類型
					cmdList.add(TT);
					cmdList.add(IS);// 個人終端類型是
					cmdList.add((byte) 'V');
					cmdList.add((byte) 'T');
					cmdList.add((byte) '1');
					cmdList.add((byte) '0');
					cmdList.add((byte) '0');
				}
				break;
			case 240:// 子選項結束
				cmdList.add(SE);
				break;
			case 252:// 必須贊成
				cmdList.add(DONT);
				cmdList.add(readBuffer[++i]);
				break;
			case 254:// 必須贊成
				cmdList.add(WONT);
				cmdList.add(readBuffer[++i]);
				break;
			}
		}
		// 若是有協商則向服務端發送協商選項
		if (cmdList.size() > 0) {
			byte[] writeBuffer = new byte[cmdList.size()];
			for (int i = 0; i < cmdList.size(); i++) {
				writeBuffer[i] = cmdList.get(i);
			}
			os.write(writeBuffer);
		}
		// 組織回顯字符
		int size = bsList.size();
		String str = "";
		if (size > 0) {
			byte[] bs = new byte[size];
			for (int i = 0; i < size; i++) {
				bs[i] = bsList.get(i).byteValue();
			}
			str = new String(bs, "gbk");
		}
		// 如下測試時打開
		// System.out.print("read===== ");
		// for (int i = 0; i < len; i++) {
		// System.out.print(readBuffer[i]&0xff);
		// System.out.print(" ");
		// }
		// System.out.println();
		// if(cmdList.size()>0){
		// System.out.print("write==== ");
		// for (int i = 0; i < cmdList.size(); i++) {
		// System.out.print(cmdList.get(i) & 0xff);
		// System.out.print(" ");
		// }
		// System.out.println();
		// }
		return str;
	}
 
	/**
	 * 直接發送命令，不發送回車鍵
	 * @param cmd
	 */
	public void sendWithoutCR(String cmd) {
		try {
			os.write(cmd.getBytes());
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
	
	/**
	 * 命令中不要包括回車、換行
	 * @param cmd
	 */
	public void sendCmd(String cmd) {
		cmd += "\r\0";
		try {
			os.write(cmd.getBytes());
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
 
	/**
	 * 按字節發送命令，數組中不要包括回車、換行
	 * @param cmd
	 */
	public void sendCmd(List<Byte> cmdList) {
		if(cmdList == null)return;
		int size = cmdList.size();
		byte[] send = null;
		if(cmdList.get(size-1) == '\r'){
			send = new byte[size+1];
			send[size] = '\0';
		}else{
			send = new byte[size];
		}
		for (int i = 0; i < size; i++) {
			send[i] = cmdList.get(i);
		}
		try {
			os.write(send);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
 
	/**
	 * 關閉telnet鏈接
	 */
	public void close() {
		if (is != null) {
			try {
				is.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		if (os != null) {
			try {
				os.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		if (client != null) {
			try {
				client.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
	
	/**
	 * 讀取指望值，使用默認超時時間15秒
	 * @param keyWords
	 * @return
	 */
	public String readKeyWords(String... keyWords){
		return this.readKeyWords(15000, keyWords);
	}
	/**
	 * 讀取指望值
	 * @param timeOut 超時時間
	 * @param keyWords
	 * @return
	 * @throws CmdException 
	 */
	public String readKeyWords(long timeOut,String... keyWords){
		String rv = "";
		long nextTime = 0;
		long endTime = System.currentTimeMillis() + timeOut;
		do {
			try{
				String _rv = this.recieveEcho();
				rv += _rv;
			}catch(IOException e){
				nextTime = endTime - System.currentTimeMillis() ;
			}
		} while (!this.findKeyWord(keyWords, rv) && nextTime >= 0);
		if(nextTime < 0)
			System.err.println("Read TimeOut...Echo:\n"+rv);
		return rv;
	}
	
	/**
	 * 查找關鍵字
	 * @param keyWords
	 * @param str
	 * @return
	 */
	private boolean findKeyWord(String[] keyWords,String str){
		if(keyWords == null || str == null)return false;
		for (int i = 0; i < keyWords.length; i++) {
			if(str.indexOf(keyWords[i]) != -1)
				return true;
		}
		return false;
	}
	public static void main(String[] args) {
		Telnet telnet = new Telnet("10.110.111.193");
		String str = telnet.readKeyWords(":");
		System.out.println(str);
		telnet.sendCmd("boco");
		str = telnet.readKeyWords(":");
		telnet.sendCmd("Ab123456");
		str = telnet.readKeyWords("$");
		System.out.println(str);
		telnet.sendCmd("ls");
		str = telnet.readKeyWords(10000,"$");
		System.out.println(str);
		telnet.close();
	}
}