inetreadthread.java

来自「Security Java Chat. This is security sim」· Java 代码 · 共 26 行

package sjc;
import java.io.*;
public class InetReadThread extends Thread {
	private InputStream inet;
	private OutputStream console;
	private BufferedReader c= new BufferedReader(new InputStreamReader(System.in));
	public InetReadThread(InputStream in, OutputStream out) {
		inet =in;
		console =out;
	}
	public void run() {
		try {
			int input = -1;
			while (!isInterrupted()) {
				input = inet.read();
				console.write(input);
				console.flush();
			}
		} catch (IOException e) {
			e.printStackTrace();
			System.out.println("Connection terminated");
			System.exit(0);
		}
	}
}