java实现实时通信聊天程序

public class ClientDemo {
    public static Socket s;
    public static void main(String[] args) throws IOException, InterruptedException {
        s = new Socket("localhost", 10000);        //此处的参数一填写服务器端ip地址
        System.out.println("连接成功");
        Thread send = new Thread(new COUT());
        Thread receive = new Thread(new CIN());
        send.start();
        receive.start();
        send.join();        //发送和接收执行完毕时，关闭套接字
        receive.join();        //因此待这两个线程结束时才回到主线程执行。
        s.close();
    }
}

class CIN implements Runnable{
    @Override
    public void run() {        //接收模块
        try {
            InputStream is = ClientDemo.s.getInputStream();//通过全局套接字s获取连接后的流
            in(is);
        }
        catch (IOException o) {
            o.printStackTrace();
        }
    }
    public static void in(InputStream is) throws IOException{
        while(true){
            byte[] bytes = new byte[1024];
            int len = is.read(bytes);
            String line = new String(bytes,0,len);
 
            System.out.println("对方:   "+line);
            if(line.equals("close"))
                break;
        }
    }
}
 
class COUT implements Runnable{
    @Override
    public void run() {        //发送模块
        try {
            OutputStream os = ClientDemo.s.getOutputStream();//套接字获取流
            out(os);
        }
        catch (IOException o){
            o.printStackTrace();
        }
    }
    public static void out(OutputStream os) throws IOException{
        Scanner sc = new Scanner(System.in);
        while(true) {
            String line = sc.nextLine();
            os.write(line.getBytes());
            if(line.equals("close"))
                break;
        }
        sc.close();
    }
}

public class ServerDemo {
    public static ServerSocket ss;
    public static Socket s;
 
    public static void main(String[] args) throws IOException, InterruptedException {
        ss = new ServerSocket(10000);        //监听端口10000，对应客户端套接字绑定的端口
        s = ss.accept();        //提取监听套接字中的一个连接
        System.out.println("连接成功");
        Thread send = new Thread(new SOUT());
        Thread receive = new Thread(new SIN());
        send.start();
        receive.start();
        send.join();
        receive.join();
        ss.close();
    }
}

class SIN implements Runnable{
    @Override
    public void run() {
        try {
            InputStream is = ServerDemo.s.getInputStream();
            in(is);
        }
        catch (IOException o) {
            o.printStackTrace();
        }
    }
    public static void in(InputStream is) throws IOException{
        while(true){
            byte[] bytes = new byte[1024];
            int len = is.read(bytes);
            String line = new String(bytes,0,len);
            System.out.println("对方:   "+line);
            if(line.equals("close"))
                break;
        }
    }
}
class SOUT implements Runnable{
    @Override
    public void run() {
        try {
            OutputStream os = ServerDemo.s.getOutputStream();
            out(os);
        }
        catch (IOException o){
            o.printStackTrace();
        }
    }
    public static void out(OutputStream os) throws IOException{
        Scanner sc = new Scanner(System.in);
        while(true) {
            String line = sc.nextLine();
            os.write(line.getBytes());
            if(line.equals("close"))
                break;
        }
        sc.close();
    }
}