serverthread.java

java编写的聊天室

package lts;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;

public class ServerThread extends Thread {
	private Socket so;
	private static String word ="";
	public ServerThread(Socket so) {
		this.so = so;
	}

	@Override
	public void run() {
		try {
			DataInputStream dis = new DataInputStream(so.getInputStream());
			DataOutputStream dos = new DataOutputStream(so.getOutputStream());
			while (true) {
				String temp = dis.readUTF();
				if ("bye".equals(temp))
					break;
				if (!"".equals(temp)) {
					word = word + temp+"\n";
				}
				dos.writeUTF(word);
			}
			dis.close();
			dos.close();
		} catch (Exception ee) {
			ee.printStackTrace();
		} finally {
			try {
				so.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}