readthread.java

本代码用java实现

package bookCase;


import java.net.*;
import java.io.*;
import javax.swing.JTextArea;



public class ReadThread extends Thread {
	Socket ssocket=null;
	JTextArea ta;
	BufferedReader dis;
	int clientnum;
	public ReadThread(JTextArea area, BufferedReader stream,Socket socket,int num) {
		ta=area;
		dis=stream;
		ssocket=socket;
		clientnum=num+1;
	}

	public void run() {
		try {
			//输入流
			//BufferedReader dis=new BufferedReader(new InputStreamReader(ssocket.getInputStream()));
			//输出流
			//PrintWriter out=new PrintWriter(ssocket.getOutputStream());
			//输出客户端输入的信息
			ta.append("对方说："+dis.readLine());
			ta.append("\n");
			//关闭输入流
			dis.close();
			//关闭socket
			ssocket.close();
		} catch (IOException e) {
			e.printStackTrace();
			System.out.println("连接中断");
		}
	}
}