package com.iplatform.tcp.util.ws;
|
|
import java.util.concurrent.TimeUnit;
|
|
import com.walker.tcp.Context;
|
import com.walker.tcp.filter.DefaultFilter;
|
|
/**
|
* 让接收数据有规律间隔的，过滤器实现
|
* @author Administrator
|
*
|
*/
|
public class StepTimeFilter extends DefaultFilter {
|
|
@Override
|
public boolean doFilter(Context context) throws Exception {
|
// long spanTime = context.getPreviousTimeSpan();
|
// if(context.getPreviousData() != null && spanTime != 0){
|
// long span = Math.abs(spanTime - 600);
|
// TimeUnit.MILLISECONDS.sleep(span);
|
// logger.debug("~~~~~~~~~~~~~~过滤器执行一次，间隔：" + span + ", spanTime = " + spanTime);
|
// logger.debug(context.getPreviousData());
|
// } else {
|
// TimeUnit.MILLISECONDS.sleep(600);
|
// logger.debug("~~~~~~~~~~~~~~过滤器执行一次，间隔：600 mills" );
|
// }
|
|
TimeUnit.MILLISECONDS.sleep(500);
|
return true;
|
}
|
|
}
|
