/** * @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(); } /** * 負(fù)責(zé)服務(wù)器端的啟動 * */ public void startUp() { try { // 創(chuàng)建服務(wù)器端ServerSocket連接,監(jiān)聽端口號5000 ServerSocket serverSocket = new ServerSocket(5000); // 輪詢等待客戶端請求 while(true) { // 等待客戶端請求,無請求則閑置;有請求到來時(shí),返回一個對該請求的socket連接 Socket clientSocket = serverSocket.accept(); // 將該客戶端加入到列表中 PrintWriter writer = new PrintWriter(clientSocket.getOutputStream()); clientList.add(writer); // 創(chuàng)建ClientHandler對象,通過socket連接通信 Thread t = new Thread(new ClientHandler(clientSocket)); t.start(); System.out.println("有Client連進(jìn)來"); } }catch(Exception e) { e.printStackTrace(); } } /** * 客戶端處理類, 主要負(fù)責(zé): * 1.接收客戶端發(fā)來的消息 * 2.將消息轉(zhuǎn)發(fā)其他客戶端 * @author sdniu * @create 2010-9-26 上午10:00:18 * @version 1.0 */ public class ClientHandler implements Runnable { private BufferedReader reader; private Socket socket; /** * ClientHandler的構(gòu)造函數(shù) * @param clientSocket */ public ClientHandler(Socket clientSocket) { try { // 得到socket連接 socket = clientSocket; // 得到客戶端發(fā)來的消息 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); // 將客戶端發(fā)來的消息轉(zhuǎn)發(fā)所有客戶端 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別忘了強(qiáng)制轉(zhuǎn)換回PrintWriter PrintWriter writer = (PrintWriter) it.next(); writer.println(message); writer.flush(); } catch (Exception e) { e.printStackTrace(); } } } } |