类似QQ的局域网通信系统

package server; import java.net.*; import java.util.*; public class TCPServer implements Runnable,Server { User user; ServerAction action; Map<String, User> users; public TCPServer(){} public TCPServer(User user, ServerAction action, Map<String, User> users) { super(); this.user = user; this.action = action; this.users = users; } public void service() throws Exception { Map<String, User> users = new HashMap<String, User>(); ServerSocket ss = new ServerSocket(9000); while (true) { Socket s = ss.accept(); User user = new TCPUser(s); ServerAction action = new TCPServerAction(user); Thread t = new Thread(new TCPServer(user, action, users)); t.start(); } } public void sendAll(String text) { Collection<User> vs = users.values(); for (User u : vs) action.send(text, u); } public void act() { try { while(true){ String t = action.receive(); String[] ss = t.split(":"); if (ss[0].equals("0")){ t = action.receive(); ss = t.split(":"); User u = users.get(ss[2]); action.send(t, u); } if (ss[0].equals("1")){ user.setName(ss[1]); Set<String> others=users.keySet(); for(String o:others){ action.send("1:"+o, user); } users.put(ss[1], user); sendAll(t); } if (ss[0].equals("2")){ sendAll("2:" + user.getName()); users.remove(user.getName()); } } } catch (Exception e) {} } public void run() { act(); } }