java编写的局域网聊天工具

import java.io.*; import java.net.*; import java.util.*; //实现了服务端向对各个clients发送信息 //1.2版本解决了关闭多个客户端之一时 服务端报错 public class ChatServer { List<Client> clients=new ArrayList<Client>(); //private Socket skt=null; Client c=null; public static void main(String[] args) { new ChatServer().start(); } public void start() { Socket skt=null; ServerSocket ss=null; boolean started=false; //boolean bConnect=false; try{ ss=new ServerSocket(8888); started=true; //服务器启动 监听端口中 }catch(BindException e) { System.out.println("端口使用中 请关闭相关程序 重新启动服务端"); System.exit(0); }catch(Exception e) { e.printStackTrace(); } try { //started=true; while(started) { skt=ss.accept(); //bConnect=true; System.out.println("A Client Connect!"); System.out.println("a thread run"); c=new Client(skt); new Thread(c).start();//创建新线程 并启动 clients.add(c); } }catch(IOException e) { e.printStackTrace(); } } class Client implements Runnable { private Socket skt; private DataInputStream dis=null; private DataOutputStream dos=null; private InputStream is=null; private boolean bConnect=false; //Client c=new Client(skt); public Client(Socket s) { skt=s; try { is=skt.getInputStream(); dis=new DataInputStream(is); dos=new DataOutputStream(skt.getOutputStream()); bConnect=true; } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void send(String str) { try { dos.writeUTF(str); dos.flush(); //System.out.println(str); }catch(SocketException se) { if(c != null) { clients.remove(c); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void run() { try { while(bConnect) { String str= dis.readUTF(); System.out.println(str); for(int i=0;i<clients.size();i++) { c=clients.get(i); c.send(str); } } }catch(EOFException e) { System.out.println("Client has closed!"); } catch (IOException e) { e.printStackTrace(); }finally{ try { if(dis != null)dis.close(); if(dos != null)dos.close(); if(skt != null)skt.close(); } catch (IOException e) { e.printStackTrace(); } } } } }