/**
 * 文件名: ConnectionStore.java    2012-7-16
 */
package com.gxzy.framework.comm.rtc.store;

import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

import javax.servlet.AsyncContext;
import javax.servlet.http.HttpServletRequest;

/**
 * 连接仓库
 * @作者 AMY
 * @版本 1.0
 */
public class ConnectionStore
{
    private static final Map<String, List<AsyncContext>> store = new ConcurrentHashMap<String, List<AsyncContext>>();
    
    //保存用户发送的最后一个rtc请求时间
    private static final Map<String, Date> lastTtcStore = new ConcurrentHashMap<String, Date>();
    
    public static Map<String, List<AsyncContext>> getStore() {
		return store;
	}

	/**
     * 孙雄伟改造支持多个链接
     * 往仓库中放入一个新的连接,改造支持多个链接
     * @param key
     * @param context
     */
    public static void put(String key, AsyncContext context)
    {
    
    	List<AsyncContext> acs = store.get(key);
    	
    	
    	
    	if(acs == null){
    		
    		acs = new ArrayList<AsyncContext>();
    		
    		store.put(key, acs);
    		
    	}
    	
    	acs.add(context);
    	
		//store.put(key, acs);
    	
        //store.put(key, context);
    	//context.getRequest().gets
    	System.out.println("request----------"+((HttpServletRequest)context.getRequest()).getSession().getId());
    	//org.apache.shiro.web.servlet.ShiroHttpServletRequest
    	
    	lastTtcStore.put(key, new Date());
    
    }
    
    /**
     * 是否包含给定主键的连接
     * @param key
     * @return
     */
    public static boolean contain(String key)
    {
        return store.containsKey(key);
    }
    
    /**
     * 返回给定主键的连接，并且将连接从仓库中移除
     * @param key
     * @return
     */
    public static List<AsyncContext> poll(String key)
    {
        if(!store.containsKey(key))
            return null;
        
        List<AsyncContext> context = store.get(key);
        
        store.remove(key);
        
        return context;
    }
    
    /**
     * 删除
     * @param key
     */
    public static void remove(String key)
    {
        if(store.containsKey(key))
            store.remove(key);
    }
}