线程练习题---简易多人聊天室

package Day_1;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.ConnectException;
import java.net.Socket;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.util.Scanner;

/*
 * 对于聊天室而言，不需要进行单线程进行即可。
 * 和Socket编程
 * */
public class Client {

    private DataInputStream Dis = null;
    private DataOutputStream Dos = null;
    private boolean connect = false;
    Socket sc = null;

    public static void main(String args[]) {
        new Client().start();
    }

    private void send(String str) {
        try {
            Dos.writeUTF(str);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    private void sec() {
        try {
            System.out.println("这是来自服务器：" + sc.getInetAddress() + ": "
                    + Dis.readUTF());
        } catch (EOFException e) {
            System.out.println("该客户端退出了！");
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

    public void start() {
        try {
            // 建立连接
            sc = new Socket("127.0.0.1", 8888);
            Dos = new DataOutputStream(sc.getOutputStream());
            Dis = new DataInputStream(sc.getInputStream());
            connect = true; // 可以开始通话了
        } catch (ConnectException e) {
            System.out.println("服务器，木有打开！");
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        while (connect) {
            Scanner read = new Scanner(System.in);
            while (read.hasNext()) {
                String st = read.next();
                if (st.equals("exit")) {
                    try {
                        if (Dos != null)
                            Dos.close();
                        if (Dis != null)
                            Dis.close();
                        if (sc != null)
                            sc.close();
                    } catch (IOException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                    }
                    connect=false;
                    break;
                }
                this.send(st);
                this.sec();
            }
        }
    }
}

package Day_1;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.EOFException;
import java.io.IOException;
import java.net.BindException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Deque;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
  

public class GetPicture {
    
    /**
     * @param args
     * 聊天室有n个人在聊天，聊天服务器就应该为每个进入聊天室的人创建一个对应的线程，
     * 该线程监听对应的聊天者是否有消息传来。如果有，则向所有的聊天者广播该消息。
     * 实现该网络聊天系统、
     */
    private boolean started =false;
    private boolean connect=false;
    //放置一个链表来存放新建的客户端
    List<NewClient> list=new ArrayList<NewClient>() ;
    //设定一个无限制大小的线程池         
    ExecutorService  es = Executors.newCachedThreadPool();
    public static  void main(String[] args) {
        // TODO Auto-generated method stub
          new GetPicture().start();    
    }    
    
    public void start(){    
        final int port=8888;  
        ServerSocket  ss = null ;    
        try {
            //创建套接字
            ss = new ServerSocket(port);
            connect = true;
        }catch(BindException e)
        {
            //不做任何处理
        }
        catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        //如果连接上，则表示不断的创建客户端对象
        try {
        while(connect){
              //表示不断的监听
               Socket st =  ss.accept();
               //将套接字放进 NewClient类中
               NewClient nc = new NewClient(st);
               //将NewClient类放进线程中，创建多线程
              // new Thread(nc).start();  //创建线程
               //放进线程池中
               es.execute(new Thread(nc));
               //将newClient放进链表中
               list.add(nc);
               System.out.println("客戶端接收成功");
            } }catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        }
    
    
 //创建一个新的客户端类
class NewClient implements Runnable
{
     DataInputStream   Dis = null;
     DataOutputStream  Dos = null;
     Socket sc=null;
     boolean started=false; //初始断开
  public NewClient(Socket st){
           this.sc=st;
           try {
                //获得对方发过来的缓存数据流
             Dis = new DataInputStream(st.getInputStream());
             Dos = new DataOutputStream(st.getOutputStream());
             //如果正常说明，已经接收到了对方的发送过来的数据、
             started =true;
        } catch (IOException e) {
            // TODO Auto-generated catch block
             e.printStackTrace();
        }
    }
  public void send(String str)
  {
       try {
           // 将数据写入到对方的内存中
             Dos.writeUTF(str);
        }
       catch(EOFException e){
           System.out.println("对方客户端退出了！");
       } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
  }
  @Override
  public void run() {
     // TODO Auto-generated method stub
      //如果连接上了，就可以提取相应的数据
       String str=null;
       try {
       while(started){
             //采用UTF-8的编码格式进行流的输入输出
               str = Dis.readUTF();
               /*for(int i=0;i<list.size() ;i++){
                 list.get(i).send(str);
               }*/
               for( NewClient sc : list )
                   sc.send(str);
               } 
       }catch(EOFException e){
            //绑定异常，说明退出了
            System.out.println("该客户端退出了!");
        }catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
              //当该线程消亡的时候，给予相应流的关闭
            try {
                 if(Dos!=null)Dos.close();
                 if(Dis!=null)Dis.close();
                 if(sc!=null)sc.close();
                } catch (IOException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
          }
  } 
}
}