broadcastthread.java

多人聊天

import java.net.*;
import java.io.*;
import java.util.*;
 
// 廣播執行緒
public class BroadCastThread extends Thread {
    private Vector _clientVector; // 儲存連線的客戶端
    private Vector _messageVector; // 儲存廣播訊息
 
    public BroadCastThread() {
       setDaemon(true);
       _clientVector = new Vector();
       _messageVector = new Vector();
    }
 
    public void addClientThread(ClientThread client) {
        // 將客戶端add至處理佇列
        _clientVector.addElement(client);
    }
 
    public void removeClientThread(ClientThread client) {
        // 移除客戶端
        _clientVector.removeElement(client);
    }
 
    public void addMessage(String message) {
        _messageVector.addElement(message);
    }
 
    public void run() {
        ClientThread client = null;
        String message = null;
        try {
            while(true) {
                // 每兩秒廣播一次
                Thread.sleep(2000);
 
                // 取出要廣播的訊息
                // 目前沒有訊息就不處理接下來的內容
                if(_messageVector.isEmpty())
                    continue;
 
                message = (String) _messageVector.firstElement();
                _messageVector.removeElement(message);
 
                // 將訊息一個一個丟給客戶端
                for(int i = 0; i < _clientVector.size(); i++) {
                    client = (ClientThread) _clientVector.elementAt(i);
                    client.sendMessage(message);
                }
            }
        }
        catch(InterruptedException e) {
            System.out.println(e.toString());
        }
    }
}