readthread.java

j2se项目网络聊天无界面版 cs模式

package Talk_Net;

import java.io.BufferedReader;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;

public class ReadThread implements Runnable {
	private InputStream in;

	public ReadThread(InputStream in) {
		this.in = in;
	}

	public void start() {
		new Thread(this).start();
	}

	public void run() {
		DataInputStream dis = new DataInputStream(in);
		while (true) {
			try {
				System.out.println(dis.readUTF());
				Thread.sleep(100);
			} catch (Exception e) {
			}
		}
	}

}

class WriteThread implements Runnable {
	private OutputStream out;

	public WriteThread(OutputStream out) {
		this.out = out;
	}

	public void start() {
		new Thread(this).start();
	}

	public void run() {
		DataOutputStream dos = new DataOutputStream(out);
		while (true) {
			BufferedReader br = new BufferedReader(new InputStreamReader(
					System.in));
			try {
				dos.writeUTF(br.readLine());
				Thread.sleep(100);
			} catch (Exception e) {
				e.printStackTrace();
			}
		}

	}

}