testpop.java

短信开发用于文件交换处理转发的类模块

package com.sms.platform.switchcenter.inner.reportrespqueue;

import org.apache.log4j.Logger;

import com.sms.protocol.standard12.Standard_Inner_Response;

public class TestPop  extends Thread{
	
	private static Logger log = Logger.getLogger(TestPop.class);

	public void run(){
		TestGlobal global = TestGlobal.getInstance();
		
		
//		try {
//			for(int i = 0 ; i  < 500 ; i++){
//			Standard_Inner_Response sir = global.getRespQueue().dropFirstTimeout(1);
//			System.err.println(sir);
//			}
//		} catch (Exception e1) {
//			// TODO 自动生成 catch 块
//			e1.printStackTrace();
//		}
		
		
		
		
		
		
		
		
        Standard_Inner_Response sir = null;
        log.error("count : " + global.getRespQueue().count());
        java.util.ArrayList<Integer> a =  new java.util.ArrayList<Integer>();
        for(int i = 1 ; i  < 500 ; i++){
        	sir = new Standard_Inner_Response();
        	sir.setSequenceId(i);
        	sir.setMessageID(i+"");
        	sir.setSrcClientID(1);
        	int state = global.getRespQueue().searchPop(sir);
        	log.error("Pop " + i + " " + state + " " + sir.getMessageID()+"|"+sir.getSrcClientID()+"|"+sir.getSequenceId()+"|"+sir.getState());
        	if(state != 0){
        		a.add(i);
        	}
        }
        
        log.error("Pop count : " + global.getRespQueue().count() + "  size : " + a.size());
        log.error("=======================================================");
        java.util.ArrayList<Integer> b =  new java.util.ArrayList<Integer>();
    	int j = a.size();
    	if(j > 0){
    		try {
				Thread.sleep(2000);
			} catch (InterruptedException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
    	}
    	for(int k = 0 ; k < j ; k++){
    		int temp = a.remove(0);
        	sir = new Standard_Inner_Response();
        	sir.setSequenceId(temp);
        	sir.setSrcClientID(1);
        	sir.setMessageID(temp+"");
        	int state = global.getRespQueue().searchPop(sir);
        	log.error(k + "  Pop " + temp + " " + state + " " + sir.getMessageID()+"|"+sir.getSrcClientID()+"|"+sir.getSequenceId()+"|"+sir.getState());
        	if(state != 0){
        		b.add(temp);
        	}
    	}
    	
        log.error("Pop count : " + global.getRespQueue().count() + "  size : " + b.size());
        log.error("=======================================================");
        java.util.ArrayList<Integer> c =  new java.util.ArrayList<Integer>();
    	int l = b.size();
    	if(l > 0){
    		try {
				Thread.sleep(2000);
			} catch (InterruptedException e) {
				// TODO 自动生成 catch 块
				e.printStackTrace();
			}
    	}
    	for(int k = 0 ; k < l ; k++){
    		int temp = b.remove(0);
        	sir = new Standard_Inner_Response();
        	sir.setSequenceId(temp);
        	sir.setSrcClientID(1);
        	sir.setMessageID(temp+"");
        	int state = global.getRespQueue().searchPop(sir);
        	log.error("Pop " + temp + " " + state + " " + sir.getMessageID()+"|"+sir.getSrcClientID()+"|"+sir.getSequenceId()+"|"+sir.getState());
        	if(state != 0){
        		c.add(temp);
        	}
    	}
        log.error("Pop count : " + global.getRespQueue().count() + "  size : " + c.size());
        log.error("=======================================================");
        long o = global.getRespQueue().count();
        for(int k = 0 ; k < o ; k++){
        	sir = global.getRespQueue().pop();
        	log.error(k + "  Pop : " + sir.getMessageID()+"|"+sir.getSrcClientID()+"|"+sir.getSequenceId()+"|"+sir.getState());
        }
        
	}
	
	public TestPop(){
		
	}
	
	public static void main(String [] args){
		new TestPop();
	}
	
}