简易QQ聊天系统java版

package com; import java.io.IOException; import java.net.*; import java.io.*; public class ChatServer { boolean started = false; ServerSocket ss =null; public static void main(String[] args){ new ChatServer().start(); } public void start(){ //Socket s = null; DataInputStream dis = null; try{ ss = new ServerSocket(8888); started = true; }catch(BindException e){ System.out.println("端口使用中~~~~"); System.out.println("请关掉相关程序并重新运行服务器"); System.exit(0); } catch(IOException e){ e.printStackTrace(); } try{ while(started){ Socket s = ss.accept(); Client c = new Client(s); System.out.println("服务器输出，一个客户端连接了服务器"); new Thread(c).start(); //dis.close(); } }catch(IOException e){ e.printStackTrace(); } finally{ try { ss.close(); } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } class Client implements Runnable{ private Socket s; private DataInputStream dis = null; private boolean bConnected = false; public Client (Socket s){ this.s = s; try { dis = new DataInputStream(s.getInputStream()); bConnected = true; } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public void run(){ try{ while(bConnected){ String str = dis.readUTF(); System.out.println(str); } }catch(IOException e){ e.printStackTrace(); } finally{ try{ if(dis != null)dis.close(); if (s != null) s.close(); }catch(IOException e1){ e1.printStackTrace(); } } } } }