Go语言视频零基础入门到精通

javalearner

var hunters = ["u003Ca href="/jobs/519" target="_blank" style="color:#000;"u003Eu003Cspan style="font-weight:bold;"u003Eu5b89u5fbd: u003C/spanu003E u5408u80a5,u676du5dde,u82cfu5ddeuff1au8bdau8058javau9ad8u7ea7u5f00u53d1u5de5u7a0bu5e08u003C/au003E","u003Ca href="/jobs/515" target="_blank" style="color:#000;"u003Eu003Cspan style="font-weight:bold;"u003Eu4e0au6d77: u003C/spanu003E u4e0au6d77uff1au5929u4f1au7693u95fbu8bdau8058u8d44u6df1Javau67b6u6784u5e08u003C/au003E","u003Ca href="/jobs/518" target="_blank" style="color:#000;"u003Eu003Cspan style="font-weight:bold;"u003Eu5b89u5fbd: u003C/spanu003E u5408u80a5,u676du5dde,u82cfu5ddeuff1au8bdau8058javau67b6u6784u5e08u003C/au003E"]
      var hunter_id = Math.ceil(Math.random() * hunters.length) - 1;
      if(hunter_id == -1) hunter_id = 0;
                     
     
   
                if($("hunter_recommended")) {
                  $("hunter_recommended").setStyle({cssFloat: "left", width: "557px"})
                }
                new Draggable("related_topics");
                     
     
    import java.io.IOException;   
import java.util.concurrent.ConcurrentHashMap;   
import java.util.concurrent.CopyOnWriteArrayList;   
  
import javax.Servlet.Filter;   
import javax.servlet.FilterChain;   
import javax.servlet.FilterConfig;   
import javax.servlet.ServletException;   
import javax.servlet.ServletRequest;   
import javax.servlet.ServletResponse;   
import javax.servlet.http.HttpServletRequest;   
import javax.servlet.http.HttpServletResponse;   
  
  
public class RefreshFilter implements Filter {   
      
    @Override  
    public void doFilter(ServletRequest request, ServletResponse response,   
            FilterChain chain) throws IOException, ServletException {   
           
        filter((HttpServletRequest) request,(HttpServletResponse) response, chain);   
    }   
      
    private void filter(HttpServletRequest request, HttpServletResponse response,   
            FilterChain chain) throws IOException, ServletException {   
           
        String requestURI = request.getRequestURI();   
        Cache cache = Cache.getInstance();   
        cache.increment(requestURI);   
        if(cache.isUpCount(requestURI)) {   
            response.getWriter().println("到达次数，不允许请求，请稍候再试");   
            return;   
        }   
        chain.doFilter(request, response);   
    }   
      
   
  
    @Override  
    public void destroy() {   
           
    }   
  
    @Override  
    public void init(FilterConfig config) throws ServletException {   
           
    }   
      
    //缓存   
    private static class Cache {   
           
        private static final ConcurrentHashMap<String, CopyOnWriteArrayList<Long>>
         map = new ConcurrentHashMap<String, CopyOnWriteArrayList<Long>>();   
        private static final long EXPIRE_TIME = 1000 * 20L;   
        private static final long CLEAR_TIME = 1000 * 2L;   
        private static final int MAX_REFRESH_COUNT = 20;   
           
        private static final Cache cache = new Cache();   
           
        private Cache() {   
            new Thread(new ClearCacheRunnable()).start();   
        }   
           
        public static Cache getInstance() {   
            return cache;   
        }   
           
           
        //增长指定URL的点击次数   
        public void increment(String key) {   
            CopyOnWriteArrayList<Long> list = map.get(key);   
            if(list == null) {   
                map.put(key, new CopyOnWriteArrayList<Long>());   
            }   
            map.get(key).add(new Long(System.currentTimeMillis()));   
        }   
           
        //是否到达指定数量   
        public boolean isUpCount(String key) {   
            CopyOnWriteArrayList<Long> list = map.get(key);   
            if(list == null) {   
                return false;   
            }   
            return list.size() > MAX_REFRESH_COUNT;   
        }   
           
        //清理过期数据线程   
        private static class ClearCacheRunnable implements Runnable {   
            @Override  
            public void run() {   
                while(true) {   
                    try {   
                        Thread.sleep(Cache.CLEAR_TIME);   
                        clear();   
                    } catch (InterruptedException e) {   
                        e.printStackTrace();   
                    }   
                }   
            }   
  
            private void clear() {   
                for(String key : map.keySet()) {   
                    CopyOnWriteArrayList<Long> list = map.get(key);   
                    for(Long date : list) {   
                        if(System.currentTimeMillis() - date > Cache.EXPIRE_TIME) {   
                            System.out.println(list.remove(date));   
                        }   
                    }   
                }   
            }   
        }   
    }   
      
      
}  
                      [/code]
      
   

   
     
     
      
      

        
      

        
      
     
   

  


源码下载：http://file.javaxxz.com/2014/10/10/045825234.zip