tcpserver.java

uml ooad 有ppt文件 和源码哦！跟大家分享

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();
	}
}