栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

集成zuul并解决因为zuul转发请求而导致的超时问题

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

集成zuul并解决因为zuul转发请求而导致的超时问题

拦截器

@Component
public class PreFilter extends ZuulFilter {

    private final Logger logger = LoggerFactory.getLogger(this.getClass());

    @Autowired
    private IRedisService redisService;

    @Override
    public String filterType() {
        return "pre";
    }

    @Override
    public int filterOrder() {
        return 0;
    }

    @Override
    public boolean shouldFilter() {
        return true;
    }

    @Override
    public Object run() throws ZuulException {
        RequestContext ctx = RequestContext.getCurrentContext();
        HttpServletRequest httpServletRequest = ctx.getRequest();
        HttpServletResponse httpServletResponse = ctx.getResponse();
        //获取路径,白名单不拦截
        String writeURI = httpServletRequest.getRequestURI();

        SoftReference> listSoftReference = new SoftReference<>(new ArrayList<>());
        ArrayList writeUrls = listSoftReference.get();
        //因为用的是软引用对象,所以可能被GC,要先判断是否为空
        if (writeUrls == null) {
            listSoftReference = new SoftReference<>(new ArrayList<>());
        }
        writeUrls = listSoftReference.get();
        //白名单URL,不走过滤器
        writeUrls.add("/user/getSign");
        //writeUrls.add("/user/test");
        writeUrls.add("/user/logout");
        writeUrls.add("/user/login");
        writeUrls.add("/user/testLogin");
        writeUrls.add("/user/encryptAccount");
        writeUrls.add("/user/getVerifyCode");
        if (writeUrls.contains(writeURI)) {
            return true;
        }

        //首先从请求头中获取token串,与页面约定好存放token值的请求头属性名为x-token
        String token = httpServletRequest.getHeader("x-token");
        logger.info("[登录校验拦截器]-token为:{}", token);
        //判断token是否有效
        if (StringUtils.isNotBlank(token)) {
            //从Redis获取到用户信息,获取不到说明token失效了;否则直接返回token
            try {
                User user = redisService.getUser(httpServletRequest);
                if (user != null) {
                    httpServletResponse.setHeader("x-token", token);
                    return true;
                }
            } catch (Exception e) {
                e.printStackTrace();
                logger.error("[PreFilter]-redisService,从Redis获取到用户信息错误");
            }

        } else {
            logger.info("[PreFilter]-token非法或已超时,重新登录");
        }
        //输出响应流
        ctx.setSendZuulResponse(false);
        Map resp = new HashMap<>(4);
        resp.put("code", ResultEnum.NOT_LOGIN.getCode());
        resp.put("msg", "用户没有登录");
        ctx.setResponseBody(JSONObject.toJSonString(resp));
        ctx.getResponse().setContentType("application/json; charset=utf-8");
        try {
            // 调用flushBuffer刷新缓冲区数据即可
            ctx.getResponse().flushBuffer();
        } catch (IOException e) {
            e.printStackTrace();
            logger.error("[PreFilter]-flushBuffer,调用flushBuffer刷新缓冲区数据错误");
        }
        return null;
    }


    
    public String getIpAddr(HttpServletRequest request) {

        String ip = request.getHeader("X-Forwarded-For");
        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getHeader("Proxy-Client-IP");
        }
        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getHeader("WL-Proxy-Client-IP");
        }
        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getHeader("HTTP_CLIENT_IP");
        }
        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getHeader("HTTP_X_FORWARDED_FOR");
        }
        if (ip == null || ip.length() == 0 || "unknown".equalsIgnoreCase(ip)) {
            ip = request.getRemoteAddr();
        }
        return ip;
    }
}

pom

		
            org.springframework.cloud
            spring-cloud-starter-netflix-zuul
        

配置文件
所有:localhost:8080/user/*的接口都会到8091端口

zuul:
  routes:
    #user微服务
    userService:
      #以/user为头部的请求都转发到onstore-user服务里
      path: /user/**
      serviceId: onstore-user
      #url: http://localhost:8091
ribbon:
  #解决zuul转发请求导致的超时问题
  ReadTimeout: 60000 
  SocketTimeout: 60000

启动类加上

@EnableZuulProxy
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/769415.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号