multichatserver.java

多人聊天

import java.net.*;
import java.io.*;
import java.util.*;
 
public class MultiChatServer {
    public static void main(String[] args) {
        BufferedReader user = null;
        String sysopMessage = null;
        int port = 0;
 
        System.out.println("多人連線聊天伺服器v0.2....");
        System.out.print("連接埠: ");
        try {
            user = new BufferedReader(new InputStreamReader(System.in));
            port = Integer.parseInt(user.readLine());
 
            // 啟動伺服器執行緒
            ServerThread server = new ServerThread(port);
            System.out.println("伺服器正在啟動......");
            System.out.print("繫結至連結埠 " + port + " ......");
            server.start();
            System.out.println("Ok!");
 
            // 後台的站台廣播
            while((sysopMessage = user.readLine()) != null) {
                if(sysopMessage.equals("shutdown")) {
                    System.out.println("伺服器即將於5秒後關閉！");
                    server.addSysopMessage("伺服器廣播: 網站即將於5秒後關閉！");
 
                    try {
                        for(int i = 0; i < 5; i++) {
                            Thread.sleep(1000);
                            System.out.print(".");
                        }
                    }
                    catch(InterruptedException e) {}
 
                    break;
                }
                else
                    server.addSysopMessage("站台廣播: " + sysopMessage);
            }
        }
        catch(IOException e) {
            System.out.println(e.toString());
        }
 
        System.out.println("伺服器關閉！");
    }
}