sender.java

基于streamsocket的简单聊天室

package socketChat;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;

public class Sender extends Thread {    
		PrintWriter writer;
    public Sender(PrintWriter theWriter) {
        writer = theWriter;
    }
    public void run() {
        try {
						while (true) {
                BufferedReader consoleReader = new BufferedReader(new InputStreamReader(System.in));
                String userInput = consoleReader.readLine(); // 接受键盘数据
                writer.write(userInput + "\r\n"); // 写入输出流
                writer.flush(); // 把流发送
            }
        } catch (Exception e) {
            e.printStackTrace();
            return;
        }     
		}
}