1 package Day_1;  2   3 import java.io.DataInputStream;  4 import java.io.DataOutputStream;  5 import java.io.EOFException;  6 import java.io.IOException;  7 import java.net.BindException;  8 import java.net.ServerSocket;  9 import java.net.Socket; 10 import java.util.ArrayList; 11 import java.util.Deque; 12 import java.util.List; 13 import java.util.concurrent.ExecutorService; 14 import java.util.concurrent.Executors; 15    16  17 public class GetPicture { 18      19     /** 20      * @param args 21      * 聊天室有n个人在聊天，聊天服务器就应该为每个进入聊天室的人创建一个对应的线程， 22      * 该线程监听对应的聊天者是否有消息传来。如果有，则向所有的聊天者广播该消息。 23      * 实现该网络聊天系统、 24      */ 25     private boolean started =false; 26     private boolean connect=false; 27     //放置一个链表来存放新建的客户端 28     List<NewClient> list=new ArrayList<NewClient>() ; 29     //设定一个无限制大小的线程池          30     ExecutorService  es = Executors.newCachedThreadPool(); 31     public static  void main(String[] args) { 32         // TODO Auto-generated method stub 33           new GetPicture().start();     34     }     35      36     public void start(){     37         final int port=8888;   38         ServerSocket  ss = null ;     39         try { 40             //创建套接字 41             ss = new ServerSocket(port); 42             connect = true; 43         }catch(BindException e) 44         { 45             //不做任何处理 46         } 47         catch (IOException e) { 48             // TODO Auto-generated catch block 49             e.printStackTrace(); 50         } 51         //如果连接上，则表示不断的创建客户端对象 52         try { 53         while(connect){ 54               //表示不断的监听 55                Socket st =  ss.accept(); 56                //将套接字放进 NewClient类中 57                NewClient nc = new NewClient(st); 58                //将NewClient类放进线程中，创建多线程 59               // new Thread(nc).start();  //创建线程 60                //放进线程池中 61                es.execute(new Thread(nc)); 62                //将newClient放进链表中 63                list.add(nc); 64                System.out.println("客戶端接收成功"); 65             } }catch (IOException e) { 66                 // TODO Auto-generated catch block 67                 e.printStackTrace(); 68             } 69         } 70      71      72  //创建一个新的客户端类 73 class NewClient implements Runnable 74 { 75      DataInputStream   Dis = null; 76      DataOutputStream  Dos = null; 77      Socket sc=null; 78      boolean started=false; //初始断开 79   public NewClient(Socket st){ 80            this.sc=st; 81            try { 82                 //获得对方发过来的缓存数据流 83              Dis = new DataInputStream(st.getInputStream()); 84              Dos = new DataOutputStream(st.getOutputStream()); 85              //如果正常说明，已经接收到了对方的发送过来的数据、 86              started =true; 87         } catch (IOException e) { 88             // TODO Auto-generated catch block 89              e.printStackTrace(); 90         } 91     } 92   public void send(String str) 93   { 94        try { 95            // 将数据写入到对方的内存中 96              Dos.writeUTF(str); 97         } 98        catch(EOFException e){ 99            System.out.println("对方客户端退出了！");100        } catch (IOException e) {101             // TODO Auto-generated catch block102             e.printStackTrace();103         }104   }105   @Override106   public void run() {107      // TODO Auto-generated method stub108       //如果连接上了，就可以提取相应的数据109        String str=null;110        try {111        while(started){112              //采用UTF-8的编码格式进行流的输入输出113                str = Dis.readUTF();114                /*for(int i=0;i<list.size() ;i++){115                  list.get(i).send(str);116                }*/117                for( NewClient sc : list )118                    sc.send(str);119                } 120        }catch(EOFException e){121             //绑定异常，说明退出了122             System.out.println("该客户端退出了!");123         }catch (IOException e) {124             // TODO Auto-generated catch block125             e.printStackTrace();126         }finally{127               //当该线程消亡的时候，给予相应流的关闭128             try {129                  if(Dos!=null)Dos.close();130                  if(Dis!=null)Dis.close();131                  if(sc!=null)sc.close();132                 } catch (IOException e) {133                 // TODO Auto-generated catch block134                 e.printStackTrace();135             }136           }137   } 138 }139 }