金融贸易项目springboot

package com.dlxy.framework.filter; import com.dlxy.framework.entity.User; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Component; import org.yaml.snakeyaml.external.biz.base64Coder.Base64Coder; import javax.servlet.*; import javax.servlet.annotation.WebFilter; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; @WebFilter("/*")// /* -->所有的路径 @Component public class GlobalFilter implements Filter { @Value("${security.check}") private Boolean check; @Value("${security.access}") private String access; public static ConcurrentHashMap<String,Long> onlines=new ConcurrentHashMap<>(); /** *用户登录成功后，生成token的数据并返回 * user：登录后的用户信息 */ public static String generateToken(User user){ String token= Base64Coder.encodeString(user.toString()); onlines.put(token,System.currentTimeMillis()); return token; } /** * * @param servletRequest * @param servletResponse * @param filterChain * @throws IOException * @throws ServletException */ @Override public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException { //1.获取HttpServletRequest和HttpServletResponse对象 HttpServletRequest request=(HttpServletRequest)servletRequest; HttpServletResponse response=(HttpServletResponse)servletResponse; //2.获取用户的请求路径 String uri=request.getRequestURI(); //3.判断请求路径是否需要拦截 if(check && !uri.endsWith(".js")&& !uri.endsWith(".css")&& !access.contains(uri)){ //请求路径被拦截 //判断用户是否登录 String token = request.getHeader("Authorization"); if(token ==null || !onlines.containsKey(token)){ //重新登录 request.getRequestDispatcher("/system/needLogin").forward(request,response); return; } } filterChain.doFilter(request,response); } //自动清除超时token @Override public void init(FilterConfig filterConfig) throws ServletException{ if(check){ //1.创建定时器对象 ScheduledExecutorService service= Executors.newScheduledThreadPool(1); //2.创建任务 Runnable task=() ->onlines.entrySet().removeIf(entry -> System.currentTimeMillis() -entry.getValue()>10*60*1000 ); //3.启动定时器，定时执行任务 service.scheduleAtFixedRate(task,0,1, TimeUnit.SECONDS); } } }