当前位置：首页 > ai >正文

Gateway 搭建

ai 2025/6/29 20:05:25

1.创建 moudle 命名为 gateway

2,pom中引入依赖网关依赖；注册中心依赖等

<!--        网关依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-gateway</artifactId></dependency>
<!--     nacos注册中心   --><dependency><groupId>com.alibaba.cloud</groupId><artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId></dependency>
<!--        负载均衡--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-loadbalancer</artifactId></dependency>

创建启动类

配置yml文件

spring:application:name: gatewaycloud:nacos:discovery:server-addr: 127.0.0.1:8848
server:port: 80

测试启动成功

配置请求分发路径

spring:application:name: gatewaycloud:nacos:discovery:server-addr: 127.0.0.1:8848gateway:routes:- id: order-route  # 路由名称uri: lb://order  # 路由要转发的服务 格式为固定的  lb:// 服务名predicates: # 断言- Path=/api/order/**  # 路径为 /api/order/** 的请求专项order服务- id: product-routeuri: lb://productpredicates:- Path=/api/product/**

网关路径重写示例：

例如：请求的全路径为 /api/order/getOrder经过网关后将请求地址省略为 /getOrder

filters:- RewritePath=/red/?(?<segment>.*),/$\{segment}

自定义网关全局过滤器

package gateway.filter;import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.Ordered;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;//自定义全局过滤器
@Component
public class RtGlobalFiler implements GlobalFilter, Ordered {@Overridepublic Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {ServerHttpRequest request = exchange.getRequest();ServerHttpResponse response = exchange.getResponse();String string = request.getURI().toString();System.out.println("当前操作时间"+System.currentTimeMillis()+"操做的地址:"+string);Mono<Void> doFinally = chain.filter(exchange).doFinally((result) -> {System.out.println("当前操作的结束时间" + System.currentTimeMillis());});return doFinally;}@Overridepublic int getOrder() {return 0;}
}

gateway yml 跨域配置