demothread.java

自编的聊天服务器端

package pentium;

import java.net.*;
import java.io.*;
import java.util.*;
public class DemoThread extends Thread{
	Socket s;
	ArrayList<Socket> l;
public DemoThread(Socket s, ArrayList<Socket> l) {
	this.s = s;
	this.l = l;
}
public void run(){
	try{
	PrintStream ps = new PrintStream(s.getOutputStream());
	BufferedReader br = new BufferedReader(new InputStreamReader
			(s.getInputStream()));

	boolean flag = true;

	while (flag) {

		ps.println("Server:hello welcome" + new Date());
		String str = br.readLine();
		System.out.println("Client:[" + s + "]" + str);
		for(int i = 0;i < l.size();i++){
			Socket sock = l.get(i);
			PrintStream psm = new PrintStream(sock.getOutputStream());
			psm.println("----:" + str);
		}
	}
	ps.close();
	s.close();
	}catch (IOException e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	}
}
}