talkserverget.java

类似于QQ的聊天程序

package server;

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

public class TalkServerGet implements Runnable {
	private TalkServer server = null;
	private Socket socket = null;
	private String name = "";

	public TalkServerGet(TalkServer server, Socket socket, String name) {
		this.server = server;
		this.socket = socket;
		this.name = name;
	}
//以线程随时接受每个用户发表的言论
	public void run() {
		InputStream input;
		while (true) {
			try {
				input = socket.getInputStream();
				DataInputStream dataInput = new DataInputStream(input);
				String str = dataInput.readUTF();
				server.sendTalk(str);
			} catch (IOException e) {
				server.getShow().append('\n' + name + "下线");
				server.removeUser(name);
				try {
					socket.close();
					break;
				} catch (IOException e1) {
					e1.printStackTrace();
				}

			}
		}
	}

}