shuru.java

用java实现的一个聊天室程序

import java.net.*;
import java.io.*;

public class ShuRu extends Thread{
    InputStream is;
    public ShuRu(InputStream is) {
        this.is = is;
    }
    
    public void run(){
        BufferedReader br = new BufferedReader(new InputStreamReader(is));
        while(true){
            try{
                String str = br.readLine();
                System.out.println (str);
                if(str.equals("Bye")){
                    break;
                }
            }catch(IOException e){
                e.printStackTrace();
            }
        }
    }
}

class ShuChu extends Thread {
    OutputStream os;
    public ShuChu(OutputStream os){
        this.os = os;
    }
    
    public void run(){
        PrintWriter pw = new PrintWriter(os,true);
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        while(true){
            try{
                String str = br.readLine();
                pw.println(str);
                if(str.equals("Bye")){
                    break;
                }
            }catch(IOException e){
                e.printStackTrace();
            }
        }
    }
}