server.java~9~

来自「这是一本关于高级软件工程的书籍」· JAVA~9~ 代码 · 共 116 行

package qqclient;
import java.io.*;
import java.net.*;
import java.util.*;
public class Server {


    public Server(){
    }
    public static void main(String[] args) {
        Hashtable ht=new Hashtable();
        try{
                        ServerSocket ss=new ServerSocket(8080);
                        int num=0;
                        while(true){
                                Socket s=ss.accept();
                                String username=""+num;num++;
                                ht.put(username,s);
                                new ServerInputThread(s.getInputStream(),username,ht).start();
                                System.out.println(username+"已登陆");

                        }
                }catch(Exception e){System.out.println(e);}

    }
}




//服务器输入流线程
class ServerInputThread extends Thread{
        InputStream in;

        String ren;
        public ServerInputThread(InputStream in,String tmpusername,Hashtable ht){
            this.in = in;
            this.ren = tmpusername;
            Ssend.send=new send(ht);
        }

        public void run(){
                BufferedReader bf=new BufferedReader(new InputStreamReader(in));
                try{
                        while(true){
                                String str=bf.readLine();
                                System.out.println(str);
                                String cxiaoxi=str.substring(0,str.indexOf(":"));
                                System.out.println(cxiaoxi);
                                if(cxiaoxi.equals("CLogin")){
                                    Ssend.send.sendOne(ren,"SOneLong:");
                                    System.out.println("------------------");
                                    Ssend.send.sendAll("SAllLogin:"+ren);
                                }
                                if(cxiaoxi.equals("COne")){
                                    String s1=str.substring(str.indexOf(":")+1);
                                    String s2=s1.substring(s1.indexOf("="));
                                    String s3=s1.substring(s1.indexOf("=")+1);
                                    String s4=s2.substring(s2.indexOf("-"));
                                    String s5=s2.substring(s2.indexOf("-")+1);
                                    Ssend.send.sendOne(s5,"SOne:"+s4+">"+s3);
                                }
                                if(cxiaoxi.equals("CAll")){
                                    String s1=str.substring(str.indexOf(":")+1);
                                    String s2=s1.substring(s1.indexOf("="));
                                    String s3=s1.substring(s1.indexOf("=")+1);
                                    String s4=s2.substring(s2.indexOf("-"));
                                    String s5=s2.substring(s2.indexOf("-")+1);
                                    Ssend.send.sendAll("SAll:"+s4+">"+s3);

                                }
                        }

                }catch(Exception e){System.out.println(e);}
        }

}
class send{
    Hashtable ht;
    public send(Hashtable ht){
        this.ht=ht;
    }

           public void sendOne(String username,String message){
                    Socket s=(Socket)ht.get(username);
                    if(s==null){
                            System.out.println("socket为空");
                    }
                    else{
                            try{
                                    PrintWriter pw=new PrintWriter(s.getOutputStream(),true);
                                    pw.println(username+"="+message);
                                    System.out.println(username+"="+message);
                            }catch(Exception e){System.out.println(e);}

                    }

            }
            public void sendAll(String message){
                    Enumeration em=ht.keys();
                    try{
                            while(em.hasMoreElements()){
                            String name=(String)em.nextElement();

                                            Socket socket=(Socket)ht.get(name);
                                            PrintWriter pw=new PrintWriter(socket.getOutputStream(),true);
                                            pw.println("="+message);

                            }
		}catch(Exception e){System.out.println(e);}
  }
}
class Ssend{
    public static send send;
}