chatserver.java

JAVA程序设计《Java课程设计》很不错的综合实验.为网络聊天室（BS模式）

package feng;
import java.io.*;
import java.net.*;
import java.util.*;
public class ChatServer
{
  public static void main(String args[])
    {
     ServerSocket server=null;
     Socket you=null;
     Hashtable peopleList;
     peopleList=new Hashtable();
     while(true)
            {
             try
                  {
                    server=new ServerSocket(6666);
                  }
             catch(IOException e1)
                  {
                     System.out.println("正在监听");
                  }
             try  {
                     you=server.accept();
                     InetAddress address=you.getInetAddress();
                     System.out.println("用户的IP:"+address);

                  }
             catch (IOException e)
                  {
                  }
             if(you!=null)
                  {
                     Server_thread peopleThread=new Server_thread(you,peopleList);
                     peopleThread.start();
                  }
             else {
                    continue;
                  }
           }
  }
}
class Server_thread extends Thread
{
   String name=null,sex=null;
   Socket socket=null;
   File file=null;
   DataOutputStream out=null;
   DataInputStream  in=null;
   Hashtable peopleList=null;
   Server_thread(Socket t,Hashtable list)
       {
         peopleList=list;
         socket=t;
         try {
               in=new DataInputStream(socket.getInputStream());
               out=new DataOutputStream(socket.getOutputStream());
             }
         catch (IOException e)
             {
             }
        }
 public void run()
  {

     while(true)
      {    String s=null;
        try
           {
            s=in.readUTF();
            if(s.startsWith("姓名:"))
              {
                name=s.substring(s.indexOf(":")+1,s.indexOf("性别"));
                sex=s.substring(s.lastIndexOf(":")+1);


                boolean boo=peopleList.containsKey(name);
                if(boo==false)
                  {
                    peopleList.put(name,this);
                    out.writeUTF("可以聊天:");
                    Enumeration enum=peopleList.elements();
                     while(enum.hasMoreElements())
                     {
                       Server_thread th=(Server_thread)enum.nextElement();
                       th.out.writeUTF("聊天者:"+name+"性别"+sex);


                       if(th!=this)
                         {
                           out.writeUTF("聊天者:"+th.name+"性别"+th.sex);
                         }
                     }

                  }
                else
                  {
                    out.writeUTF("不可以聊天:");
                  }
              }
            else if(s.startsWith("公共聊天内容:"))
              {
                 String message=s.substring(s.indexOf(":")+1);
                 Enumeration enum=peopleList.elements();
                 while(enum.hasMoreElements())
                     {
                       ((Server_thread)enum.nextElement()).out.writeUTF("聊天内容:"+message);
                     }
              }

            else if(s.startsWith("用户离开:"))
              {
                 Enumeration enum=peopleList.elements();
                 while(enum.hasMoreElements())
                   { try
                     {
                        Server_thread th=(Server_thread)enum.nextElement();
                        if(th!=this&&th.isAlive())
                         {
                           th.out.writeUTF("用户离线:"+name);
                         }
                     }
                   catch(IOException eee)
                     {
                     }
                   }
                peopleList.remove(name);
                socket.close();
                System.out.println(name+"用户离开了");
                break;
              }
            else if(s.startsWith("私人聊天内容:"))
              {
                 String 悄悄话=s.substring(s.indexOf(":")+1,s.indexOf("#"));
                 String toPeople=s.substring(s.indexOf("#")+1);

                 Server_thread toThread=(Server_thread)peopleList.get(toPeople);
                 if(toThread!=null)
                   {
                    toThread.out.writeUTF("私人聊天内容:"+悄悄话);
                   }
                 else
                   {
                     out.writeUTF("私人聊天内容:"+toPeople+"已经离线");
                   }
              }
           }
       catch(IOException ee)
           {
               Enumeration enum=peopleList.elements();
                 while(enum.hasMoreElements())
                   { try
                     {
                        Server_thread th=(Server_thread)enum.nextElement();
                        if(th!=this&&th.isAlive())
                         {
                           th.out.writeUTF("用户离线:"+name);
                         }
                     }
                   catch(IOException eee)
                     {
                     }
                   }
                peopleList.remove(name);
                 try
                    {
                      socket.close();
                    }
                catch(IOException eee)
                    {
                    }

              System.out.println(name+"用户离开了");
              break;
           }
     }
  }
}