基于SpringCloudGateway实现微服务网关的方式

   4.0.0com.javayznacos-discovery-spring-cloud-gateway0.0.1-SNAPSHOTnacos-discovery-spring-cloud-gatewayDemo project for Spring Boot 1.8UTF-8UTF-82.3.0.RELEASE2.2.1.RELEASE  org.springframework.bootspring-boot-starter-actuator com.alibaba.cloudspring-cloud-starter-alibaba-nacos-discovery com.alibaba.cloudspring-cloud-starter-alibaba-sentinel org.springframework.cloudspring-cloud-starter-gateway org.projectlomboklombok com.alibaba.cspsentinel-spring-cloud-gateway-adapter1.7.2   com.alibaba.cloudspring-cloud-alibaba-dependencies${spring-cloud-alibaba.version}pomimport org.springframework.bootspring-boot-dependencies${spring-boot.version}pomimport org.springframework.cloudspring-cloud-dependenciesHoxton.SR3pomimport   org.apache.maven.pluginsmaven-compiler-plugin 1.81.8UTF-8 org.springframework.bootspring-boot-maven-plugin

 @EnableDiscoveryClient @SpringBootApplication public class NacosDiscoverySpringCloudGatewayApplication { public static void main(String[] args) { SpringApplication.run(NacosDiscoverySpringCloudGatewayApplication.class, args); } }

 server: port: 9090 spring: application: name: nacos-discovery-spring-cloud-gateway cloud: gateway: discovery: locator: enabled: true  #启用discoveryClient网关集成,实现服务发现 routes: - id: route1 uri: lb://nacos-discovery-consumer  #lb://表示负载均衡 predicates:  #判断条件 - Path=/test,/index/**

 predicates: #匹配一个时间，在这个时间之后发生的请求才能访问（格式是ZonedDateTime） - After=2021-03-14T11:31:08.377+08:00[Asia/Shanghai] #匹配一个时间，在这个时间之前发生的请求才能访问（ZonedDateTime） - Before=2021-03-14T11:31:08.377+08:00[Asia/Shanghai] #匹配两个时间，在这个时间之间才能访问 - Between=2021-03-14T11:31:08.377+08:00[Asia/Shanghai],2021-03-14T12:31:08.377+08:00[Asia/Shanghai] #路由断言之间 #路由断言Cookie匹配，匹配给定名称（如master）或者正则表达式，如下面配置，请求的cookie中必须有token=master才能访问 - Cookie=token,master #根据请求头信息匹配，使用方式和cookie类似 - Header=XXX,XXX #根据host地址匹配 - Host=**.somehost.org #根据请求方法匹配 - Method=GET #根据请求路径进行匹配 - Path=*** #根据参数匹配，如果配置为token，则所有的请求必须要带上token=XXX - Query=token #根据远程IP匹配 - RemoteAddr=192.168.1.1/24 #权重,第一个参数是组名，第二个参数是权重，两个route下配置不同权重，会根据权重负载访问 - Weight=group1,8

 uri: http://127.0.0.1:9001  #当访问9090端口时，自动把ip和端口替换为此uri uri: lb://userservice #根据微服务名称拉取请求路径

 server: port: 9090 spring: application: name: nacos-discovery-spring-cloud-gateway cloud: gateway: discovery: locator: enabled: true  #启用discoveryClient网关集成,实现服务发现 routes: - id: route1 uri: lb://nacos-discovery-consumer  #lb://表示负载均衡 predicates:  #判断条件 - Path=/test,/index/**,/** nacos: discovery: server-addr: 192.168.78.128:8848 username: nacos password: nacos sentinel: eager: true transport: dashboard: localhost:8080

 @Data public class TokenConfig { private String token; }

 @Slf4j @Component public class TokenRoutePredicateFactory extends AbstractRoutePredicateFactory { public TokenRoutePredicateFactory(){ super(TokenConfig.class); } //用来把配置中的值变成一个集合 @Override public List shortcutFieldOrder() { return Collections.singletonList("token"); } //通过jdk1.8的断言接口来返回true或者false，如果是true表示过滤器不拦截 @Override public Predicate apply(TokenConfig config) { return exchange ->{ //获取request请求参数 MultiValueMap valueMap=exchange.getRequest().getQueryParams(); boolean flag=false; List list=new ArrayList<>(); //将request请求的value保存到集合里 valueMap.forEach((k,v)->{ list.addAll(v); }); //判断有没有和配置文件中相同的值 for (String s:list){ log.info("Token"+s); if (StringUtils.equalsIgnoreCase(s,config.getToken())){ flag=true; break; } } return flag; }; } }

 predicates:  #判断条件 - Path=/test,/index/**,/** - Token=javayz

 public class MyErrorWebExceptionHandler extends DefaultErrorWebExceptionHandler { public MyErrorWebExceptionHandler(ErrorAttributes errorAttributes, ResourceProperties resourceProperties, ErrorProperties errorProperties, ApplicationContext applicationContext) { super(errorAttributes, resourceProperties, errorProperties, applicationContext); } /** * 指定响应处理方法为JSON处理 * @param errorAttributes * @return */ @Override protected RouterFunction getRoutingFunction(ErrorAttributes errorAttributes) { return RouterFunctions.route(RequestPredicates.all(),this::renderErrorResponse); } /** * 根据code获取对应的HttpStatus * @param errorAttributes * @return */ @Override protected int getHttpStatus(Map errorAttributes) { return (int) errorAttributes.get("status"); } /** * 构建异常信息 * @param request * @param ex * @return */ private String buildMessage(ServerRequest request,Throwable ex){ StringBuilder builder = new StringBuilder("Failed to handle request:"); builder.append(request.methodName()); builder.append(" "); builder.append(request.uri()); if (ex!=null){ builder.append(ex.getMessage()); } return builder.toString(); } /** * 返回的json数据 * @param status * @param errorMsg * @param data * @return */ public static Map response(int status,String errorMsg,Object data){ Map map=new HashMap<>(); map.put("code",status); map.put("message",errorMsg); map.put("data",data); return map; } }

 @Configuration public class GatewayConfiguration { private final ServerProperties serverProperties; private final ApplicationContext applicationContext; private final ResourceProperties resourceProperties; private final List viewResolvers; private final ServerCodecConfigurer serverCodecConfigurer; public GatewayConfiguration(ServerProperties serverProperties, ApplicationContext applicationContext, ResourceProperties resourceProperties, ObjectProvider> viewResolversProvider, ServerCodecConfigurer serverCodecConfigurer) { this.serverProperties = serverProperties; this.applicationContext = applicationContext; this.resourceProperties = resourceProperties; this.viewResolvers = viewResolversProvider.getIfAvailable(Collections::emptyList); this.serverCodecConfigurer = serverCodecConfigurer; } @Bean("myErrorWebExceptionHandler") @Order(Ordered.HIGHEST_PRECEDENCE) public ErrorWebExceptionHandler myErrorWebExceptionHandler(ErrorAttributes errorAttributes){ MyErrorWebExceptionHandler exceptionHandler=new MyErrorWebExceptionHandler( errorAttributes, this.resourceProperties, this.serverProperties.getError(), this.applicationContext ); exceptionHandler.setViewResolvers(this.viewResolvers); exceptionHandler.setMessageWriters(this.serverCodecConfigurer.getWriters()); exceptionHandler.setMessageReaders(this.serverCodecConfigurer.getReaders()); return exceptionHandler; } }

 spring: cloud: gateway: routes: - id: add_request_header_route uri: https://example.org filters: - AddRequestHeader=X-Request-red, blue

 @Component public class GatewayFilter implements GlobalFilter, Ordered { //在里面写过滤器的逻辑 @Override public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) { System.out.println("进入了过滤器"); //表示继续向下执行 return chain.filter(exchange); } //过滤器的优先级，数值越小，优先级越高 @Override public int getOrder() { return 0; } }

 @Component public class GatewayFilter implements GlobalFilter, Ordered { //在里面写过滤器的逻辑 @Override public Mono filter(ServerWebExchange exchange, GatewayFilterChain chain) { System.out.println("进入了过滤器"); String token = exchange.getRequest().getQueryParams().getFirst("access-token"); if (token==null){ //如果不存在，认证失败 System.out.println("没有登陆"); exchange.getResponse().setStatusCode(HttpStatus.UNAUTHORIZED); return exchange.getResponse().setComplete(); } return chain.filter(exchange); } //过滤器的优先级，数值越小，优先级越高 @Override public int getOrder() { return 0; } }

  com.alibaba.cspsentinel-spring-cloud-gateway-adapter1.7.2

 spring: cloud: sentinel: eager: true transport: dashboard: localhost:8080

 @Bean @Order(-1) public GlobalFilter sentinelGatewayFilter(){ return new SentinelGatewayFilter(); }

 @Configuration public class GatewayConfiguration { private final ServerProperties serverProperties; private final ApplicationContext applicationContext; private final ResourceProperties resourceProperties; private final List viewResolvers; private final ServerCodecConfigurer serverCodecConfigurer; public GatewayConfiguration(ServerProperties serverProperties, ApplicationContext applicationContext, ResourceProperties resourceProperties, ObjectProvider> viewResolversProvider, ServerCodecConfigurer serverCodecConfigurer) { this.serverProperties = serverProperties; this.applicationContext = applicationContext; this.resourceProperties = resourceProperties; this.viewResolvers = viewResolversProvider.getIfAvailable(Collections::emptyList); this.serverCodecConfigurer = serverCodecConfigurer; } //自定义一个错误处理 @Bean(name = "myBlockRequestHandler") public BlockRequestHandler myBlockRequestHandler(){ BlockRequestHandler blockRequestHandler=new BlockRequestHandler() { @Override public Mono handleRequest(ServerWebExchange serverWebExchange, Throwable throwable) { return ServerResponse.status(HttpStatus.BAD_GATEWAY) .contentType(MediaType.APPLICATION_JSON) .body(BodyInserters.fromValue("服务被限流了")); } }; return blockRequestHandler; } //用自定义的handler替换掉默认的，或者重定向 @Bean @Order(Ordered.HIGHEST_PRECEDENCE) public SentinelGatewayBlockExceptionHandler sentinelGatewayBlockExceptionHandler(BlockRequestHandler myBlockRequestHandler){ //自定义Block处理 GatewayCallbackManager.setBlockHandler(myBlockRequestHandler); //重定向block处理 //GatewayCallbackManager.setBlockHandler(new RedirectBlockRequestHandler("http://www.baidu.com")); return new SentinelGatewayBlockExceptionHandler(viewResolvers,serverCodecConfigurer); } @Bean @Order(-1) public GlobalFilter sentinelGatewayFilter(){ return new SentinelGatewayFilter(); } }

 @Configuration public class CorsConfig { @Bean public CorsWebFilter corsWebFilter(){ CorsConfiguration configuration=new CorsConfiguration(); configuration.addAllowedHeader("*"); configuration.addAllowedMethod("*"); configuration.addAllowedOrigin("*"); UrlBasedCorsConfigurationSource source=new UrlBasedCorsConfigurationSource(new PathPatternParser()); source.registerCorsConfiguration("/*",configuration); return new CorsWebFilter(source); } }