一、前言
生產環(huán)境中所有的請求入口都是統一的,一般用Nginx->Gateway。微服務之間相互調用是走內網。Gateway是所有服務對外的入口。在Gateway上可以做權限的認證和攔截。
二、Maven依賴
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<parent>
<groupId>com.llh</groupId>
<artifactId>parent</artifactId>
<version>1.0.0</version>
<relativePath/>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>gateway</artifactId>
<version>1.0.0</version>
<name>gateway</name>
<description>gateway description</description>
<packaging>jar</packaging>
<dependencies>
<!--服務注冊與發(fā)現-->
<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-gateway</artifactId>
</dependency>
<!--負載均衡器-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-loadbalancer</artifactId>
</dependency>
</dependencies>
</project>
三、配置文件 application.properties
server.port=20000
# 應用名稱
spring.application.name=gateway
# nacos服務注冊相關
spring.cloud.nacos.discovery.server-addr=http://localhost:8848
spring.cloud.nacos.discovery.namespace=83e9d384-d49e-4f40-84bf-c25612883dcc
spring.cloud.nacos.discovery.username=nacos
spring.cloud.nacos.discovery.password=nacos
# 網關相關
spring.cloud.gateway.discovery.locator.enabled=true
spring.cloud.gateway.discovery.locator.lower-case-service-id=true
spring.cloud.gateway.routes[0].id=consumer
spring.cloud.gateway.routes[0].uri=lb://consumer
spring.cloud.gateway.routes[0].predicates[0]=Path=/order/**
spring.cloud.gateway.routes[0].filters[0]=StripPrefix=1
- 這里做了路由更改,所有/order開頭的接口會路由到
consumer服務上的接口。
四、自定義Filter
MyFilter類
package com.llh.gateway;
import org.springframework.http.server.reactive.ServerHttpRequest;
import org.springframework.stereotype.Component;
import org.springframework.web.server.ServerWebExchange;
import org.springframework.web.server.WebFilter;
import org.springframework.web.server.WebFilterChain;
import reactor.core.publisher.Mono;
/**
* @author 小虎哥的技術博客
*/
@Component
public class MyFilter implements WebFilter{
@Override
public Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
ServerHttpRequest request = exchange.getRequest();
String path = request.getPath().toString();
// 打印請求路徑,生產環(huán)境可以在此做一些權限認證等
System.out.println(path);
return chain.filter(exchange);
}
}
- 所有的請求都會通過這個攔截器,這里只是打印了一下請求路徑,生產環(huán)境可以在此做一些權限認證等
五、運行
請求網關的接口都會被轉發(fā)到具體的服務中
請求接口: 網關ip:網關port/服務名/服務內部接口
如 http://localhost:20000/consumer/consumer/buy/1/1
因為做了路由的轉發(fā)
http://localhost:20000/order/consumer/buy/1/1
就等于
http://localhost:20000/consumer/consumer/buy/1/1
六、結語
源碼地址:https://github.com/tigerleeli/xiaohuge-blog/tree/master/spring-cloud-alibaba-gateway
同步微信公眾號:小虎哥的技術博客