怎么添加一个线程，在发送信息的同时，接受信息？

下面的代码能Telnet到远程主机，并执行脚本。但是在执行write(command)时，如果不用for(int i=0;i<800000000;i++);那么程序等不到接收到的数据就退出了。怎么添加个线程，可以在发送信息(out.println)的时候，可以同步接受信息（printresponse）呢？

import org.apache.commons.net.telnet.*;
import java.io.*;

public class TmhTelnet {
	private static TelnetClient tc = null;
	private InputStream in;
	private PrintStream out;

	public static void main(String args[]) {
		new TmhTelnet("192.168.5.55",23,"root","1234");
	}

	public TmhTelnet(String host, int port, String username, String password) {
		byte[] a = new byte[1024];
		if (intconnect(host, port)) {
            write(username);
            write(password);
            write("test.bat");
			closeconnect();
		}
	}

	private void writescript(String filename) {
		try {
			if (new File(filename).exists()) {
				FileReader f = new FileReader(filename);
				BufferedReader reader = new BufferedReader(f);
				String command = "";
				while (command != null) {
					command = reader.readLine();
					write(command);
				}
			}
		} catch (FileNotFoundException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}

	}

	public void write(String command) {
		try {
			//System.out.println("command:>>>>>>>>>" + command);
			out.println(command);
			out.flush();

			// for(int i=0;i<800000000;i++);
			// 应该使用线程同步使程序在接受到对方相应后再执行下一条命令这里使用for循环来模拟对方的相应时间
			printresponse();
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	private boolean intconnect(String host, int port) {
		try {
			tc = new TelnetClient();
			TerminalTypeOptionHandler ttopt = new TerminalTypeOptionHandler(
					"VT220", false, false, true, false);
			EchoOptionHandler echoopt = new EchoOptionHandler(true, false,
					true, false);
			SuppressGAOptionHandler gaopt = new SuppressGAOptionHandler(true,
					true, true, true);
			tc.addOptionHandler(ttopt);
			tc.addOptionHandler(echoopt);
			tc.addOptionHandler(gaopt);
			tc.connect(host, port);
			in = tc.getInputStream();
			out = new PrintStream(tc.getOutputStream());
			return true;
		} catch (Exception e) {
			e.printStackTrace();
			try {
				tc.disconnect();
				in.close();
				out.close();
			} catch (IOException e1) {
				// TODO Auto-generated catch block
				e1.printStackTrace();
			}
			return false;
		}
	}

	private void closeconnect() {
		try {
			tc.disconnect();
			in.close();
			// out.close();
		} catch (IOException e1) {
			// TODO Auto-generated catch block
			e1.printStackTrace();
		}
	}

	private String printresponse() {
		try {
			byte[] buff = new byte[1024];
			int ret_read = 0;
			do {
				ret_read = in.read(buff);
				String a = new String(buff, 0, ret_read);
				if (a.endsWith(": ") | a.endsWith(">") | a.endsWith("]")) {
					System.out.print(a);
					return null;
				}
			} while (ret_read >= 0);
		} catch (Exception e) {
			System.err.println("Exception while reading socket:"
					+ e.getMessage());
		}
		try {
			tc.disconnect();
		} catch (Exception e) {
			System.err.println("Exception while closing telnet:"
					+ e.getMessage());
		}
		return null;
	}

}

4 个解决方案

#1

2个线程一个接受信息一个发送信息

#2

能大概写一个架构吗？我自己写的总出问题，多谢！

#3

该回复于2012-09-07 11:19:54被版主删除

#4

问题还没解决~~~~~
问题还没解决~~~~~
问题还没解决~~~~~
问题还没解决~~~~~