chatroomserver.java

一个简单的聊天室：基于Tcp传输的

/*
 * ChatRoomServer.java
 *
 * Created on 2007年10月28日, 下午1:53
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */

package chatroomprogram;

/*
 * ChatRoomServer.java
 *
 * Created on 2007年10月27日, 下午12:47
 *
 * To change this template, choose Tools | Template Manager
 * and open the template in the editor.
 */



import java.net.*;
import java.io.*;
import java.util.*;

public class ChatRoomServer
{
    public static ArrayList<TcpThread> cl=new ArrayList<TcpThread>();
    public static void main(String args[]){
         ServerSocket ss=null;
         Socket socket=null;

        try{
            ss = new ServerSocket(3000);
            while(true){
                socket = ss.accept();
                TcpThread crc=new TcpThread(socket);
                cl.add(crc);
                crc.start();
                System.out.println(socket.getInetAddress()+"   "+cl.size());
                }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            try{
                if(socket != null)socket.close();
                if(ss != null)ss.close();
            }catch(Exception  e){
                e.printStackTrace();
            }
        }
    }
}

class TcpThread extends Thread
{

    private Socket socket;
    public static String data;

        BufferedReader br=null;
         PrintWriter pw = null;
         InputStream is=null;
         InputStreamReader isr=null;
         OutputStream os =null;
        

    public TcpThread(Socket socket){
        this.socket=socket;
    }    
    public void sendMess(){
      
        pw.println(data);
        
    }
    public void run(){
        try{
            is = socket.getInputStream();
            isr = new InputStreamReader(is);
            br = new BufferedReader(isr);
            os = socket.getOutputStream();
            pw = new PrintWriter(os, true);
                                   
            data="  ";
                for(Object ss:ChatRoomServer.cl)
                    ((TcpThread)ss).sendMess();
            while(true){    
            data = br.readLine();
           
            if(data==null)break;
            else if(data!=null){
               
                System.out.println(data);
                for(TcpThread ss:ChatRoomServer.cl)
                    ss.sendMess();
                }
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            try{
                if(br!=null)br.close();
                if(pw!=null)pw.close();
                if(socket!=null)
                    socket.close();
            ChatRoomServer.cl.remove(this);
            System.out.println(socket.getInetAddress().toString()+"client quit\n"
            +"linkings:"+ChatRoomServer.cl.size());
            }catch(Exception e){
                e.printStackTrace();
            }
        }
    }
    
}