package org.springblade.modules.nettyServer;

import io.netty.channel.Channel;

import java.util.concurrent.ConcurrentHashMap;

public class ChannelMap {
	public static int channelNum=0;
	private static ConcurrentHashMap<String, Channel> channelHashMap=null;//concurrentHashmap以解决多线程冲突

	public static ConcurrentHashMap<String, Channel> getChannelHashMap() {
		return channelHashMap;
	}

	public static Channel getChannelByName(String name){
		if(channelHashMap==null||channelHashMap.isEmpty()){
			return null;
		}
		return channelHashMap.get(name);
	}
	public static void addChannel(String name, Channel channel){
		if(channelHashMap==null){
			channelHashMap=new ConcurrentHashMap<String, Channel>(10);
		}
		channelHashMap.put(name,channel);
		channelNum++;
	}
	public static int removeChannelByName(String name){
		if(channelHashMap.containsKey(name)){
			channelHashMap.remove(name);
			return 0;
		}else{
			return 1;
		}
	}
}