springcloud脚手架搭建(四)---zuul网关搭建

分手后的思念是犯贱 2022-06-02 09:36 271阅读 0赞

1.引入pom.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  3.     <modelVersion>4.0.0</modelVersion>
  5.     <groupId>com.gameley</groupId>
  6.     <artifactId>gateway-service</artifactId>
  7.     <version>1.0.0-SNAPSHOT</version>
  8.     <packaging>jar</packaging>
  10.     <name>gateway-service</name>
  11.     <description>Demo project for Spring Boot</description>
  13.     <parent>
  14.         <groupId>com.gameley</groupId>
  15.         <artifactId>adplatform</artifactId>
  16.         <version>1.0.0-SNAPSHOT</version>
  17.     </parent>
  21.     <dependencies>
  22.         <dependency>
  23.             <groupId>org.springframework.cloud</groupId>
  24.             <artifactId>spring-cloud-starter-eureka</artifactId>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.springframework.cloud</groupId>
  28.             <artifactId>spring-cloud-starter-zuul</artifactId>
  29.         </dependency>
  30.         <dependency>
  31.             <groupId>org.springframework.boot</groupId>
  32.             <artifactId>spring-boot-starter-web</artifactId>
  33.             <exclusions>
  34.                 <exclusion>
  35.                     <groupId>org.springframework.boot</groupId>
  36.                     <artifactId>spring-boot-starter-tomcat</artifactId>
  37.                 </exclusion>
  38.             </exclusions>
  39.         </dependency>
  40.         <dependency>
  41.             <groupId>org.springframework.boot</groupId>
  42.             <artifactId>spring-boot-starter-jetty</artifactId>
  43.         </dependency>
  44.         <dependency>
  45.             <groupId>org.springframework.boot</groupId>
  46.             <artifactId>spring-boot-starter-actuator</artifactId>
  47.         </dependency>
  48.         <!--<dependency>-->
  49.             <!--<groupId>org.springframework.cloud</groupId>-->
  50.             <!--<artifactId>spring-cloud-sleuth-zipkin-stream</artifactId>-->
  52.         <!--</dependency>-->
  53.         <!--<dependency>-->
  54.             <!--<groupId>org.springframework.cloud</groupId>-->
  55.             <!--<artifactId>spring-cloud-starter-stream-rabbit</artifactId>-->
  56.         <!--</dependency>-->
  57.         <dependency>
  58.             <groupId>io.jsonwebtoken</groupId>
  59.             <artifactId>jjwt</artifactId>
  60.             <version>0.6.0</version>
  61.         </dependency>
  62.         <dependency>
  63.             <groupId>com.alibaba</groupId>
  64.             <artifactId>fastjson</artifactId>
  65.             <version>1.2.33</version>
  66.         </dependency>
  67.         <dependency>
  68.             <groupId>org.projectlombok</groupId>
  69.             <artifactId>lombok</artifactId>
  70.             <version>1.16.14</version>
  71.             <scope>provided</scope>
  72.         </dependency>
  73.         <dependency>
  74.             <groupId>com.gameley</groupId>
  75.             <artifactId>gameley-common</artifactId>
  76.             <version>1.0</version>
  77.         </dependency>
  78.         <dependency>
  79.             <groupId>org.springframework.cloud</groupId>
  80.             <artifactId>spring-cloud-starter-feign</artifactId>
  81.         </dependency>
  82.         <dependency>
  83.             <groupId>org.springframework.boot</groupId>
  84.             <artifactId>spring-boot-starter-aop</artifactId>
  85.         </dependency>
  87.         <!--<dependency>-->
  88.             <!--<groupId>org.springframework.cloud</groupId>-->
  89.             <!--<artifactId>spring-cloud-starter-zipkin</artifactId>-->
  90.             <!--<version>RELEASE</version>-->
  91.         <!--</dependency>-->
  93.     </dependencies>
  95.     <build>
  96.         <plugins>
  97.             <plugin>
  98.                 <groupId>org.springframework.boot</groupId>
  99.                 <artifactId>spring-boot-maven-plugin</artifactId>
  100.             </plugin>
  101.         </plugins>
  102.     </build>
  105. </project>

2.配置zuul：

  1. zuul:
  2.   routes:
  3.     api-a:
  4.       path: /user-api/**
  5.       serviceId: user-service
  6.     api-b:
  7.           path: /gameley-auth/**
  8.           serviceId: gameley-auth
  9.   prefix: /api #为zuul设置一个公共的前缀

3.创建springboot启动类

  1. package com.gameley;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
  6. import org.springframework.cloud.netflix.feign.EnableFeignClients;
  7. import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
  8. import org.springframework.context.annotation.Bean;
  9. import org.springframework.web.cors.CorsConfiguration;
  10. import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
  11. import org.springframework.web.filter.CorsFilter;
  13. @SpringBootApplication
  14. @EnableZuulProxy
  15. @EnableEurekaClient
  16. @EnableFeignClients
  17. public class GatewayServiceApplication {
  19.     public static void main(String[] args) {
  20.         SpringApplication.run(GatewayServiceApplication.class, args);
  21.     }
  23.     /** * 解决跨域问题 * @return */
  24.     @Bean
  25.     public CorsFilter corsFilter() {
  26.         final UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
  27.         final CorsConfiguration config = new CorsConfiguration();
  28.         config.setAllowCredentials(true); // 允许cookies跨域
  29.         config.addAllowedOrigin("*");// #允许向该服务器提交请求的URI，*表示全部允许
  30.         config.addAllowedHeader("*");// #允许访问的头信息,*表示全部
  31.         config.setMaxAge(18000L);// 预检请求的缓存时间（秒），即在这个时间段里，对于相同的跨域请求不会再预检了
  32.         config.addAllowedMethod("*");// 允许提交请求的方法，*表示全部允许，也可以单独设置GET、PUT等
  33.         config.addAllowedMethod("HEAD");
  34.         config.addAllowedMethod("GET");// 允许Get的请求方法
  35.         config.addAllowedMethod("PUT");
  36.         config.addAllowedMethod("POST");
  37.         config.addAllowedMethod("DELETE");
  38.         config.addAllowedMethod("PATCH");
  39.         source.registerCorsConfiguration("/**", config);
  40.         return new CorsFilter(source);
  41.     }
  42. }

4.配置登录拦截器

  1. package com.gameley.filter;
  3. import com.alibaba.fastjson.JSON;
  4. import com.gameley.bean.Audience;
  5. import com.gameley.bean.JwtInfo;
  7. import com.gameley.common.constant.RestCodeConstants;
  8. import com.gameley.common.msg.auth.TokenErrorResponse;
  10. import com.gameley.feign.ElementService;
  11. import com.gameley.utils.JwtHelper;
  12. import com.netflix.zuul.ZuulFilter;
  13. import com.netflix.zuul.context.RequestContext;
  14. import io.jsonwebtoken.Claims;
  15. import lombok.extern.slf4j.Slf4j;
  16. import org.springframework.beans.factory.annotation.Autowired;
  17. import org.springframework.beans.factory.annotation.Value;
  18. import org.springframework.boot.context.properties.EnableConfigurationProperties;
  19. import org.springframework.stereotype.Component;
  21. import javax.servlet.http.HttpServletRequest;
  23. @EnableConfigurationProperties(Audience.class)
  24. @Slf4j
  25. @Component
  26. public class loginfiler extends ZuulFilter { 
  28.     @Autowired
  29.     ElementService iUserService;
  30.     @Override
  31.     public String filterType() {
  32.         return "pre";
  33.     }
  35.     @Override
  36.     public int filterOrder() {
  37.         return 0;
  38.     }
  39.     @Value("${zuul.prefix}")
  40.     private String zuulPrefix;
  41.     @Value("${gate.ignore.startWith}")
  42.     private String startWith;
  44.     @Autowired
  45.     private  Audience audience;
  46.     @Override
  47.     public boolean shouldFilter() {
  48.         return true;
  49.     }
  51.     @Override
  52.     public Object run() {
  53.         RequestContext ctx = RequestContext.getCurrentContext();
  54.         HttpServletRequest request = ctx.getRequest();
  55.         final String requesturi=request.getRequestURI().substring(zuulPrefix.length());
  56.         String token=request.getHeader("token");
  57.         String client=request.getHeader("client");
  58.         //不进行拦截的地址
  59.         if(isStartWith(requesturi)){
  60.             return null;
  61.         }
  62.         /** * 未登录，踢出 */
  63.         if(token==null||client==null){
  64.             ctx.setSendZuulResponse(false);// 过滤该请求，不对其进行路由
  65.             ctx.setResponseStatusCode(RestCodeConstants.TOKEN_ERROR_CODE);// 返回错误码
  66.             ctx.setResponseBody("fail token");// 返回错误内容
  67.             ctx.set("isSuccess", false);
  68.             return null;
  69.         }
  71.         try {
  72.             JwtInfo jwtInfo=new JwtInfo();
  73.             jwtInfo.setToken(token);
  74.             jwtInfo.setClientId(audience.getClientId());
  75.             jwtInfo.setExpiresSecond(audience.getExpiresSecond());
  76.             jwtInfo.setName(audience.getName());
  77.             JwtHelper jwtHelper=new JwtHelper();
  78.             jwtHelper.setJwtInfo(jwtInfo);
  79.             Claims claims = jwtHelper.parseJWT(token, audience.getBase64Secret());
  80.             Claims clientClaims = jwtHelper.parseJWT(client, audience.getClient64Secret());
  83.             if(claims==null||clientClaims==null){
  84.                 /** * 暂不使用后台自动刷新，改为前端页面定时自动拉取刷新 */
  85.                 setFailedRequest("token过期", RestCodeConstants.TOKEN_ERROR_CODE);
  86.                 return null;
  87. // String refreshToken=jwtInfo.getToken();
  88. // ctx.addZuulRequestHeader("token",refreshToken);
  89. // ctx.addZuulResponseHeader("token",refreshToken);
  90.             }else {
  92.                 ctx.addZuulRequestHeader("token",token);
  93.             }
  96.         } catch (Exception e) {
  97.             setFailedRequest(JSON.toJSONString(new TokenErrorResponse(e.getMessage())), RestCodeConstants.TOKEN_ERROR_CODE);
  98.             return null;
  99.         }
  102.         return null;
  103.     }
  106.     /** * URI是否以什么打头 * * @param requestUri * @return */
  107.     private boolean isStartWith(String requestUri) {
  108.         boolean flag = false;
  109.         for (String s : startWith.split(",")) {
  110.             if (requestUri.startsWith(s)) {
  111.                 return true;
  112.             }
  113.         }
  114.         return flag;
  115.     }
  117.     /** * 网关抛异常 * * @param body * @param code */
  118.     private void setFailedRequest(String body, int code) {
  120.         log.debug("Reporting error ({}): {}", code, body);
  121.         RequestContext ctx = RequestContext.getCurrentContext();
  122.         ctx.setResponseStatusCode(code);
  123.         if (ctx.getResponseBody() == null) {
  124.             ctx.setResponseBody(body);
  125.             ctx.setSendZuulResponse(false);
  126.         }
  127.     }
  128. }

5.备注：这里登录使用的为jwt-token（https://www.jianshu.com/p/576dbf44b2ae）

发表评论

表情：
评论列表 （有 0 条评论，271人围观）

还没有评论，来说两句吧...

相关阅读