6.springcloud微服务架构搭建 之 《springboot集成Gateway》

5.springcloud微服务架构搭建 之 《springboot集成Hystrix》

目录

1.gateway介绍

2.项目引入gateway

3.yml配置gateway参数

5.自定义全局Filter

6.测试

---

1.gateway介绍

        服务网关（Spring Cloud Gateway）是Spring Cloud官方推出的 第二代网关框架，用于替代第一代网关Netflix Zuul，其不仅提供统 一的路由方式，并且基于Filter链的方式提供了网关的基本功能。服 务网关建立在Spring Framework 5之上，使用非阻塞模式，并且支持 长连接Websocket。Netflix Zuul是基于Servlet的，采用HttpClient 进行请求转发，使用阻塞模式。在性能上，服务网关优于Netflix Zuul，并且服务网关几乎实现了Netflix Zuul的全部功能。在使用和 功能上，用服务网关替换掉Netflix Zuul的成本上是非常低的，几乎 可以实现无缝切换。

        服务网关作为整个分布式系统的流量入口，有着举足轻重的作 用，列举如下。

•         协议转换，路由转发。
•         流量聚合，对流量进行监控，日志输出。
•         作为整个系统的前端工程，对流量进行控制，有限流的作用。
•         作为系统的前端边界，外部流量只能通过网关才能访问系统。
•         可以在网关层做权限判断。 可以在网关层做缓存。

2.项目引入gateway

<?xml version="1.0" encoding="UTF-8"?>
<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"><parent><artifactId>lilock-modules</artifactId><groupId>lilock.cn</groupId><version>1.0-SNAPSHOT</version></parent><modelVersion>4.0.0</modelVersion><artifactId>lilock-service-gateway</artifactId><dependencies><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency><!-- getway 配置 loadbalancer 之后lb才会生效--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build>
</project>

3.yml配置gateway参数

server:port: 9090spring:application:name: lilock-service-gatewaycloud:nacos:discovery:server-addr: 127.0.0.1:8848namespace: devregister-enabled: truegroup: DEFAULT_GROUPgateway:discovery:locator:lower-case-service-id: trueenabled: trueroutes:- id: lilock-service-useruri: lb://lilock-service-userpredicates:- Path=/api-user/**filters:- StripPrefix=1 #替换前缀，如果是/api-user/访问的地址，则会通过/api-user/获取到对应服务lilock-service-user，再通过lilock-service-user获取到对应的服务IP和端口，完成一次完整请求main:allow-bean-definition-overriding: true

4.测试

5.自定义全局Filter

 

package lilock.cn.gateway.filter;import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;@Component
public class RequestTimeFilter implements GlobalFilter, Ordered {private static Logger log = LoggerFactory.getLogger(RequestTimeFilter.class);private static final String REQUEST_TIME_BEGIN = "requestBeginTime";@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {exchange.getAttributes().put(REQUEST_TIME_BEGIN,System.currentTimeMillis());return chain.filter(exchange).then(Mono.fromRunnable(()->{Long startTime = (Long) exchange.getAttributes().get(REQUEST_TIME_BEGIN);if(null != startTime){log.info(exchange.getRequest().getURI().getRawPath() + ":" + (System.currentTimeMillis() - startTime) + "ms");}}));}@Overridepublic int getOrder() {return HIGHEST_PRECEDENCE + 2;}
}

 

6.测试