ConcurrentLinkedQueue 数据缓存

忘是亡心i 2024-04-20 08:44 51阅读 0赞

public class SumMonitorAlertRecord {
    	
    	private static ConcurrentLinkedQueue<MonitorAlertInfo> allQueue;
    		
    	
    	private static ConcurrentHashMap<String, ConcurrentLinkedQueue<MonitorAlertInfo>> perMap;
    	
    	
    	private static int alertAllCount=0;
    		
    	
    	private static int alertSingleCount=0;
    	
    	static
    	{
    		perMap=new ConcurrentHashMap<String, ConcurrentLinkedQueue<MonitorAlertInfo>>();
    		allQueue=new ConcurrentLinkedQueue<MonitorAlertInfo>();
    		alertAllCount=AdapterProperties.getAlertAllCount();
    		alertSingleCount=AdapterProperties.getAlertSingleCount();
    	}
    	
    	/**
    	 * 
    	 * @param allModel
    	 */
    	public static void add(MonitorAlertInfo allModel) {
    		addToAllQueue(allModel);
    		addToPerMap(allModel);
    	}
    	
    	
    	private static void addToPerMap(MonitorAlertInfo allModel)
    	{
    		String location=allModel.getAlertposition();
    		if (StringUtil.isEmpty(location)) {
    			return;
    		}
    		
    		if(!perMap.containsKey(location))// 不存在key
    		{
    			ConcurrentLinkedQueue<MonitorAlertInfo> queueAdd=
    					new ConcurrentLinkedQueue<MonitorAlertInfo>();
    			
    			queueAdd.offer(allModel);
    			perMap.put(location, queueAdd);
    		}
    		else // 存在key
    		{
    			// 判断是否达到最大缓存数量
    			ConcurrentLinkedQueue<MonitorAlertInfo> queue=perMap.get(location);
    			if(queue.size()>=alertSingleCount)
    			{
    				queue.poll();
    			}
    			
    			// 添加到缓存中
    			queue.offer(allModel);
    		}
    	}
    	
    	
    	private static void addToAllQueue(MonitorAlertInfo allModel)
    	{
    		if(allQueue.size()>=alertAllCount)
    		{
    			allQueue.poll();
    		}
    		
    		// 添加到缓存中
    		allQueue.offer(allModel);
    	}
    	
    	
    	public static List<MonitorAlertInfo> getListByKey(String location)
    	{
    		if (StringUtil.isEmpty(location)) {
    			return null;
    		}
    		ConcurrentLinkedQueue<MonitorAlertInfo> queue=perMap.get(location);
    		if(queue==null){
    			return null;
    		}else{
    			List<MonitorAlertInfo> resultList = new ArrayList<MonitorAlertInfo>();
    			Iterator<MonitorAlertInfo> it=queue.iterator();
    			while(it.hasNext())
    			{
    				MonitorAlertInfo currentModel=it.next();
    				resultList.add(currentModel);
    			}
    			return resultList;
    		}
    	}
    	
    
    	public static List<MonitorAlertInfo> getListAll()
    	{
    		int queueSize = allQueue.size();
    		
    		if(queueSize==0){
    			return null;
    		}else{
    			List<MonitorAlertInfo> resultList = new ArrayList<MonitorAlertInfo>();
    			Iterator<MonitorAlertInfo> it=allQueue.iterator();
    			while(it.hasNext())
    			{
    				MonitorAlertInfo currentModel=it.next();
    				resultList.add(currentModel);
    			}
    			
    			return resultList;
    		}
    	}
    }