Dos.QQ.rar_https ://dos.qq.com_qq聊天系统java

package com.softeem.net; import java.io.BufferedReader; import java.io.InputStreamReader; import java.io.PrintStream; import java.net.Socket; import java.util.Iterator; import java.util.Vector; public class NetGroup extends Thread { /** * 有任何一个人输出，我们就要进行对应的广播 * * @author jaty * */ private Socket s; private BufferedReader br; public NetGroup(Socket s) { this.s = s; try { br = new BufferedReader(new InputStreamReader(s.getInputStream())); } catch (Exception e) { e.printStackTrace(); } } public void run() { try { if (br != null) { String msg = null; while (true) { msg = br.readLine(); if (msg != null) {// 有任何人输入就要广播 // 拿到所有人 Vector v = NetBoss.sockets; Iterator item = v.iterator(); while (item.hasNext()) { Socket socket = (Socket) item.next(); if (this.s != socket) {// 除自身而外 // 广播 PrintStream ps = new PrintStream( socket.getOutputStream()); ps.println(msg); ps.flush(); } } } else { System.out.println(">>>>>有人退出"); // 踢人 Vector v = NetBoss.sockets; Iterator item = v.iterator(); while (item.hasNext()) { Socket socket = (Socket) item.next(); if (this.s == socket) {// 表示有人退出 v.remove(socket); } } } } } } catch (Exception e) { e.printStackTrace(); } } }