qqpublic.java

QQ聊天

package com.sato.server.servermanager;

import java.io.IOException;
import java.util.Collection;
import java.util.HashMap;

public class QQpublic {
	public static HashMap<String, MyServerReader> threadMap=new HashMap<String, MyServerReader>();
	
	public static void sendMessage(String id, Object message)
	throws IOException {
		MyServerReader msr = threadMap.get(id);
		if (msr != null) {
			if (msr.isAlive())
				msr.sendMessage(message);
		}
	}
	
	public static void sendToAll(Object message){
		Collection<MyServerReader> col=threadMap.values();
		for(MyServerReader msr:col){
			msr.sendMessage(message);
		}
	}
	
	public static void close(String id,Object message)throws IOException{
		MyServerReader msr=threadMap.get(id);
		if(msr!=null){
			if(msr.isAlive())
			{
				msr.closeAll();
				QQpublic.threadMap.remove(id);
			}
		}
	}
	
	public static void closeAll(){
		Collection<MyServerReader> col=threadMap.values();
		for(MyServerReader msr:col){
			if(msr.isAlive()){
				msr.closeAll();
			}
			threadMap.clear();
		}
	}
}