基于B/S的多人聊天java程序

package com.server; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.OutputStreamWriter; import java.io.PrintStream; import java.net.Socket; public class serverthread implements Runnable { Socket s; BufferedReader br = null; public serverthread(Socket s) throws Exception { // TODO Auto-generated constructor stub this.s = s; br = new BufferedReader(new InputStreamReader(s.getInputStream())); } @Override public void run() { // TODO Auto-generated method stub String con; while((con = readfromclient())!= null){ try { for(Socket s:myserver.socketlist){ PrintStream ps = new PrintStream(s.getOutputStream()); ps.println(con); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } private String readfromclient(){ try{ return br.readLine(); } catch(Exception e){ myserver.socketlist.remove(s); } return null; } }