spring boot过滤器实现项目内接口过滤

打印 上一主题 下一主题

主题 932|帖子 932|积分 2796

spring boot过滤器实现项目内接口过滤

业务

由于业务需求,存在两套项目,一套是路由中心,一套是业务系统.
现在存在问题是,路由中心集成了微信公众号与小程序模块功能,业务系统部署了多套服务.
现在需要通过调用路由中心将接口重新路由到指定的业务系统中

需要处理的问题


  • 将小程序,公众号用户信息与业务系统做绑定
  • 将路由中心的接口与业务系统的接口判断出来
  • 通过用户信息找到的业务系统服务,分发到对应的业务系统中
公众号用户信息与业务系统做绑定

处理步骤


  • 业务系统存在手机号,如果用户注册将手机号发送给路由中心记录
将路由中心的接口与业务系统的接口判断

处理步骤


  • 获取路由中心系统中接口映射
  1.     private static List<String> URLS = new ArrayList<>();
  2.     @Resource
  3.     private WebApplicationContext applicationContext;
  4.        
  5.     @Override
  6.     public void init(FilterConfig filterConfig) throws ServletException {
  7.         applicationContext
  8.                 .getBean(RequestMappingHandlerMapping.class)
  9.                 .getHandlerMethods()
  10.                 .forEach((k, v) -> { k.getPatternsCondition().getPatterns().stream().forEach(s-> URLS.add(s)); });
  11.         log.info("过滤器初始化");
  12.     }
复制代码

  • 获取请求接口路径
  1.         HttpServletRequest request = (HttpServletRequest) servletRequest;
  2.         HttpServletResponse response = (HttpServletResponse) servletResponse;
  3.         String requestName = request.getRequestURI();
复制代码

  • 判断是否是路由中心的接口
  1.         if (URLS.contains(requestName)) {
  2.                 //系统接口
  3.             chain.doFilter(servletRequest, servletResponse);
  4.         } else {
  5.                 //业务系统接口 需要代理
  6. //            代理请求
  7.             ResponseEntity<String> redirect = routerService.redirect(request, response, "xxx", "xxx");
  8.             //设置将字符以"UTF-8"编码输出到客户端浏览器
  9.             response.setCharacterEncoding("UTF-8");
  10.             //通过设置响应头控制浏览器以UTF-8的编码显示数据,如果不加这句话,那么浏览器显示的将是乱码
  11.             response.setHeader("content-type", "application/json; charset=utf-8");
  12.             response.getWriter().write(redirect.getBody());
  13.         }
复制代码
全部代码
  1. import com.jyw.router.miniapp.service.IRouterService;import lombok.extern.slf4j.Slf4j;import org.springframework.context.annotation.Configuration;import org.springframework.http.ResponseEntity;import org.springframework.web.context.WebApplicationContext;import org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerMapping;import javax.annotation.Resource;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.ArrayList;import java.util.List;/** * @author 沈峻 * @ClassName RouterFilter * @Description TODO * @Date 2023/4/20 12:23 **/@Configuration@WebFilter(urlPatterns = "/*", filterName = "Router")@Slf4jpublic class RouterFilter implements Filter {    private static List URLS = new ArrayList();    @Resource    private WebApplicationContext applicationContext;    @Resource    private IRouterService routerService;    @Override    public void init(FilterConfig filterConfig) throws ServletException {        applicationContext.getBean(RequestMappingHandlerMapping.class).getHandlerMethods().forEach((k, v) -> { k.getPatternsCondition().getPatterns().stream().forEach(s-> URLS.add(s)); });        log.info("过滤器初始化");    }    @Override    public void doFilter(ServletRequest servletRequest, ServletResponse servletResponse, FilterChain chain) throws IOException, ServletException {        HttpServletRequest request = (HttpServletRequest) servletRequest;
  2.         HttpServletResponse response = (HttpServletResponse) servletResponse;
  3.         String requestName = request.getRequestURI();        /*顺手解决跨域问题*/        response.setHeader("Access-Control-Allow-Origin", "*");        response.setHeader("Access-Control-Allow-Methods", "POST, GET, OPTIONS, DELETE");        response.setHeader("Access-Control-Max-Age", "3600");        response.setHeader("Access-Control-Allow-Headers", "x-requested-with");        log.info(requestName);        if (URLS.contains(requestName)) {            chain.doFilter(servletRequest, servletResponse);        } else {//            代理请求            ResponseEntity redirect = routerService.redirect(request, response, "http://192.168.2.18/api", "/router");            //设置将字符以"UTF-8"编码输出到客户端浏览器            response.setCharacterEncoding("UTF-8");            //通过设置响应头控制浏览器以UTF-8的编码显示数据,如果不加这句话,那么浏览器显示的将是乱码            response.setHeader("content-type", "application/json; charset=utf-8");            response.getWriter().write(redirect.getBody());        }        log.info("--------------------------------------------------------");    }    @Override    public void destroy() {        Filter.super.destroy();    }
复制代码
代理转发实现

https://www.cnblogs.com/shenjun980326/p/spring-boot-route.html

免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!

本帖子中包含更多资源

您需要 登录 才可以下载或查看,没有账号?立即注册

x
回复

使用道具 举报

0 个回复

倒序浏览

快速回复

您需要登录后才可以回帖 登录 or 立即注册

本版积分规则

干翻全岛蛙蛙

金牌会员
这个人很懒什么都没写!

标签云

快速回复 返回顶部 返回列表