broadcase.java

一个简单的java聊天程序

import java.io.IOException;

public class BroadCase extends Thread {

	ClientThread clientThread;

	ServerThread serverThread;

	String str;

	public BroadCase(ServerThread serverThread) {
		this.serverThread = serverThread;
	}

	public void run() {
		while (true) {
			try {
				Thread.sleep(300);
			} catch (InterruptedException e) {
			}

			synchronized (serverThread.messages) {
				if (serverThread.messages.isEmpty()) {
					continue;
				}
				str = (String) this.serverThread.messages.firstElement();
				this.serverThread.messages.removeElement(str);
			}

			synchronized (serverThread.clients) {
				for (int i = 0; i < serverThread.clients.size(); i++) {
					clientThread = serverThread.clients.elementAt(i);
					try {
						clientThread.out.writeUTF(str);

					} catch (IOException e) {
					}
				}

			}
		}
	}
}