团队项目（三）

 1 public class Server {
 2 
 3     public static void main(String[] args) {
 4         // TODO Auto-generated method stub
 5         try {
 6             ServerSocket svr = new ServerSocket(5555);
 7             while (true) {
 8                 Socket s = svr.accept();
 9                 ServerThread ST = new ServerThread(s);
10                 ST.start();
11                 ChatManager.getChatManager().add(ST);
12             }
13         } catch (IOException e) {
14             // TODO Auto-generated catch block
15             e.printStackTrace();
16         }
17 
18     }
19 
20 }

public class ServerThread extends Thread {

    private Socket soc=null;
    public BufferedReader in=null;
    public BufferedWriter out=null;
    public ServerThread(Socket soc) {
        // TODO Auto-generated constructor stub
        this.soc = soc;
    }
    public void out(String msg){
        try {
            out.write(msg);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
    @Override
    public void run() {

        InputStream is=null;
        OutputStream os=null;
        try {
            is=soc.getInputStream();
            os=soc.getOutputStream();
            in=new BufferedReader(new InputStreamReader(is));
            out=new BufferedWriter(new OutputStreamWriter(os));
            System.out.println(soc.getPort());
            ChatManager.getChatManager().threadsVector.add(this);
            out.write("欢迎");
            out.flush();
            while (true) {
                String str = in.readLine();
                ChatManager.getChatManager().pulish(this, str);
                System.out.println(str);
                //System.out.println(ChatManager.getChatManager().threadsVector.size());
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        super.run();
    }

}