多线程版本的Socket传输

服务器

public class Server {
    public static void main(String[] args)   {
        ServerSocket ss &＃61; null;
        Socket s &＃61; null;
        try {
            ss &＃61; new ServerSocket(5210);
        } catch (IOException e) {
            // TODO 自动生成的 catch 块
            e.printStackTrace();
        }
        while(true) {
            try {
                s &＃61; ss.accept();
            } catch (IOException e) {
                // TODO 自动生成的 catch 块
                e.printStackTrace();
            }
        Threadds ts &＃61; new Threadds(s);
        ts.start();
        MyThread mt &＃61; new MyThread(s);
        mt.start();
        }
    }
}

客户端

public class Client {
    public static void main(String[] args) {
        Socket s&＃61; null ;
        try {
            s &＃61; new Socket("localhost", 5210);

        } catch (Exception e) {
            e.printStackTrace();
        }
        MyThread mt &＃61; new MyThread(s);
        mt.start();
        Threadds ts &＃61; new Threadds(s);
        ts.start();
    }
}

public class MyThread extends Thread{
    Scanner sca &＃61; new Scanner(System.in);
    private Socket s &＃61; null;
    PrintWriter pw &＃61; null;
    public MyThread() {
        // TODO 自动生成的构造函数存根
    }
    public MyThread(Socket s) {
        this.s&＃61; s;
    }
    public void run() {
        try {
            pw &＃61; new PrintWriter(s.getOutputStream());
            while(true) {
                pw.println(sca.next());
                pw.flush();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            pw.close();
        }
    }
}

public class Threadds extends Thread{
    private Socket s &＃61; null;
    BufferedReader br &＃61; null;
    public Threadds() {
        // TODO 自动生成的构造函数存根
    }
    public Threadds(Socket s) {
        this.s&＃61; s;
    }
    
    public void run() {
        try {
            br &＃61; new BufferedReader(new InputStreamReader(s.getInputStream()));
            while(true){
                System.out.println(br.readLine());
            }
        } catch (IOException e) {
            e.printStackTrace();
        }finally {
            try {
                br.close();
            } catch (IOException e) {
                // TODO 自动生成的 catch 块
                e.printStackTrace();
            }
        }
    }
}