/** * @author notifier * @create 2010-9-25 下午07:06:54 * @version 1.0 */ public class SimpleChatServer { // 保存客戶端列表 private ArrayList clientList = new ArrayList();; public static void main(String[] args) { new SimpleChatServer().startUp(); } /** * 負責服務器端的啟動 * */ public void startUp() { try { // 創建服務器端ServerSocket連接,監聽端口號5000 ServerSocket serverSocket = new ServerSocket(5000); // 輪詢等待客戶端請求 while(true) { // 等待客戶端請求,無請求則閑置;有請求到來時,返回一個對該請求的socket連接 Socket clientSocket = serverSocket.accept(); // 將該客戶端加入到列表中 PrintWriter writer = new PrintWriter(clientSocket.getOutputStream()); clientList.add(writer); // 創建ClientHandler對象,通過socket連接通信 Thread t = new Thread(new ClientHandler(clientSocket)); t.start(); System.out.println("有Client連進來"); } }catch(Exception e) { e.printStackTrace(); } } /** * 客戶端處理類, 主要負責: * 1.接收客戶端發來的消息 * 2.將消息轉發其他客戶端 * @author sdniu * @create 2010-9-26 上午10:00:18 * @version 1.0 */ public class ClientHandler implements Runnable { private BufferedReader reader; private Socket socket; /** * ClientHandler的構造函數 * @param clientSocket */ public ClientHandler(Socket clientSocket) { try { // 得到socket連接 socket = clientSocket; // 得到客戶端發來的消息 InputStreamReader isReader = new InputStreamReader(socket.getInputStream()); reader = new BufferedReader(isReader); } catch (IOException e) { e.printStackTrace(); } } public void run() { String message; try { while((message = reader.readLine()) != null) { System.out.println("客戶端消息: " + message); // 將客戶端發來的消息轉發所有客戶端 notifyAllClients(message); } } catch (IOException e) { e.printStackTrace(); } } } /** * * @param message */ public void notifyAllClients(String message) { // 得到客戶端列表的迭代器,語法格式為 Iterator it = clientList.iterator(); Iterator it = clientList.iterator(); while(it.hasNext()) { try { // 得到的Iterator別忘了強制轉換回PrintWriter PrintWriter writer = (PrintWriter) it.next(); writer.println(message); writer.flush(); } catch (Exception e) { e.printStackTrace(); } } } } |